producer

Jun 4, 2024

Changes in this version

+ func MarshalMessageBatch(msgs ...*primitive.Message) []byte

+ func NewDefaultProducer(opts ...Option) (*defaultProducer, error)

+ func NewTransactionProducer(listener primitive.TransactionListener, opts ...Option) (*transactionProducer, error)

+ type Option func(*producerOptions)

+ func WithCompressLevel(level int) Option

+ func WithCompressMsgBodyOverHowmuch(threshold int) Option

+ func WithCreateTopicKey(topic string) Option

+ func WithCredentials(c primitive.Credentials) Option

+ func WithDefaultTopicQueueNums(queueNum int) Option

+ func WithGroupName(group string) Option

+ func WithInstanceName(name string) Option

+ func WithInterceptor(f ...primitive.Interceptor) Option

+ func WithNameServer(nameServers primitive.NamesrvAddr) Option

+ func WithNameServerDomain(nameServerUrl string) Option

+ func WithNamespace(namespace string) Option

+ func WithNsResolver(resolver primitive.NsResolver) Option

+ func WithQueueSelector(s QueueSelector) Option

+ func WithRetry(retries int) Option

+ func WithSendMsgTimeout(duration time.Duration) Option

+ func WithTrace(traceCfg *primitive.TraceConfig) Option

+ func WithUnitName(unitName string) Option

+ func WithVIPChannel(enable bool) Option

+ type QueueSelector interface

+ Select func(msg *primitive.Message, mqs []*primitive.MessageQueue, lastBrokerName string) *primitive.MessageQueue

+ func NewHashQueueSelector() QueueSelector

+ func NewManualQueueSelector() QueueSelector

+ func NewRandomQueueSelector() QueueSelector

+ func NewRoundRobinQueueSelector() QueueSelector