com.epam.cmemdp.impl.reader
Class FastChannelReaderImpl

java.lang.Object
  com.epam.cmemdp.impl.reader.FastChannelReaderImpl

All Implemented Interfaces:

FastChannelReader

public class FastChannelReaderImpl
extends java.lang.Object
implements FastChannelReader

Nested Class Summary

static class

FastChannelReaderImpl.FIXStreamChannelListenerAdaptor

Field Summary

static int

KBYTE

Constructor Summary

FastChannelReaderImpl(java.lang.String uriToTemplates)

Method Summary

void	connect(Connection connectionA, Connection connectionB, java.lang.String channelID, FastChannelReaderListener listener, com.epam.mdp.full.coders.stream.SeqNumHelper secNumHelper, TransportType transportType)
void	connect(Connection connectionParams, java.lang.String channelID, FastChannelReaderListener listener, com.epam.mdp.full.coders.stream.SeqNumHelper secNumHelper, TransportType transportType) Connects channel.
void	disconnect(Connection connection, java.lang.String channelID) Disconnects channel.
FASTDecoderFactory	getDecoderFactory()
void	setClientFactory(StreamClientFactory fastFactoryProxy)
void	setNetworkInterfaceA(java.lang.String networkInterface)
void	setNetworkInterfaceB(java.lang.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(java.lang.String uriToTemplates)

Method Detail

setNetworkInterfaceA

public void setNetworkInterfaceA(java.lang.String networkInterface)

Specified by:

setNetworkInterfaceA in interface FastChannelReader

setNetworkInterfaceB

public void setNetworkInterfaceB(java.lang.String networkInterface)

Specified by:

setNetworkInterfaceB in interface FastChannelReader

setClientFactory

public void setClientFactory(StreamClientFactory fastFactoryProxy)

connect

public void connect(Connection connectionParams,
                    java.lang.String channelID,
                    FastChannelReaderListener listener,
                    com.epam.mdp.full.coders.stream.SeqNumHelper secNumHelper,
                    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,
                    java.lang.String channelID,
                    FastChannelReaderListener listener,
                    com.epam.mdp.full.coders.stream.SeqNumHelper secNumHelper,
                    TransportType transportType)

Specified by:

connect in interface FastChannelReader

getDecoderFactory

public FASTDecoderFactory getDecoderFactory()
                                     throws java.io.IOException

Specified by:

getDecoderFactory in interface FastChannelReader

Throws:

java.io.IOException

disconnect

public void disconnect(Connection connection,
                       java.lang.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