src/services/mq_service.py

import streamlit as st

from project import Config
from project.adapters import MessageQueueOutAdapterImpl, OutAdapter


class PrintingOutAdapter(OutAdapter):
    def send_message(self, message):
        print(f"Publishing message: \n {message}")


@st.cache_resource
def create_out_adapter(_config: Config, queue_dest: str) -> OutAdapter:
    if _config.mq_user == "local":
        return PrintingOutAdapter()
    else:
        return MessageQueueOutAdapterImpl(_config, queue_dest)