com.epam.bovespafast.impl.transport

Class AbstractSelfDisconnectTransport

java.lang.Object

com.epam.bovespafast.impl.transport.AbstractObserverTransport

com.epam.bovespafast.impl.transport.AbstractSelfDisconnectTransport

All Implemented Interfaces:

StreamTransport

Direct Known Subclasses:

AbstractStreamTransport

public abstract class AbstractSelfDisconnectTransport
extends AbstractObserverTransport

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	connectCount
protected TransportType	transportType

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

listenerObservers, log

Constructor Summary

Constructors

Constructor and Description
AbstractSelfDisconnectTransport(TransportType transportType)

Method Summary

Modifier and Type	Method and Description
protected int	addConnectRef()
void	connect(StreamListener listener) Connect to stream.
abstract void	connectImpl()
void	disconnect(StreamListener listener) Disconnect to stream.
abstract void	disconnectImpl()
void	dispose() Dispose the transport.
int	getTotalConnectRefs()
boolean	isConnect() Check if stream is connected.
protected int	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

connectCount

protected AtomicInteger connectCount

transportType

protected TransportType transportType

Constructor Detail

AbstractSelfDisconnectTransport

public AbstractSelfDisconnectTransport(TransportType transportType)

Method Detail

addConnectRef

protected int addConnectRef()

releaseConnectRef

protected int releaseConnectRef()

getTotalConnectRefs

public int getTotalConnectRefs()

connect

public void connect(StreamListener listener)
             throws IOException

Description copied from interface: StreamTransport

Connect to stream.

Specified by:

connect in interface StreamTransport

Overrides:

connect in class AbstractObserverTransport

Parameters:

listener - the listener

Throws:

IOException - if error occurred

disconnect

public void disconnect(StreamListener listener)
                throws IOException

Description copied from interface: StreamTransport

Disconnect to stream.

Specified by:

disconnect in interface StreamTransport

Overrides:

disconnect in class AbstractObserverTransport

Parameters:

listener - the listener

Throws:

IOException - if error occurred

connectImpl

public abstract void connectImpl()
                          throws IOException

Throws:

IOException

disconnectImpl

public abstract void disconnectImpl()
                             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 AbstractObserverTransport

Throws:

IOException - if error occurred

isConnect

public boolean isConnect()

Description copied from interface: StreamTransport

Check if stream is connected.

Returns:

boolean