messaging

Documentation

Index

• func CorrelationIdMiddleware(h message.HandlerFunc) message.HandlerFunc
• func ErrorLoggerMiddleware(logger *logs.Logger) func(h message.HandlerFunc) message.HandlerFunc
• func NewHeader(eventName, serviceName string) *events.Header
• 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
• type Publisher
  • func NewPublisher(config amqp.Config, logger watermill.LoggerAdapter) (*Publisher, error)
  • func (p *Publisher) Close() error
  • func (p *Publisher) Publish(topic string, event any) error

Functions

func CorrelationIdMiddleware

func CorrelationIdMiddleware(h message.HandlerFunc) message.HandlerFunc

func ErrorLoggerMiddleware

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

func NewHeader

func NewHeader(eventName, serviceName string) *events.Header

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

type Publisher

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

func NewPublisher

func NewPublisher(config amqp.Config, logger watermill.LoggerAdapter) (*Publisher, error)

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) Publish

func (p *Publisher) Publish(topic string, event any) error