com.epam.bovespafast.impl.transport.fast

Class StreamTransportImpl

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.StreamTransportImpl

All Implemented Interfaces:

StreamTransport

public class StreamTransportImpl
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
StreamTransportImpl(Connection connection, InputStream templateInputStream, TransportType transportType)

Method Summary

Modifier and Type	Method and Description
void	connectImpl()
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

StreamTransportImpl

public StreamTransportImpl(Connection connection,
                           InputStream templateInputStream,
                           TransportType transportType)

Method Detail

connectImpl

public void connectImpl()
                 throws IOException

Specified by:

connectImpl in class AbstractSelfDisconnectTransport

Throws:

IOException

disconnectImpl

public void disconnectImpl()
                    throws IOException

Specified by:

disconnectImpl in class AbstractSelfDisconnectTransport

Throws:

IOException