com.epam.bovespafast.impl.transport.fast

Class AbstractStreamTransport

java.lang.Object

com.epam.bovespafast.impl.transport.AbstractObserverTransport

com.epam.bovespafast.impl.transport.AbstractSelfDisconnectTransport

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

All Implemented Interfaces:

StreamTransport

Direct Known Subclasses:

StreamTransportImpl, TwinStreamTransportImpl

public abstract class AbstractStreamTransport
extends AbstractSelfDisconnectTransport

Field Summary

Fields

Modifier and Type	Field and Description
protected FASTChannelFactory	fastChannelFactory
static int	KBYTE
protected static int	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

Modifier	Constructor and Description
protected	AbstractStreamTransport(FASTChannelFactory fastChannelFactory, TransportType transportType)
protected	AbstractStreamTransport(InputStream templateInputStream, TransportType transportType)

Method Summary

Modifier and Type	Method and Description
protected IFASTChannel	connectImpl(Connection connection, TransportType transportType)
void	dispose() Dispose the transport.

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

addConnectRef, connect, connectImpl, disconnect, disconnectImpl, 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

Field Detail

KBYTE

public static final int KBYTE

See Also:

Constant Field Values

SOCKET_RECEIVE_BUFFER_SIZE

protected static final int SOCKET_RECEIVE_BUFFER_SIZE

fastChannelFactory

protected FASTChannelFactory fastChannelFactory

Constructor Detail

AbstractStreamTransport

protected AbstractStreamTransport(InputStream templateInputStream,
                                  TransportType transportType)

AbstractStreamTransport

protected AbstractStreamTransport(FASTChannelFactory fastChannelFactory,
                                  TransportType transportType)

Method Detail

connectImpl

protected IFASTChannel connectImpl(Connection connection,
                                   TransportType transportType)
                            throws IOException

Throws:

IOException

dispose

public void dispose()
             throws IOException

Description copied from interface: StreamTransport

Dispose the transport.

This methods disconnect from stream and cleans all subscribed listeners.

Specified by:

dispose in interface StreamTransport

Overrides:

dispose in class AbstractSelfDisconnectTransport

Throws:

IOException - if error occurred