NewConsumer returns a new Consumer connected to the given rabbitmq server.

NewPublisher returns a new publisher with an open channel to the cluster.

WithConsumeOptionsBindingExchangeArgs returns a function that sets the binding exchange arguments that are specific to the server's implementation of the exchange.

WithConsumeOptionsBindingExchangeAutoDelete returns a function that sets the binding exchange autoDelete flag.

WithConsumeOptionsBindingExchangeDurable returns a function that sets the binding exchange durable flag.

WithConsumeOptionsBindingExchangeInternal returns a function that sets the binding exchange internal flag.

WithConsumeOptionsBindingExchangeKind returns a function that sets the binding exchange kind/type.

WithConsumeOptionsBindingExchangeName returns a function that sets the exchange name the queue will be bound to.

WithConsumeOptionsBindingExchangeNoWait returns a function that sets the binding exchange noWait flag.

WithConsumeOptionsBindingNoWait sets the bindings to nowait, which means if the queue can not be bound the channel will not be closed with an error.

WithConsumeOptionsConcurrency returns a function that sets the concurrency, which means that many goroutines will be spawned to run the provided handler on messages.

WithConsumeOptionsConsumerAutoAck returns a function that sets the auto acknowledge property on the server of this consumer if unset the default will be used (false).

WithConsumeOptionsConsumerExclusive sets the consumer to exclusive, which means the server will ensure that this is the sole consumer from this queue.

WithConsumeOptionsConsumerName returns a function that sets the name on the server of this consumer if unset a random name will be given.

WithConsumeOptionsConsumerNoWait sets the consumer to nowait, which means it does not wait for the server to confirm the request and immediately begin deliveries.

WithConsumeOptionsQOSGlobal sets the qos on the channel to global, which means these QOS settings apply to ALL existing and future consumers on all channels on the same connection.

WithConsumeOptionsQOSPrefetch returns a function that sets the prefetch count, which means that many messages will be fetched from the server in advance to help with throughput.

WithConsumeOptionsQueueAutoDelete sets the queue to auto delete, which means it will be deleted when there are no more conusmers on it.

WithConsumeOptionsQueueDurable sets the queue to durable, which means it won't be destroyed when the server restarts.

WithConsumeOptionsQueueExclusive sets the queue to exclusive, which means it's are only accessible by the connection that declares it and will be deleted when the connection closes.

WithConsumeOptionsQueueNoWait sets the queue to nowait, which means the queue will assume to be declared on the server.

WithConsumeOptionsQuorum sets the queue a quorum type, which means multiple nodes in the cluster will have the messages distributed amongst them for higher reliability.

WithPublishOptionsContentType returns a function that sets the content type, i.e.

WithPublishOptionsExchange returns a function that sets the exchange to publish to.

WithPublishOptionsExpiration returns a function that sets the expiry/TTL of a message.

WithPublishOptionsHeaders returns a function that sets message header values, i.e.

WithPublishOptionsImmediate makes the publishing immediate, which means when a consumer is not available to immediately handle the new message, a message will be sent back on the returns channel for you to handle.

WithPublishOptionsMandatory makes the publishing mandatory, which means when a queue is not bound to the routing key a message will be sent back on the returns channel for you to handle.

WithPublishOptionsPersistentDelivery sets the message to persist.

DeliveryMode.

DeliveryMode.

BindingExchangeOptions are used when binding to an exchange.

ConsumeOptions are used to describe how a new consumer will be created.

Consumer allows you to create and connect to queues for data consumption.

Publisher allows you to publish messages safely across an open connection.

PublishOptions are used to control how data is published.