com.epam.cmemdp.impl.transport.fix
Class FIXFastTransport

java.lang.Object
  com.epam.cmemdp.impl.transport.fix.FIXFastTransport

All Implemented Interfaces:

FIXTransport, StreamTransport

public class FIXFastTransport
extends java.lang.Object
implements FIXTransport, StreamTransport

Created by IntelliJ IDEA. User: Alexander_Sereda Date: 24.11.11 Time: 12:32 To change this template use File | Settings | File Templates.

Nested Class Summary

class

FIXFastTransport.SimpleRecoveryAdapter process request in one thread

Field Summary

FIXFastTransport.SimpleRecoveryAdapter	adaptor
static boolean	DEBUG_ENABLED
static boolean	TRACE_ENABLED

Constructor Summary

FIXFastTransport(Connection primary, Connection backup)

Method Summary

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	send(FIXFieldList message)
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

Field Detail

TRACE_ENABLED

public static final boolean TRACE_ENABLED

DEBUG_ENABLED

public static final boolean DEBUG_ENABLED

adaptor

public FIXFastTransport.SimpleRecoveryAdapter adaptor

Constructor Detail

FIXFastTransport

public FIXFastTransport(Connection primary,
                        Connection backup)

Method Detail

send

public void send(FIXFieldList message)
          throws java.io.IOException

Specified by:

send in interface FIXTransport

Throws:

java.io.IOException

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 java.io.IOException

Description copied from interface: StreamTransport

Connect to stream.

Specified by:

connect in interface StreamTransport

Parameters:

listener - the listener

Throws:

java.io.IOException - if error occurred

isConnect

public boolean isConnect()

Description copied from interface: StreamTransport

Check if stream is connected.

Specified by:

isConnect in interface StreamTransport

Returns:

boolean

disconnect

public void disconnect(StreamListener listener)
                throws java.io.IOException

Description copied from interface: StreamTransport

Disconnect to stream.

Specified by:

disconnect in interface StreamTransport

Parameters:

listener - the listener

Throws:

java.io.IOException - if error occurred

dispose

public void dispose()
             throws java.io.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:

java.io.IOException - if error occurred