watermill

Documentation

Index

• func NewPubSub(logger logur.Logger) (message.Publisher, message.Subscriber)
• func NewRouter(logger logur.Logger) (*message.Router, error)
• func PublisherCorrelationID(publisher message.Publisher) message.Publisher
• func SubscriberCorrelationID(subscriber message.Subscriber) message.Subscriber

Functions

func NewPubSub

func NewPubSub(logger logur.Logger) (message.Publisher, message.Subscriber)

NewPubSub returns a new PubSub.

func NewRouter

func NewRouter(logger logur.Logger) (*message.Router, error)

NewRouter returns a new message router for message subscription logic.

func PublisherCorrelationID

func PublisherCorrelationID(publisher message.Publisher) message.Publisher

PublisherCorrelationID decorates a publisher with a correlation ID middleware.

func SubscriberCorrelationID

func SubscriberCorrelationID(subscriber message.Subscriber) message.Subscriber

SubscriberCorrelationID decorates a subscriber with a correlation ID middleware.