InMemoryTransportFactory

In-memory implementation of the TransportFactory.

Publishers and subscribers must be in the same JVM. Therefore this factory usage should be limited to tests.

Constructors

Prevent direct instantiation from outside of the inheritance tree.

public synchronized void close()

public final synchronized Publisher createPublisher(ChannelId id)

Creates a Publisher channel with the given ID.

public final synchronized Subscriber createSubscriber(ChannelId id)

Creates a Subscriber channel with the given ID.

public synchronized boolean isOpen()

Tells if the object is still open.

Creates a new instance of InMemoryTransportFactory.

protected Subscriber newSubscriber(ChannelId id)

Creates a new instance of subscriber.

public void checkOpen()

Ensures that the object is open.