rocketmq

Jun 7, 2022

Changes in this version

type Config

+ Logger log.ILogger

Jan 11, 2022

Changes in this version

+ func NewBroker(config Config) (broker.IBroker, error)

+ type Broker struct

+ func (b *Broker) Close() error

+ func (b *Broker) Send(ctx context.Context, name string, body interface{}) error

+ func (b *Broker) SendDelay(ctx context.Context, name string, body interface{}, delay time.Duration) error

+ func (b *Broker) Worker() error

+ type Config struct

+ AllocateStrategy func(string, string, []*primitive.MessageQueue, []string) []*primitive.MessageQueue

+ BroadCasting bool

+ Codec codec.Codec

+ ConsumerGroupName string

+ Hosts []string

+ InstanceName string

+ Order bool

+ ProducerGroupName string

+ RetryMaxReconsume uint8

+ Topic string