Module mcai_worker_sdk::message_exchange::rabbitmq[−][src]

Implements a RabbitMQ MessageExchange

Modules

channels

Structs

CurrentOrders
RabbitmqConnection
RabbitmqConsumer
RabbitmqExchange
RabbitmqPublisher

Statics

DIRECT_MESSAGING_NOT_FOUND
EXCHANGE_NAME_DELAYED
EXCHANGE_NAME_DIRECT_MESSAGING
EXCHANGE_NAME_JOB_RESPONSE
EXCHANGE_NAME_RESPONSE_DELAYED
EXCHANGE_NAME_SUBMIT
EXCHANGE_NAME_WORKER_RESPONSE
JOB_QUEUE_NOT_FOUND
JOB_RESPONSE_NOT_FOUND
QUEUE_JOB_COMPLETED
QUEUE_JOB_ERROR
QUEUE_JOB_PROGRESSION
QUEUE_JOB_STOPPED
QUEUE_WORKER_CREATED
QUEUE_WORKER_DISCOVERY
QUEUE_WORKER_INITIALIZED
QUEUE_WORKER_STARTED
QUEUE_WORKER_STATUS
QUEUE_WORKER_TERMINATED
QUEUE_WORKER_UPDATED
WORKER_RESPONSE_NOT_FOUND