messaging

Documentation

Index

• func CorrelationIdMiddleware(h message.HandlerFunc) message.HandlerFunc
• func ErrorLoggerMiddleware(logger *logs.Logger) func(h message.HandlerFunc) message.HandlerFunc
• type AmqpPublisher
  • func NewAmqpPublisher(amqpUrl string, logger *logs.Logger) (AmqpPublisher, error)
  • func (p AmqpPublisher) Close() error
  • func (p AmqpPublisher) Publish(topic string, messages ...*message.Message) error
• type CorrelationIdPublisher
  • func NewCorrelationIdPublisher(publisher message.Publisher) CorrelationIdPublisher
  • func (c CorrelationIdPublisher) Close() error
  • func (c CorrelationIdPublisher) Publish(topic string, messages ...*message.Message) error

Functions

func CorrelationIdMiddleware

func CorrelationIdMiddleware(h message.HandlerFunc) message.HandlerFunc

func ErrorLoggerMiddleware

func ErrorLoggerMiddleware(logger *logs.Logger) func(h message.HandlerFunc) message.HandlerFunc

Types

type AmqpPublisher

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

func NewAmqpPublisher

func NewAmqpPublisher(amqpUrl string, logger *logs.Logger) (AmqpPublisher, error)

func (AmqpPublisher) Close

func (p AmqpPublisher) Close() error

func (AmqpPublisher) Publish

func (p AmqpPublisher) Publish(topic string, messages ...*message.Message) error

type CorrelationIdPublisher

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

func NewCorrelationIdPublisher

func NewCorrelationIdPublisher(publisher message.Publisher) CorrelationIdPublisher

func (CorrelationIdPublisher) Close

func (c CorrelationIdPublisher) Close() error

func (CorrelationIdPublisher) Publish

func (c CorrelationIdPublisher) Publish(topic string, messages ...*message.Message) error