NewSubscriber creates a new RabbitMQ consumer.

WithDurableFanoutExchange declare a fanout exchange an bind it to the consumer queue.

WithDurablePriorityQueue defines a named durable queue for consumer with priority.

WithDurableQueue defines a named durable queue for consumer.

WithDurableTopicExchange declare a topic exchange and bind it to the consumer queue.

WithName set consumer name.

WithPrefetch set prefetch count, and size.

ExchangeTypeDirect represents a direct exchange type.

ExchangeTypeFanout represents a fanout exchange type.

ExchangeTypeHeaders represents a header exchange type.

ExchangeTypeTopic represents a topic exchange type.

Exchange contains exchange settings.

ExchangeType represents the RabbitMQ exchange type.

Option is a subscriber option used to customize the consumer.