TransportMessageBus

A distributed message bus over a Transport: the one place that names topics, encodes and decodes messages, validates received records and builds exchanges, whatever the broker.

The wire format is the v9 one on every backend: the topic is topicNaming's (memoised per aggregate), the key is the aggregate ID, the timestamp is the message's creation time and the payload is the message's JSON. A received record must decode to a messageType whose aggregate ID equals the record key (when the backend has keys) and whose topic is the record's; anything else goes to decodeFailureHandler. Decoded messages are read-only.

Inheritors