File size: 480 Bytes
4b63644 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | from project import Config
from project.adapters.out_adapter import OutAdapter
from wrapper import MessageQueue
class MessageQueueOutAdapterImpl(OutAdapter):
def __init__(self, config: Config, queue_name: str) -> None:
self.__config = config
# initialize queue
self.__queue = MessageQueue(config.mq_host, config.mq_user, config.mq_password, queue_name)
def send_message(self, message: bytes) -> None:
self.__queue.send_message(message)
|