X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fcommon.git;a=blobdiff_plain;f=osm_common%2Fmsglocal.py;fp=osm_common%2Fmsglocal.py;h=2f9030763274ac0073e97d2e7d4c401cd213085b;hp=c10ff17b0808c6e649755f3e7886b33db8d4ecf3;hb=3dd0db6efaab109fa1bd43395fbbddecf1eb73d4;hpb=3d82ba2cc4c3ebb340a88400aaa4a8d3683806a1 diff --git a/osm_common/msglocal.py b/osm_common/msglocal.py index c10ff17..2f90307 100644 --- a/osm_common/msglocal.py +++ b/osm_common/msglocal.py @@ -15,16 +15,16 @@ # See the License for the specific language governing permissions and # limitations under the License. +import asyncio +from http import HTTPStatus import logging import os -import yaml -import asyncio -from osm_common.msgbase import MsgBase, MsgException from time import sleep -from http import HTTPStatus -__author__ = "Alfonso Tierno " +from osm_common.msgbase import MsgBase, MsgException +import yaml +__author__ = "Alfonso Tierno " """ This emulated kafka bus by just using a shared file system. Useful for testing or devops. One file is used per topic. Only one producer and one consumer is allowed per topic. Both consumer and producer