SingleThreadInMemTransportFactory

The implementation of TransportFactory which uses single-thread subscribers.

Constructors

protected Subscriber newSubscriber(ChannelId channelId)

Creates a new instance of subscriber.

public void checkOpen()

Ensures that the object is open.

public synchronized void close()

public abstract 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.