public abstract class AbstractStreamTransport extends AbstractSelfDisconnectTransport
Modifier and Type | Field and Description |
---|---|
protected FASTChannelFactory |
fastChannelFactory |
static int |
KBYTE |
protected static int |
SOCKET_RECEIVE_BUFFER_SIZE |
connectCount, transportType
listenerObservers, log
Modifier | Constructor and Description |
---|---|
protected |
AbstractStreamTransport(FASTChannelFactory fastChannelFactory,
TransportType transportType) |
protected |
AbstractStreamTransport(InputStream templateInputStream,
TransportType transportType) |
Modifier and Type | Method and Description |
---|---|
protected IFASTChannel |
connectImpl(Connection connection,
TransportType transportType) |
void |
dispose()
Dispose the transport.
|
addConnectRef, connect, connectImpl, disconnect, disconnectImpl, getTotalConnectRefs, isConnect, releaseConnectRef
removeMessageStreamListener, setMessageStreamListener
public static final int KBYTE
protected static final int SOCKET_RECEIVE_BUFFER_SIZE
protected FASTChannelFactory fastChannelFactory
protected AbstractStreamTransport(InputStream templateInputStream, TransportType transportType)
protected AbstractStreamTransport(FASTChannelFactory fastChannelFactory, TransportType transportType)
protected IFASTChannel connectImpl(Connection connection, TransportType transportType) throws IOException
IOException
public void dispose() throws IOException
StreamTransport
This methods disconnect from stream and cleans all subscribed listeners.
dispose
in interface StreamTransport
dispose
in class AbstractSelfDisconnectTransport
IOException
- if error occurredCopyright © 2000-2017 EPAM Systems. All Rights Reserved.