com.epam.bovespafast.impl.transport

Class AbstractObserverTransport

java.lang.Object

com.epam.bovespafast.impl.transport.AbstractObserverTransport

All Implemented Interfaces:

StreamTransport

Direct Known Subclasses:

AbstractFIXTransport, AbstractSelfDisconnectTransport

public abstract class AbstractObserverTransport
extends Object
implements StreamTransport

Field Summary

Fields

Modifier and Type	Field and Description
protected ListenerObservers	listenerObservers
protected com.epam.common.logging.Log	log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractObserverTransport()

Method Summary

Modifier and Type	Method and Description
void	connect(StreamListener listener) Connect to stream.
void	disconnect(StreamListener listener) Disconnect to stream.
void	dispose() Dispose the transport.
void	removeMessageStreamListener(StreamListener listener) Remove message stream listener.
void	setMessageStreamListener(StreamListener listener) Sets message stream listener.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.epam.fast.adaptor.api.tranport.StreamTransport

isConnect

Field Detail

log

protected final com.epam.common.logging.Log log

listenerObservers

protected ListenerObservers listenerObservers

Constructor Detail

AbstractObserverTransport

protected AbstractObserverTransport()

Method Detail

setMessageStreamListener

public void setMessageStreamListener(StreamListener listener)

Description copied from interface: StreamTransport

Sets message stream listener.

This listener will call on every received messages before all subscribed listeners. Users can listen every pre processed messages.

Specified by:

setMessageStreamListener in interface StreamTransport

Parameters:

listener - the listener

removeMessageStreamListener

public void removeMessageStreamListener(StreamListener listener)

Description copied from interface: StreamTransport

Remove message stream listener.

Specified by:

removeMessageStreamListener in interface StreamTransport

Parameters:

listener - the listener

connect

public void connect(StreamListener listener)
             throws IOException

Description copied from interface: StreamTransport

Connect to stream.

Specified by:

connect in interface StreamTransport

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

Parameters:

listener - the listener

Throws:

IOException - if error occurred

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

Throws:

IOException - if error occurred