public class TwinStreamTransportImpl extends AbstractStreamTransport
fastChannelFactory, KBYTE, SOCKET_RECEIVE_BUFFER_SIZE
connectCount, transportType
listenerObservers, log
Constructor and Description |
---|
TwinStreamTransportImpl(Connection primary,
Connection backup,
FASTChannelFactory fastChannelFactory,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
TransportType transportType) |
TwinStreamTransportImpl(Connection primary,
Connection backup,
FASTChannelFactory channelFactory,
String interfaceName,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
TransportType transportType) |
TwinStreamTransportImpl(Connection primary,
Connection backup,
InputStream templateInputStream,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
TransportType transportType) |
Modifier and Type | Method and Description |
---|---|
void |
connectImpl() |
protected IFASTChannel |
connectImpl(Connection connectionA,
Connection connectionB,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
TransportType transportType) |
void |
disconnectImpl() |
connectImpl, dispose
addConnectRef, connect, disconnect, getTotalConnectRefs, isConnect, releaseConnectRef
removeMessageStreamListener, setMessageStreamListener
public TwinStreamTransportImpl(Connection primary, Connection backup, InputStream templateInputStream, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, TransportType transportType)
public TwinStreamTransportImpl(Connection primary, Connection backup, FASTChannelFactory fastChannelFactory, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, TransportType transportType)
public TwinStreamTransportImpl(Connection primary, Connection backup, FASTChannelFactory channelFactory, String interfaceName, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, TransportType transportType)
public void connectImpl() throws IOException
connectImpl
in class AbstractSelfDisconnectTransport
IOException
protected IFASTChannel connectImpl(Connection connectionA, Connection connectionB, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, TransportType transportType) throws IOException
IOException
public void disconnectImpl() throws IOException
disconnectImpl
in class AbstractSelfDisconnectTransport
IOException
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.