InMemoryPublisher

An in-memory implementation of the Publisher.

To use only in scope of the same JVM as subscribers.

Functions

public void close()

Does nothing as there are no resources to close in the in-memory implementation.

public boolean isStale()

Always returns false as publishers don't get stale.

public Ack publish(Any messageId, ExternalMessage message)

Publishes a given ExternalMessage to the channel under a given ID.

public static ChannelId channelIdFor(TypeUrl messageType)

Converts the given message type into a ChannelId.

public ChannelId id()

Obtains the channel identifier.

public TypeUrl targetType()

Obtains the type of the messages transferred through this channel.