com.epam.bovespafast.impl.transport.fast

Class TwinStreamTransportImpl

java.lang.Object

com.epam.bovespafast.impl.transport.AbstractObserverTransport

com.epam.bovespafast.impl.transport.AbstractSelfDisconnectTransport

com.epam.bovespafast.impl.transport.fast.AbstractStreamTransport

com.epam.bovespafast.impl.transport.fast.TwinStreamTransportImpl

All Implemented Interfaces:

StreamTransport

public class TwinStreamTransportImpl
extends AbstractStreamTransport

Field Summary

Fields inherited from class com.epam.bovespafast.impl.transport.fast.AbstractStreamTransport

fastChannelFactory, KBYTE, SOCKET_RECEIVE_BUFFER_SIZE

Fields inherited from class com.epam.bovespafast.impl.transport.AbstractSelfDisconnectTransport

connectCount, transportType

Fields inherited from class com.epam.bovespafast.impl.transport.AbstractObserverTransport

listenerObservers, log

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class com.epam.bovespafast.impl.transport.fast.AbstractStreamTransport

connectImpl, dispose

Methods inherited from class com.epam.bovespafast.impl.transport.AbstractSelfDisconnectTransport

addConnectRef, connect, disconnect, getTotalConnectRefs, isConnect, releaseConnectRef

Methods inherited from class com.epam.bovespafast.impl.transport.AbstractObserverTransport

removeMessageStreamListener, setMessageStreamListener

Methods inherited from class java.lang.Object

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

Constructor Detail

TwinStreamTransportImpl

public TwinStreamTransportImpl(Connection primary,
                               Connection backup,
                               InputStream templateInputStream,
                               com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
                               TransportType transportType)

TwinStreamTransportImpl

public TwinStreamTransportImpl(Connection primary,
                               Connection backup,
                               FASTChannelFactory fastChannelFactory,
                               com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
                               TransportType transportType)

TwinStreamTransportImpl

public TwinStreamTransportImpl(Connection primary,
                               Connection backup,
                               FASTChannelFactory channelFactory,
                               String interfaceName,
                               com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
                               TransportType transportType)

Method Detail

connectImpl

public void connectImpl()
                 throws IOException

Specified by:

connectImpl in class AbstractSelfDisconnectTransport

Throws:

IOException

connectImpl

protected IFASTChannel connectImpl(Connection connectionA,
                                   Connection connectionB,
                                   com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
                                   TransportType transportType)
                            throws IOException

Throws:

IOException

disconnectImpl

public void disconnectImpl()
                    throws IOException

Specified by:

disconnectImpl in class AbstractSelfDisconnectTransport

Throws:

IOException