com.epam.cmefast.impl.reader

Class FastChannelReaderImpl

java.lang.Object

com.epam.cmefast.impl.reader.FastChannelReaderImpl

All Implemented Interfaces:

FastChannelReader

public class FastChannelReaderImpl
extends Object
implements FastChannelReader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FastChannelReaderImpl.FIXFASTChannelListenerAdaptor

Field Summary

Fields

Modifier and Type	Field and Description
static int	KBYTE

Constructor Summary

Constructors

Constructor and Description
FastChannelReaderImpl(String uriToTemplates)

Method Summary

Methods

Modifier and Type	Method and Description
void	connect(Connection connectionA, Connection connectionB, String channelID, FastChannelReaderListener listener, com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver, TransportType transportType)
void	connect(Connection connectionParams, String channelID, FastChannelReaderListener listener, com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver, TransportType transportType) Connects channel.
void	disconnect(Connection connection, String channelID) Disconnects channel.
FASTDecoderFactory	getDecoderFactory()
void	setClientFactory(FASTClientFactory fastFactoryProxy)
void	setNetworkInterfaceA(String networkInterface)
void	setNetworkInterfaceB(String networkInterface)
void	stop() Stops channel reader.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KBYTE

public static final int KBYTE

See Also:

Constant Field Values

Constructor Detail

FastChannelReaderImpl

public FastChannelReaderImpl(String uriToTemplates)

Method Detail

setNetworkInterfaceA

public void setNetworkInterfaceA(String networkInterface)

Specified by:

setNetworkInterfaceA in interface FastChannelReader

setNetworkInterfaceB

public void setNetworkInterfaceB(String networkInterface)

Specified by:

setNetworkInterfaceB in interface FastChannelReader

setClientFactory

public void setClientFactory(FASTClientFactory fastFactoryProxy)

connect

public void connect(Connection connectionParams,
           String channelID,
           FastChannelReaderListener listener,
           com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver,
           TransportType transportType)

Description copied from interface: FastChannelReader

Connects channel.

Specified by:

connect in interface FastChannelReader

Parameters:

connectionParams - the connection parameters

channelID - the channel ID

listener - the channel listener

connect

public void connect(Connection connectionA,
           Connection connectionB,
           String channelID,
           FastChannelReaderListener listener,
           com.epam.fast.full.coders.stream.SequenceObserver sequenceObserver,
           TransportType transportType)

Specified by:

connect in interface FastChannelReader

getDecoderFactory

public FASTDecoderFactory getDecoderFactory()
                                     throws IOException

Specified by:

getDecoderFactory in interface FastChannelReader

Throws:

IOException

disconnect

public void disconnect(Connection connection,
              String channelID)

Description copied from interface: FastChannelReader

Disconnects channel.

Specified by:

disconnect in interface FastChannelReader

Parameters:

connection - the connection parameters

stop

public void stop()

Description copied from interface: FastChannelReader

Stops channel reader.

Specified by:

stop in interface FastChannelReader