io.spine.server.transport.memory

Class SingleThreadInMemTransportFactory

java.lang.Object

io.spine.server.transport.memory.InMemoryTransportFactory

io.spine.server.transport.memory.SingleThreadInMemTransportFactory

All Implemented Interfaces:

Closeable, TransportFactory, java.lang.AutoCloseable

public class SingleThreadInMemTransportFactory
extends InMemoryTransportFactory

The implementation of TransportFactory which uses single-thread subscribers.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SingleThreadInMemTransportFactory()

Method Summary

Modifier and Type	Method and Description
static SingleThreadInMemTransportFactory	newInstance()
protected Subscriber	newSubscriber(io.spine.server.transport.ChannelId channelId) Creates a new instance of subscriber.

Methods inherited from class io.spine.server.transport.memory.InMemoryTransportFactory

close, createPublisher, createSubscriber, isOpen

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.spine.server.Closeable

checkOpen

Constructor Detail

SingleThreadInMemTransportFactory

protected SingleThreadInMemTransportFactory()

Method Detail

newInstance

public static SingleThreadInMemTransportFactory newInstance()

newSubscriber

protected Subscriber newSubscriber(io.spine.server.transport.ChannelId channelId)

Description copied from class: InMemoryTransportFactory

Creates a new instance of subscriber.

The descendants may override this method to customize the implementation of subscribers to use within this TransportFactory instance.

Overrides:

newSubscriber in class InMemoryTransportFactory

Parameters:

channelId - the identifier of the resulting subscriber

Returns:

an instance of subscribe