MessageID returns a MessageID valuer.

RedeliveryCount returns a RedeliveryCount valuer.

Topic returns a Topic valuer.

WithGroup sets the consumer group to be part of when consuming events.

WithMetadata sets the Metadata field on PublishOptions.

WithRetryLimit sets the RetryLimit field on ConsumeOptions.

WithTimestamp sets the timestamp field on PublishOptions.

默认工作池大小.

清理回收周期.

阻塞, 无可用协程则等待.

消费失败, 需要重传, 不进行ACK.

消费负载异常, 不需要重传, 进行ACK.

重传消费超过限制次数, 不再重传, 进行ACK.

消费成功, 不再重传, 进行ACK.

ConsumeOptions contains all the options which can be provided when subscribing to a topic.

PublishOptions contains all the options which can be provided when publishing an event.

ConsumeOption sets attributes on ConsumeOptions.

PublishOption sets attributes on PublishOptions.