public class TwinFASTChannel extends Object implements ITwinFASTChannel
Constructor and Description |
---|
TwinFASTChannel(Transport primaryTransport,
Transport backupTransport,
FIXFASTListener listener,
FASTDecoderFactory decoderFactory,
com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver,
TransportType transportType) |
Modifier and Type | Method and Description |
---|---|
void |
connect()
Connect all transports to the servers.
|
void |
disconnect()
Disconnect all transports.
|
int |
getBackupPort()
Returns Port of client transport.
|
FASTDecoderFactory |
getDecoderFactory()
Returns decoder associate with this channel.
|
int |
getPort()
Returns Port of client transport.
|
int |
getPrimaryPort()
Returns Port of client transport.
|
boolean |
isStarted()
Returns true if at least one transport connected.
|
void |
resetSeqNum(long newSeqNum)
Resets channel data.
|
public TwinFASTChannel(Transport primaryTransport, Transport backupTransport, FIXFASTListener listener, FASTDecoderFactory decoderFactory, com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver, TransportType transportType)
public FASTDecoderFactory getDecoderFactory()
IFASTChannel
getDecoderFactory
in interface IFASTChannel
public boolean isStarted()
isStarted
in interface IFASTChannel
true
if at least one transport connected.public int getPort()
getPort
in interface IFASTChannel
public int getPrimaryPort()
public int getBackupPort()
public void connect() throws IOException
connect
in interface IFASTChannel
IOException
- If connect does not establish.public void disconnect() throws IOException
disconnect
in interface IFASTChannel
IOException
- If connect does not closed.public void resetSeqNum(long newSeqNum)
IFASTChannel
resetSeqNum
in interface IFASTChannel
newSeqNum
- the new seq numCopyright © 2000-2017 EPAM Systems. All Rights Reserved.