Method send_message

shared/queueclient/QueueClient.py:62–79

Publishes a message to rabbit MQ. For now its using the default actions exchange. But we can modify this wrapper to include more paremeters for the exchange name. :param message: :param routing_key: :param exchange: :return:

(self,
                     message: dict,
                     routing_key: str,
                     exchange: str)

            exchange_type = ExchangeType.direct.value)

    def send_message(self,
                     message: dict,
                     routing_key: str,
                     exchange: str):
        """
            Publishes a message to rabbit MQ. For now its using the default
            actions exchange. But we can modify this wrapper to include more paremeters
            for the exchange name.
        :param message:
        :param routing_key:
        :param exchange:
        :return:
        """
        self.main_channel.basic_publish(
            exchange = exchange,
            routing_key = routing_key,
            body = json.dumps(message).encode('utf-8'),
            properties = pika.BasicProperties(content_type = 'application/json'))