New returns a new broker with interception capabilities.

WithChainPublishInterceptors returns a Option that specifies the chained interceptor for publishing.

WithChainSubscribeInterceptors returns a Option that specifies the chained interceptor for subscribing.

WithPublishInterceptor returns a Option that sets the PublishInterceptor middleware for the broker.

WithSubscribeInterceptor returns a Option that sets the SubscriberInterceptor for the broker.

Option sets options for a interceptor broker instance.

PublishHandler wraps a call to publish, for interception.

PublishInterceptor provides a hook to intercept each message before it gets published.

SubscribeMessageHandler defines the handler invoked by SubscriberInterceptor before a message is delivered to a particular subscriber.

SubscriberInterceptor provides a hook to intercept each message before it gets delivered to subscribers.