Multiplex given channels.

NewMessenger returns a new Messenger with given Client code must not modify options.

NewService returns a new initialized service.

ErrAlreadyExists is returned by AddSubscription when a subcription on given topic already exists.

ErrNotExists is returned by RemoveHandler when a subscription on given topic does not exists.

ErrStopped is returned when subscription was cancelled by stopping it.

Options define how to connect to pub sub.

PubSubMessenger implements Messenger interface.

RawMessage is pub sub message model.

Service is a wrapper around a Messenger that permits to stop and wait to return all subscription and handlers.

SubscriptionError is a type that wrap an error and the topic on which it occured Err is nil only if the subscription was canceled.

SubscriptionOptions define how to perform a sub on a topic.

Handler is invoked on new messages.