GetDefaultClientOptions describes the options that will be used when a value isn't provided.

GetDefaultConsumeOptions descibes the options that will be used when a value isn't provided.

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

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

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

WithClientOptionsQueueArgs adds optional args to the queue.

WithClientOptionsQueueAutoDelete ensures the queue is an auto-delete queue.

WithClientOptionsQueueDurable ensures the queue is a durable queue.

WithClientOptionsQueueExclusive ensures the queue is an exclusive queue.

WithClientPublishOptionsImmediate 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 return channel for you to handle.

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

WithRabbitMqClientGroupName set group name address.

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

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

WithRabbitMqConsumeOptionsBindingRoutingKeys returns a function that sets the exchange name the RoutingKeys will be bound to.

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

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

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

WithRabbitMqConsumeOptionsExchangeDeclare returns a function that sets the exchange is a passive exchange.

WithRabbitMqConsumeOptionsExchangeDurable returns a function that sets the exchange is a durable exchange.

WithRabbitMqConsumeOptionsExchangePassive returns a function that sets the exchange is a passive exchange.

WithRabbitMqConsumeOptionsQOSPrefetch 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.

WithRabbitMqPublishGroupName set group name address.

WithRabbitMqPublishOptionsAppID returns a function that sets the application id.

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

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

WithRabbitMqPublishOptionsMessageID returns a function that sets the message identifier.

WithRabbitMqPublishOptionsReplyTo returns a function that sets the reply to field.

WithRabbitMqPublishOptionsUserID returns a function that sets the user id i.e.

WithRocketMqGroupName set group name address.

WithRocketMqMaxReconsumeTimes set MaxReconsumeTimes of options, if message reconsume greater than MaxReconsumeTimes, it will be sent to retry or dlq topic.

WithRocketMqPublishGroupName set group name address.

WithRocketMqPublishRetry return an Option that specifies the retry times when send failed.

BindingExchangeOptions are used when binding to an exchange.

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

ExchangeOptions are used to configure an exchange.

PublishOptions are used to control how data is published.

QueueOptions are used to configure a queue.