com.marketfactory.mfclient.internal.core.marketdata

Class MFMarketDataSessionToCoreMarketDataSessionAdapter

java.lang.Object

com.marketfactory.mfclient.internal.core.marketdata.MFMarketDataSessionToCoreMarketDataSessionAdapter

All Implemented Interfaces:

MFMarketDataSession, MFSession

public final class MFMarketDataSessionToCoreMarketDataSessionAdapter
extends java.lang.Object
implements MFMarketDataSession

Adapts a MFMarketDataSession to a CoreMarketDataSession CoreMarketDataSession is an internal, SBE encoder/decoder oriented interface while the MFMarketDataSession uses MF domain objects.

Constructor Summary

Constructors

Constructor and Description
MFMarketDataSessionToCoreMarketDataSessionAdapter(CoreMarketDataSession delegate)

Method Summary

Modifier and Type	Method and Description
int	getPort() The port used for this session.
long	getSendingTime() Retrieves the MF server sending time (nanoseconds since epoch) of the current message frame.
java.lang.String	getUsername() The username used for this session.
long	getVenueID() Gets the venue ID associated with this session.
java.lang.String	getVenueName() Gets the venue name associated with this session.
boolean	isLoggedOn()
void	logon() Sends a logon message with the supplied username and password.
void	logout() Initiates logout.
void	logoutResponse() The response to a logout from the server.
void	marketDataRequest(mfmarketdata.SubscriptionRequestType subType, long securityID) A request to subscribe or unsubscribe to a particular security.
void	marketDataRequestHistoric(mfmarketdata.SubscriptionRequestType subType, long startTimestamp, long endTimestamp, long venueID, long securityID)
void	registerForBatch(int batchDefinitionID, long[] securityIDs) Register for a given list of securities.
void	securityDefinitionRequest() Requests information about the securities supported on this venue.
java.lang.String	toString()
void	unregisterFromBatch(int batchDefinitionID) Unregister for a previously subscribed for batch of securities.

Methods inherited from class java.lang.Object

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

Constructor Detail

MFMarketDataSessionToCoreMarketDataSessionAdapter

public MFMarketDataSessionToCoreMarketDataSessionAdapter(CoreMarketDataSession delegate)
                                                  throws MFException

Throws:

MFException

Method Detail

getUsername

public java.lang.String getUsername()

Description copied from interface: MFSession

The username used for this session.

Specified by:

getUsername in interface MFSession

Returns:

username associated with this session.

getPort

public int getPort()

Description copied from interface: MFSession

The port used for this session. Useful to see if the port was calculated.

Specified by:

getPort in interface MFSession

Returns:

the port associated with this session.

getVenueID

public long getVenueID()

Description copied from interface: MFMarketDataSession

Gets the venue ID associated with this session.

Specified by:

getVenueID in interface MFMarketDataSession

getVenueName

public java.lang.String getVenueName()

Description copied from interface: MFMarketDataSession

Gets the venue name associated with this session.

Specified by:

getVenueName in interface MFMarketDataSession

securityDefinitionRequest

public void securityDefinitionRequest()
                               throws MFException

Description copied from interface: MFMarketDataSession

Requests information about the securities supported on this venue.

Specified by:

securityDefinitionRequest in interface MFMarketDataSession

Throws:

MFException - If there is an error when attempting to send this message.

marketDataRequest

public void marketDataRequest(mfmarketdata.SubscriptionRequestType subType,
                              long securityID)
                       throws MFException

Description copied from interface: MFMarketDataSession

A request to subscribe or unsubscribe to a particular security.

Specified by:

marketDataRequest in interface MFMarketDataSession

Throws:

MFException - If there is an error when attempting to send this message

marketDataRequestHistoric

public void marketDataRequestHistoric(mfmarketdata.SubscriptionRequestType subType,
                                      long startTimestamp,
                                      long endTimestamp,
                                      long venueID,
                                      long securityID)
                               throws MFException

Specified by:

marketDataRequestHistoric in interface MFMarketDataSession

Throws:

MFException

registerForBatch

public void registerForBatch(int batchDefinitionID,
                             long[] securityIDs)
                      throws MFException

Description copied from interface: MFMarketDataSession

Register for a given list of securities. The provided batchDefinitionID will be sent back in all callbacks. It is also needed when you MFMarketDataSession.unregisterFromBatch(int)

Specified by:

registerForBatch in interface MFMarketDataSession

Parameters:

batchDefinitionID - identifier for the batch that you can use to later unregister

securityIDs - list of ids of securities to include in this batch

Throws:

MFException

unregisterFromBatch

public void unregisterFromBatch(int batchDefinitionID)
                         throws MFException

Description copied from interface: MFMarketDataSession

Unregister for a previously subscribed for batch of securities. Use the batchDefinitionID used when registering for batch MFMarketDataSession.registerForBatch(int, long[])

Specified by:

unregisterFromBatch in interface MFMarketDataSession

Parameters:

batchDefinitionID - identifier for the batch to unregister

Throws:

MFException

logon

public void logon()
           throws MFException

Description copied from interface: MFSession

Sends a logon message with the supplied username and password. Should only be called in the event loop by the handler.

Specified by:

logon in interface MFSession

Throws:

MFException - If there is an error when attempting to send this message.

logout

public void logout()
            throws MFException

Description copied from interface: MFSession

Initiates logout. This should be called so a clean and dirty (one where the socket closes w/o a logout) can be easily differentiated. Can be called from any thread

Specified by:

logout in interface MFSession

Throws:

MFException - If there is an error when attempting to send this message.

isLoggedOn

public boolean isLoggedOn()

Specified by:

isLoggedOn in interface MFSession

logoutResponse

public void logoutResponse()
                    throws MFException

Description copied from interface: MFSession

The response to a logout from the server. This should be called if a logout is received so that the client can indicate a clean logout. Can be called from any thread

Specified by:

logoutResponse in interface MFSession

Throws:

MFException - If there is an error when attempting to send this message.

getSendingTime

public long getSendingTime()

Description copied from interface: MFSession

Retrieves the MF server sending time (nanoseconds since epoch) of the current message frame. If the message frame has multiple messages the returned timestamp might be the same for several callbacks messages.
If called before data is received, will return 0.
Note: No synchronization. Should not be called outside the callback thread.

Specified by:

getSendingTime in interface MFSession

Returns:

timestamp current message was sent from the MF servers (in nanos)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object