Versions in this module Expand all Collapse all v0 v0.26.7 Jun 12, 2024 v0.26.6 Jun 8, 2024 Changes in this version + func CorrelationIdMiddleware(h message.HandlerFunc) message.HandlerFunc + func ErrorLoggerMiddleware(logger *logs.Logger) func(h message.HandlerFunc) message.HandlerFunc + type AmqpPublisher struct + 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 struct + func NewCorrelationIdPublisher(publisher message.Publisher) CorrelationIdPublisher + func (c CorrelationIdPublisher) Close() error + func (c CorrelationIdPublisher) Publish(topic string, messages ...*message.Message) error
Go to main page