com.epam.fast.adaptor.api.tranport

Interface StreamTransport

All Known Subinterfaces:

FIXTransport, StreamTransport

All Known Implementing Classes:

AbstractFIXTransport, AbstractObserverTransport, AbstractSelfDisconnectTransport, AbstractStreamTransport, FIXFastTransport, FIXTransportImpl, StreamTransportImpl, TwinStreamTransportImpl

public interface StreamTransport

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.
boolean	isConnect() Check if stream is connected.
void	removeMessageStreamListener(StreamListener listener) Remove message stream listener.
void	setMessageStreamListener(StreamListener listener) Sets message stream listener.

Method Detail

setMessageStreamListener

void setMessageStreamListener(StreamListener listener)

Sets message stream listener.

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

Parameters:

listener - the listener

removeMessageStreamListener

void removeMessageStreamListener(StreamListener listener)

Remove message stream listener.

Parameters:

listener - the listener

connect

void connect(StreamListener listener)
      throws IOException

Connect to stream.

Parameters:

listener - the listener

Throws:

IOException - if error occurred

isConnect

boolean isConnect()

Check if stream is connected.

Returns:

boolean

disconnect

void disconnect(StreamListener listener)
         throws IOException

Disconnect to stream.

Parameters:

listener - the listener

Throws:

IOException - if error occurred

dispose

void dispose()
      throws IOException

Dispose the transport.

This methods disconnect from stream and cleans all subscribed listeners.

Throws:

IOException - if error occurred