public class FastChannel extends Object implements IFASTChannel
Constructor and Description |
---|
FastChannel(Transport transport,
FIXFASTListener listener,
FASTDecoderFactory factoryDecoder,
com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver,
TransportType transportType)
Creates the
FastChannel with specified version. |
FastChannel(Transport transport,
FIXFASTListener listener,
TemplateContainer templateContainer,
ChannelVersion chanelVersion,
TransportType transportType)
Deprecated.
|
FastChannel(Transport transport,
FIXFASTListener listener,
TemplateContainer templateContainer,
TransportType transportType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
connect()
Connect all transports to the servers.
|
void |
disconnect()
Disconnect all transports.
|
FASTDecoderFactory |
getDecoderFactory()
Returns decoder associate with this channel.
|
int |
getPort()
Returns Port of client transport.
|
boolean |
isStarted()
Returns true if at least one transport connected.
|
boolean |
onNextMessageReceived(long seqNum) |
void |
reset(long seqNum) |
void |
resetSeqNum(long newSeqNum)
Resets channel data.
|
@Deprecated public FastChannel(Transport transport, FIXFASTListener listener, TemplateContainer templateContainer, TransportType transportType)
transport
- Instance of Client transport.listener
- Instance of FAST listener.templateContainer
- Container of FAST templates.@Deprecated public FastChannel(Transport transport, FIXFASTListener listener, TemplateContainer templateContainer, ChannelVersion chanelVersion, TransportType transportType)
FastChannel
with specified version.transport
- Instance of Client transport.listener
- Instance of FAST listener.templateContainer
- Container of FAST templates.public FastChannel(Transport transport, FIXFASTListener listener, FASTDecoderFactory factoryDecoder, com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver, TransportType transportType)
FastChannel
with specified version.transport
- Instance of Client transport.listener
- Instance of FAST listener.public boolean isStarted()
isStarted
in interface IFASTChannel
true
if at least one transport connected.public int getPort()
getPort
in interface IFASTChannel
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 FASTDecoderFactory getDecoderFactory()
IFASTChannel
getDecoderFactory
in interface IFASTChannel
public boolean onNextMessageReceived(long seqNum)
public void resetSeqNum(long newSeqNum)
IFASTChannel
resetSeqNum
in interface IFASTChannel
newSeqNum
- the new seq numpublic void reset(long seqNum)
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.