com.epam.cmefast.adaptor

Class CMEChannel

java.lang.Object

com.epam.cmefast.adaptor.CMEChannel

All Implemented Interfaces:

Channel

public class CMEChannel
extends Object
implements Channel

CME implementation of FAST Channel API

Constructor Summary

Constructors

Constructor and Description
CMEChannel(CMEApplicationParam applicationParams)
CMEChannel(CMEApplicationParam applicationParams, FastChannelReader reader)

Method Summary

Modifier and Type	Method and Description
protected boolean	doNaturalRefresh(String secDesc, long secID, List<com.epam.fix.message.FIXFieldList> groupEntries)
void	findInstrumentBySecID(String secId, SecurityDefinitionListener securityListener) Finds instrument in channel.
void	findInstrumentBySymbol(String symbol, SecurityDefinitionListener securityListener) Finds instrument in channel.
void	findInstruments(SecurityDefinitionListener securityListener) Finds all instrument in channel.
void	setErrorListener(ErrorListener errorListener) Sets error listener.
void	setInstrumentListener(InstrumentListener instrumentListener) Sets instrument listener.
void	setMessageListener(MessageListener messageListener) Sets message listener.
void	stop() Stop channel and close opened connections.
void	stopFindInstrumentBySecID(String secId, SecurityDefinitionListener securityListener)
void	stopFindInstrumentBySymbol(String symbol, SecurityDefinitionListener securityListener)
void	stopFindInstruments(SecurityDefinitionListener securityListener)
void	subscribeAll() Subscribe for all instruments.
boolean	subscribeChannel(String channelID) Subscribe to instruments on channel.
void	subscribeSecGroup(String secGroup) Subscribe to instrument.
void	subscribeSecId(String secId) Subscribe to instrument.
void	subscribeSymbol(String symbol) Subscribe to instrument.
void	unSubscribeAll() UnSubscribe from instruments.
void	unSubscribeChannel(String channelID) Unsubscribe from instruments on channel.
void	unSubscribeSecGroup(String secGroup) UnSubscribe to instrument.
void	unSubscribeSecId(String secId) UnSubscribe to instrument.
void	unSubscribeSymbol(String symbol) UnSubscribe from instrument.

Methods inherited from class java.lang.Object

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

Constructor Detail

CMEChannel

public CMEChannel(CMEApplicationParam applicationParams)

CMEChannel

public CMEChannel(CMEApplicationParam applicationParams,
                  FastChannelReader reader)

Method Detail

setInstrumentListener

public void setInstrumentListener(InstrumentListener instrumentListener)

Description copied from interface: Channel

Sets instrument listener.

Specified by:

setInstrumentListener in interface Channel

Parameters:

instrumentListener - the instrument listener

setMessageListener

public void setMessageListener(MessageListener messageListener)

Description copied from interface: Channel

Sets message listener.

Specified by:

setMessageListener in interface Channel

Parameters:

messageListener - the message listener

setErrorListener

public void setErrorListener(ErrorListener errorListener)

Description copied from interface: Channel

Sets error listener.

Specified by:

setErrorListener in interface Channel

Parameters:

errorListener - the error listener

findInstruments

public void findInstruments(SecurityDefinitionListener securityListener)
                     throws IOException

Description copied from interface: Channel

Finds all instrument in channel.

Specified by:

findInstruments in interface Channel

Parameters:

securityListener - the callback listener.

Throws:

IOException - - if error occurred

stopFindInstruments

public void stopFindInstruments(SecurityDefinitionListener securityListener)
                         throws IOException

Throws:

IOException

findInstrumentBySymbol

public void findInstrumentBySymbol(String symbol,
                                   SecurityDefinitionListener securityListener)
                            throws IOException

Description copied from interface: Channel

Finds instrument in channel.

Specified by:

findInstrumentBySymbol in interface Channel

Parameters:

symbol - the symbol

securityListener - the listener

Throws:

IOException - - if error occurred

stopFindInstrumentBySymbol

public void stopFindInstrumentBySymbol(String symbol,
                                       SecurityDefinitionListener securityListener)
                                throws IOException

Throws:

IOException

findInstrumentBySecID

public void findInstrumentBySecID(String secId,
                                  SecurityDefinitionListener securityListener)
                           throws IOException

Description copied from interface: Channel

Finds instrument in channel.

Specified by:

findInstrumentBySecID in interface Channel

Parameters:

secId - the security Id

securityListener - the listener

Throws:

IOException - - if error occurred

stopFindInstrumentBySecID

public void stopFindInstrumentBySecID(String secId,
                                      SecurityDefinitionListener securityListener)
                               throws IOException

Throws:

IOException

subscribeAll

public void subscribeAll()
                  throws IOException

Description copied from interface: Channel

Subscribe for all instruments.

Specified by:

subscribeAll in interface Channel

Throws:

IOException - - if error occurred

unSubscribeAll

public void unSubscribeAll()
                    throws IOException

Description copied from interface: Channel

UnSubscribe from instruments.

Specified by:

unSubscribeAll in interface Channel

Throws:

IOException - - if error occurred

subscribeSymbol

public void subscribeSymbol(String symbol)
                     throws IOException

Description copied from interface: Channel

Subscribe to instrument.

Specified by:

subscribeSymbol in interface Channel

Parameters:

symbol - the symbol

Throws:

IOException - - if error occurred

unSubscribeSymbol

public void unSubscribeSymbol(String symbol)

Description copied from interface: Channel

UnSubscribe from instrument.

Specified by:

unSubscribeSymbol in interface Channel

Parameters:

symbol - the symbol

subscribeSecId

public void subscribeSecId(String secId)
                    throws IOException

Description copied from interface: Channel

Subscribe to instrument.

Specified by:

subscribeSecId in interface Channel

Parameters:

secId - the security ID

Throws:

IOException - - if error occurred

unSubscribeSecId

public void unSubscribeSecId(String secId)

Description copied from interface: Channel

UnSubscribe to instrument.

Specified by:

unSubscribeSecId in interface Channel

Parameters:

secId - the security ID

subscribeChannel

public boolean subscribeChannel(String channelID)
                         throws IOException

Description copied from interface: Channel

Subscribe to instruments on channel.

Specified by:

subscribeChannel in interface Channel

Parameters:

channelID - unique id of channel

Throws:

IOException - - if error occurred

unSubscribeChannel

public void unSubscribeChannel(String channelID)
                        throws IOException

Description copied from interface: Channel

Unsubscribe from instruments on channel.

Specified by:

unSubscribeChannel in interface Channel

Parameters:

channelID - unique id of channel

Throws:

IOException - - if error occurred

subscribeSecGroup

public void subscribeSecGroup(String secGroup)
                       throws IOException

Description copied from interface: Channel

Subscribe to instrument.

Specified by:

subscribeSecGroup in interface Channel

Parameters:

secGroup - the security group

Throws:

IOException - - if error occurred

unSubscribeSecGroup

public void unSubscribeSecGroup(String secGroup)

Description copied from interface: Channel

UnSubscribe to instrument.

Specified by:

unSubscribeSecGroup in interface Channel

Parameters:

secGroup - the security group

doNaturalRefresh

protected boolean doNaturalRefresh(String secDesc,
                                   long secID,
                                   List<com.epam.fix.message.FIXFieldList> groupEntries)

stop

public void stop()

Description copied from interface: Channel

Stop channel and close opened connections.

Specified by:

stop in interface Channel