rocketmq

Documentation

Index

• func NewBroker(config Config) (broker.IBroker, error)
• type Broker
  • func (b *Broker) Close() error
  • func (b *Broker) Send(ctx context.Context, name string, value interface{}) error
  • func (b *Broker) SendDelay(ctx context.Context, name string, value interface{}, delay time.Duration) error
  • func (b *Broker) Worker() error
• type Config

Functions

func NewBroker

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

Types

type Broker

type Broker struct {
	*broker.Broker
	// contains filtered or unexported fields
}

func (*Broker) Close

func (b *Broker) Close() error

func (*Broker) Send

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

func (*Broker) SendDelay

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

func (*Broker) Worker

func (b *Broker) Worker() error

type Config

type Config struct {
	Hosts             []string
	Topic             string
	ProducerGroupName string
	ConsumerGroupName string
	Order             bool
	BroadCasting      bool
	// default processId, warning: using defaults can be problematic when docker is deployed
	InstanceName string
	// Strategy Algorithm for message allocating between consumers. reference: https://github.com/apache/rocketmq-client-go/blob/master/consumer/strategy.go
	AllocateStrategy func(string, string, []*primitive.MessageQueue, []string) []*primitive.MessageQueue
	// The maximum number of times the message is re-consumed. default 16 times.
	RetryMaxReconsume uint8
	// The Duration of backoff to apply between retries.
	//Backoff time.Duration
	Codec codec.Codec
	// Define the concurrency number of worker processes, default runtime.NumCPU()*2
	//Concurrency int
	// A Logger represents an active logging object that generates lines of output to an io.Writer
	Logger log.ILogger
}