Versions in this module Expand all Collapse all v1 v1.10.0 Jul 3, 2026 Changes in this version + var ErrNoRoutingKey = fmt.Errorf("no routing key configured for message type") + type Amqp struct + func New(p BackingPublisher, opts ...Option) (*Amqp, error) + func (a *Amqp) Publish(ctx context.Context, event eventsourced.Event) error + type BackingPublisher interface + Publish func(ctx context.Context, routingKey string, msg any, headers ...goamqp.Header) error + type Option func(amqp *Amqp) error + func WithTraceHandler(traceHandler eventsourced.TraceHandler) Option + func WithTypeMapping(routingKey string, msgType any) Option
Go to main page