com.marketfactory.mfclient.internal

Class MFStpBookingSessionImpl

java.lang.Object

com.marketfactory.mfclient.internal.MFStpBookingSessionImpl

All Implemented Interfaces:

CoreSession, CoreStpBookingSession

public class MFStpBookingSessionImpl
extends java.lang.Object
implements CoreStpBookingSession

Field Summary

Fields

Modifier and Type	Field and Description
protected long	heartbeatIntervalMs
protected java.lang.String	hostname
protected java.nio.ByteBuffer	logoutMessage
protected long	logoutSentToServerMs
protected long	maximumAllowedTimeWithoutReceivingLogoutResponseFromServerMs
protected long	maximumAllowedTimeWithoutReceivingMessageMs
protected int	port
protected java.nio.channels.Selector	selector
protected com.marketfactory.mfclient.internal.SessionState	state
protected static int	TWO_SECONDS

Constructor Summary

Constructors

Constructor and Description
MFStpBookingSessionImpl(CoreStpBookingHandler handler, java.nio.channels.Selector selector, java.lang.String username, java.lang.String password, java.lang.String hostname, int port, boolean relogonOnDisconnect, long heartbeatIntervalMs, MFProtoInputBufferStpBooking inputBuffer, BufferProvider bufferProvider, com.marketfactory.mfclient.internal.ChannelProvider channelProvider)

Method Summary

Modifier and Type	Method and Description
protected void	closeAndReset(boolean reconnectionPossible)
void	confirmation(mfstp_booking.ConfirmationEncoder confirmation)
protected void	encodeHeartbeatMessage()
protected void	encodeLogonMessage(byte[] username, byte[] password)
protected void	encodeLogoutMessage()
protected void	encodeLogoutResponse()
mfstp_booking.ConfirmationEncoder	getConfirmationEncoder()
mfstp_booking.NewOrderSingleEncoder	getNewOrderSingleEncoder()
mfstp_booking.OrderCancelReplaceRequestEncoder	getOrderCancelReplaceRequestEncoder()
mfstp_booking.OrderCancelRequestEncoder	getOrderCancelRequestEncoder()
int	getPort() The port used for this session.
long	getSendingTime()
protected com.marketfactory.mfclient.internal.SessionState.State	getState()
mfstp_booking.TradeCaptureReportSpotForwardEncoder	getTradeCaptureReportSpotForwardEncoder()
mfstp_booking.TradeCaptureReportSwapEncoder	getTradeCaptureReportSwapEncoder()
java.lang.String	getUsername()
protected void	handleMessage(int msgID)
boolean	isLoggedOn()
void	logon() Sends a logon message with the supplied username and password.
void	logon(long nextExpectedMsgSeqNum)
void	logout() Initiates logout.
void	logoutResponse() The response to a logout from the server.
void	newOrderSingle(mfstp_booking.NewOrderSingleEncoder newOrderSingle)
protected void	notifyUserOfConnection()
protected void	notifyUserOfDisconnection(java.lang.String message)
void	onConnectable()
protected void	onLogonResponseMessageReceived()
protected void	onLogoutMessageReceived()
protected void	onLogoutResponseMessageReceived()
void	onReadable()
void	onTimer(long now)
void	orderCancelReplaceRequest(mfstp_booking.OrderCancelReplaceRequestEncoder orderCancelReplaceRequest)
void	orderCancelRequest(mfstp_booking.OrderCancelRequestEncoder orderCancelRequest)
void	securityDefinitionRequest() Requests information about the securities supported on this venue.
void	start()
void	stop()
void	tradeCaptureReportSpotForward(mfstp_booking.TradeCaptureReportSpotForwardEncoder tradeCaptureReportSpotForward)
void	tradeCaptureReportSwap(mfstp_booking.TradeCaptureReportSwapEncoder tradeCaptureReportSwap)
protected void	write(MFProtoOutputBuffer buffer, int encodedLength)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.marketfactory.mfclient.internal.CoreSession

getPort, getSendingTime, getUsername, isLoggedOn, logout, logoutResponse

Field Detail

TWO_SECONDS

protected static final int TWO_SECONDS

See Also:

Constant Field Values

hostname

protected final java.lang.String hostname

port

protected final int port

heartbeatIntervalMs

protected final long heartbeatIntervalMs

selector

protected final java.nio.channels.Selector selector

logoutMessage

protected final java.nio.ByteBuffer logoutMessage

logoutSentToServerMs

protected long logoutSentToServerMs

state

protected final com.marketfactory.mfclient.internal.SessionState state

maximumAllowedTimeWithoutReceivingMessageMs

protected final long maximumAllowedTimeWithoutReceivingMessageMs

maximumAllowedTimeWithoutReceivingLogoutResponseFromServerMs

protected final long maximumAllowedTimeWithoutReceivingLogoutResponseFromServerMs

Constructor Detail

MFStpBookingSessionImpl

public MFStpBookingSessionImpl(CoreStpBookingHandler handler,
                               java.nio.channels.Selector selector,
                               java.lang.String username,
                               java.lang.String password,
                               java.lang.String hostname,
                               int port,
                               boolean relogonOnDisconnect,
                               long heartbeatIntervalMs,
                               MFProtoInputBufferStpBooking inputBuffer,
                               BufferProvider bufferProvider,
                               com.marketfactory.mfclient.internal.ChannelProvider channelProvider)

Method Detail

start

public void start()

stop

public void stop()
          throws MFException

Throws:

MFException

encodeLogoutResponse

protected void encodeLogoutResponse()
                             throws MFException

Throws:

MFException

tradeCaptureReportSpotForward

public void tradeCaptureReportSpotForward(mfstp_booking.TradeCaptureReportSpotForwardEncoder tradeCaptureReportSpotForward)
                                   throws MFException

