rabbitmq

Documentation

Index

• func NewConnManager(c *config.Configuration, log *zap.Logger) *connManager
• func NewRabbitmqReceiver(m *connManager, logger *mq.QueueLogger) event.Receiver
• func NewRabbitmqSender(m *connManager) event.Sender
• type Receiver
  • func (r *Receiver) Close() error
  • func (r *Receiver) Receive(ctx context.Context, e event.Event, handler event.Handler, workerNum int64) error
• type Sender
  • func (r *Sender) Close() error
  • func (r *Sender) Send(ctx context.Context, msg event.Event) error

Functions

func NewConnManager

func NewConnManager(c *config.Configuration, log *zap.Logger) *connManager

func NewRabbitmqReceiver

func NewRabbitmqReceiver(m *connManager, logger *mq.QueueLogger) event.Receiver

func NewRabbitmqSender

func NewRabbitmqSender(m *connManager) event.Sender

Types

type Receiver

type Receiver struct {
	// contains filtered or unexported fields
}

func (*Receiver) Close

func (r *Receiver) Close() error

func (*Receiver) Receive

func (r *Receiver) Receive(ctx context.Context, e event.Event, handler event.Handler, workerNum int64) error

type Sender

type Sender struct {
	// contains filtered or unexported fields
}

func (*Sender) Close

func (r *Sender) Close() error

func (*Sender) Send

func (r *Sender) Send(ctx context.Context, msg event.Event) error