Structs§
- AmqpConsumer holds open channel and consumes all messages from given queue
- AmqpPublisher holds open channel and publish messages to given exchange/routing_key
- Re-export of lapin::types::FieldTable A Map<String, AMQPValue>
- Message constructed from AmqpMessage
- QueueSettings for declaring RabbitMq queue within consumer & publisher
Functions§
- Initialize RabbitMq connection Must be called before using consumers or publishers
Type Aliases§
- Consumer callback processing each message