src/project/adapters/message_queue_out_adapter_impl.py

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)