public class FIXFastTransport extends Object implements FIXTransport, StreamTransport
Modifier and Type | Class and Description |
---|---|
class |
FIXFastTransport.SimpleRecoveryAdapter
process request in one thread
|
Modifier and Type | Field and Description |
---|---|
FIXFastTransport.SimpleRecoveryAdapter |
adaptor |
static boolean |
DEBUG_ENABLED |
static boolean |
TRACE_ENABLED |
Constructor and Description |
---|
FIXFastTransport(Connection primary,
Connection backup) |
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 |
send(com.epam.fix.message.FIXFieldList message) |
void |
setMessageStreamListener(StreamListener listener)
Sets message stream listener.
|
public static final boolean TRACE_ENABLED
public static final boolean DEBUG_ENABLED
public FIXFastTransport.SimpleRecoveryAdapter adaptor
public FIXFastTransport(Connection primary, Connection backup)
public void send(com.epam.fix.message.FIXFieldList message) throws IOException
send
in interface FIXTransport
IOException
public void setMessageStreamListener(StreamListener listener)
StreamTransport
This listener will call on every received messages before all subscribed listeners. Users can listen every pre processed messages.
setMessageStreamListener
in interface StreamTransport
listener
- the listenerpublic void removeMessageStreamListener(StreamListener listener)
StreamTransport
removeMessageStreamListener
in interface StreamTransport
listener
- the listenerpublic void connect(StreamListener listener) throws IOException
StreamTransport
connect
in interface StreamTransport
listener
- the listenerIOException
- if error occurredpublic boolean isConnect()
StreamTransport
isConnect
in interface StreamTransport
public void disconnect(StreamListener listener) throws IOException
StreamTransport
disconnect
in interface StreamTransport
listener
- the listenerIOException
- if error occurredpublic void dispose() throws IOException
StreamTransport
This methods disconnect from stream and cleans all subscribed listeners.
dispose
in interface StreamTransport
IOException
- if error occurredCopyright © 2000–2025 EPAM Systems. All rights reserved.