NewEntityMessage is a message factory.

NewInMemoryMessageBus Factory method.

BaseMessage base implementation of IMessage interface.

EntityMessage general entity message implementation of IMessage interface.

InMemoryMessageBus represents in memory implementation of IMessageBus interface topics is a map ot topic -> array of channels (channel per subscriber).

Message is a generic message structure.

IMessage General message interface.

IMessageBus Message bus interface.

IMessageConsumer Message bus consumer (reader) interface.

IMessageProducer Message bus producer interface.

MessageFactory is a factory method of any message.

SubscriptionCallback Message subscription callback function, return true for ack.