AckOnSuccess will automatically acknowledge messages when no error is returned.

AppID sets a property application id for publishing.

ContentEncoding sets a property MIME content encoding for publishing.

ContentType sets a property MIME content type for publishing.

CorrelationID sets a property correlation ID for publishing.

DelayQueue Declare this to be a delayed queue.

DeliveryMode sets a delivery mode for publishing.

DurableExchange is an option to set the Exchange to be durable.

DurableQueue creates a durable queue when subscribing.

ExchangeName is an option to set the ExchangeName.

Expiration sets a property message expiration spec for publishing.

FanoutExchange is set exchange type to fanout , default exchange is topic.

Headers adds headers used by the headers exchange.

MessageId sets a property message identifier for publishing.

PrefetchCount ...

PrefetchGlobal creates a durable queue when subscribing.

Priority sets a priority level for publishing.

QueueArguments sets arguments for queue creation.

ReplyTo sets a property address to to reply to (ex: RPC) for publishing.

RequeueOnError calls Nack(muliple:false, requeue:true) on amqp delivery when handler returns error.

SubscribeContext set the context for broker.SubscribeOption.

Timestamp sets a property message timestamp for publishing.

TypeMsg sets a property message type name for publishing.

UserID sets a property user id for publishing.

DefaultDelayExchange 延时队列交换机* @auth liqi [email protected] */.

Exchange is the rabbitmq exchange.