Message Broker Queues Module

async action_triggers.msg_broker_queues.process_msg_broker_queue(msg_broker_queue: MessageBrokerQueue, payload: str | dict) → None[source]

Process the action for the message broker queue.

Parameters:

  • msg_broker_queue (MessageBrokerQueue) – The message broker queue object to process.

  • payload (Union[str, dict]) – The payload to send to the message broker queue.

Returns:

None