Specified by:

tradeCaptureReportSpotForward in interface CoreStpBookingSession

Throws:

MFException

getTradeCaptureReportSpotForwardEncoder

public mfstp_booking.TradeCaptureReportSpotForwardEncoder getTradeCaptureReportSpotForwardEncoder()

Specified by:

getTradeCaptureReportSpotForwardEncoder in interface CoreStpBookingSession

tradeCaptureReportSwap

public void tradeCaptureReportSwap(mfstp_booking.TradeCaptureReportSwapEncoder tradeCaptureReportSwap)
                            throws MFException

Specified by:

tradeCaptureReportSwap in interface CoreStpBookingSession

Throws:

MFException

getTradeCaptureReportSwapEncoder

public mfstp_booking.TradeCaptureReportSwapEncoder getTradeCaptureReportSwapEncoder()

Specified by:

getTradeCaptureReportSwapEncoder in interface CoreStpBookingSession

confirmation

public void confirmation(mfstp_booking.ConfirmationEncoder confirmation)
                  throws MFException

Specified by:

confirmation in interface CoreStpBookingSession

Throws:

MFException

getConfirmationEncoder

public mfstp_booking.ConfirmationEncoder getConfirmationEncoder()

Specified by:

getConfirmationEncoder in interface CoreStpBookingSession

getOrderCancelRequestEncoder

public mfstp_booking.OrderCancelRequestEncoder getOrderCancelRequestEncoder()

Specified by:

getOrderCancelRequestEncoder in interface CoreStpBookingSession

orderCancelRequest

public void orderCancelRequest(mfstp_booking.OrderCancelRequestEncoder orderCancelRequest)
                        throws MFException

Specified by:

orderCancelRequest in interface CoreStpBookingSession

Throws:

MFException

getOrderCancelReplaceRequestEncoder

public mfstp_booking.OrderCancelReplaceRequestEncoder getOrderCancelReplaceRequestEncoder()

Specified by:

getOrderCancelReplaceRequestEncoder in interface CoreStpBookingSession

orderCancelReplaceRequest

public void orderCancelReplaceRequest(mfstp_booking.OrderCancelReplaceRequestEncoder orderCancelReplaceRequest)
                               throws MFException

Specified by:

orderCancelReplaceRequest in interface CoreStpBookingSession

Throws:

MFException

getNewOrderSingleEncoder

public mfstp_booking.NewOrderSingleEncoder getNewOrderSingleEncoder()

Specified by:

getNewOrderSingleEncoder in interface CoreStpBookingSession

newOrderSingle

public void newOrderSingle(mfstp_booking.NewOrderSingleEncoder newOrderSingle)
                    throws MFException

Specified by:

newOrderSingle in interface CoreStpBookingSession

Throws:

MFException

handleMessage

protected void handleMessage(int msgID)
                      throws MFException

Throws:

MFException

encodeLogoutMessage

protected void encodeLogoutMessage()
                            throws MFException

Throws:

MFException

encodeLogonMessage

protected void encodeLogonMessage(byte[] username,
                                  byte[] password)
                           throws MFException

Throws:

MFException

encodeHeartbeatMessage

protected void encodeHeartbeatMessage()
                               throws MFException

Throws:

MFException

notifyUserOfDisconnection

protected void notifyUserOfDisconnection(java.lang.String message)

notifyUserOfConnection

protected void notifyUserOfConnection()

logon

public void logon()
           throws MFException

Description copied from interface: CoreSession

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 CoreSession

Specified by:

logon in interface CoreStpBookingSession

Throws:

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

logon

public void logon(long nextExpectedMsgSeqNum)
           throws MFException

Specified by:

logon in interface CoreStpBookingSession

Throws:

MFException

securityDefinitionRequest

public void securityDefinitionRequest()
                               throws MFException

Description copied from interface: CoreStpBookingSession

Requests information about the securities supported on this venue.

Specified by:

securityDefinitionRequest in interface CoreStpBookingSession

Throws:

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

getUsername

public java.lang.String getUsername()

Specified by:

getUsername in interface CoreSession

getPort

public int getPort()

Description copied from interface: CoreSession

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

Specified by:

getPort in interface CoreSession

Returns:

the port associated with this session.

logout

public void logout()
            throws MFException

Description copied from interface: CoreSession

Initiates logout. This should be called so a clean and dirty (one where the socket closes w/o a logout) can be easily differentiated. Should only be called in the event loop by the handler.

Specified by:

logout in interface CoreSession

Throws:

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

logoutResponse

public void logoutResponse()
                    throws MFException

Description copied from interface: CoreSession

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. Should only be called in the event loop by the handler.

Specified by:

logoutResponse in interface CoreSession

Throws:

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

isLoggedOn

public boolean isLoggedOn()

Specified by:

isLoggedOn in interface CoreSession

onReadable

public void onReadable()
                throws MFException

Throws:

MFException

onConnectable

public void onConnectable()
                   throws MFException

Throws:

MFException

onTimer

public void onTimer(long now)
             throws MFException

Throws:

MFException

getSendingTime

public long getSendingTime()

Specified by:

getSendingTime in interface CoreSession

getState

protected com.marketfactory.mfclient.internal.SessionState.State getState()

onLogonResponseMessageReceived

protected void onLogonResponseMessageReceived()
                                       throws MFException

Throws:

MFException

onLogoutMessageReceived

protected void onLogoutMessageReceived()

onLogoutResponseMessageReceived

protected void onLogoutResponseMessageReceived()

write

protected void write(MFProtoOutputBuffer buffer,
                     int encodedLength)
              throws MFException

Throws:

MFException

closeAndReset

protected void closeAndReset(boolean reconnectionPossible)
                      throws MFException

Throws:

MFException