com.epam.bovespafast.impl.transport.fix

Class AbstractFIXTransport

java.lang.Object

com.epam.bovespafast.impl.transport.AbstractObserverTransport

com.epam.bovespafast.impl.transport.fix.AbstractFIXTransport

All Implemented Interfaces:

FIXTransport, StreamTransport

Direct Known Subclasses:

FIXTransportImpl

public abstract class AbstractFIXTransport
extends AbstractObserverTransport
implements FIXTransport

Field Summary

Fields

Modifier and Type	Field and Description
protected ExtendedFIXSession	fixSession

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

listenerObservers, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractFIXTransport(Connection primary, Connection backup)

Method Summary

Methods

Modifier and Type	Method and Description
void	connect(StreamListener listener) Connect to stream.
void	connectImpl()
protected void	createFIXSession()
void	disconnect(StreamListener listener) Disconnect to stream.
void	disconnectImpl()
void	dispose() Dispose the transport.
boolean	isConnect() Check if stream is connected.
boolean	isSessionConnected()
void	removeStateListener(TransportStateListener listener) Remove connection state listener.
void	setStateListener(TransportStateListener listener) Sets connection state listener.

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

Methods inherited from interface com.epam.bovespafast.impl.transport.fix.FIXTransport

send

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

removeMessageStreamListener, setMessageStreamListener

Field Detail

fixSession

protected ExtendedFIXSession fixSession

Constructor Detail

AbstractFIXTransport

protected AbstractFIXTransport(Connection primary,
                    Connection backup)

Method Detail

setStateListener

public void setStateListener(TransportStateListener listener)

Description copied from interface: FIXTransport

Sets connection state listener.

Specified by:

setStateListener in interface FIXTransport

Parameters:

listener - the listener

removeStateListener

public void removeStateListener(TransportStateListener listener)

Description copied from interface: FIXTransport

Remove connection state listener.

Specified by:

removeStateListener in interface FIXTransport

Parameters:

listener - the listener

isSessionConnected

public boolean isSessionConnected()

Specified by:

isSessionConnected in interface FIXTransport

createFIXSession

protected void createFIXSession()
                         throws IOException

Throws:

IOException

connectImpl

public void connectImpl()
                 throws IOException

Throws:

IOException

isConnect

public boolean isConnect()

Description copied from interface: StreamTransport

Check if stream is connected.

Specified by:

isConnect in interface StreamTransport

Returns:

boolean

disconnectImpl

public void disconnectImpl()
                    throws IOException

Throws:

IOException

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

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