Crate icee_rabbit_rs 

Structs

AmqpConsumer

AmqpConsumer holds open channel and consumes all messages from given queue

AmqpPublisher

AmqpPublisher holds open channel and publish messages to given exchange/routing_key

FieldTable

Re-export of lapin::types::FieldTable A Map<String, AMQPValue>

Message

Message constructed from AmqpMessage

QueueSettings

QueueSettings for declaring RabbitMq queue within consumer & publisher

Functions

init

Initialize RabbitMq connection Must be called before using consumers or publishers

Type Aliases

DeliveryCallback

Consumer callback processing each message