biz.onixs.fix.benchmark.session

Class LatencyInitiatorSendRecv

java.lang.Object

biz.onixs.fix.benchmark.session.Participant

biz.onixs.fix.benchmark.session.Initiator

biz.onixs.fix.benchmark.session.LatencyInitiatorSendRecv

All Implemented Interfaces:

Session.InboundApplicationMessageListener, Session.InboundSessionMessageListener, Session.MessageSendingListener, Session.OutboundApplicationMessageListener, Session.OutboundSessionMessageListener, Session.ReceivedBytesListener, Session.StateChangeListener

public class LatencyInitiatorSendRecv
extends Initiator
implements Session.InboundApplicationMessageListener, Session.MessageSendingListener, Session.ReceivedBytesListener

Field Summary

Fields inherited from class biz.onixs.fix.benchmark.session.Participant

ACCEPTOR_ID, INITIATOR_ID

Constructor Summary

Constructors

Constructor and Description
LatencyInitiatorSendRecv()

Method Summary

Modifier and Type	Method and Description
boolean	isPrintHistogram()
void	onInboundApplicationMessage(Object sender, Session.InboundApplicationMessageArgs args) This method is called when an application-level message is received from the counterparty.
void	onMessageSending(Object sender, Session.MessageSendingArgs args) This method is called right before the bytes is sent to the wire.
void	onReceivedBytes(Object sender, Session.ReceivedBytesArgs args) This method is called as soon as bytes are received from the wire.
void	setPrintHistogram(boolean printHistogram)
void	start()

Methods inherited from class biz.onixs.fix.benchmark.session.Initiator

getCounterpartyHost, getCounterpartyPort, setCounterpartyHost, setCounterpartyPort

Methods inherited from class biz.onixs.fix.benchmark.session.Participant

getCompleted, getFixVersionId, getLogStatNumber, getMessageNum, getNumber, getSession, getStorageTypeId, getTotalMessageNum, getWarmUpMessageNum, onInboundSessionMessage, onOutboundApplicationMessage, onOutboundSessionMessage, onStateChange, send, send, setFixVersionId, setLogStatNumber, setMessageNum, setNumber, setReceivingThreadAffinity, setSendingThreadAffinity, setStorageTypeId, setWarmUpMessageNum, stop, waitCompletion

Methods inherited from class java.lang.Object

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

Constructor Detail

LatencyInitiatorSendRecv

public LatencyInitiatorSendRecv()

Method Detail

isPrintHistogram

public boolean isPrintHistogram()

setPrintHistogram

public void setPrintHistogram(boolean printHistogram)

start

public void start()

Overrides:

start in class Initiator

onMessageSending

public void onMessageSending(Object sender,
                             Session.MessageSendingArgs args)

Description copied from interface: Session.MessageSendingListener

This method is called right before the bytes is sent to the wire. In case of non blocking sends the listener does not called. Warning. It is critical to avoid time-consuming tasks.

Specified by:

onMessageSending in interface Session.MessageSendingListener

Parameters:

sender - event source

args - event data

onReceivedBytes

public void onReceivedBytes(Object sender,
                            Session.ReceivedBytesArgs args)

Description copied from interface: Session.ReceivedBytesListener

This method is called as soon as bytes are received from the wire. Warning. It is critical to avoid time-consuming tasks.

Specified by:

onReceivedBytes in interface Session.ReceivedBytesListener

Parameters:

sender - event source

args - event data

onInboundApplicationMessage

public void onInboundApplicationMessage(Object sender,
                                        Session.InboundApplicationMessageArgs args)

Description copied from interface: Session.InboundApplicationMessageListener

This method is called when an application-level message is received from the counterparty. Warning. It is critical to avoid

• time-consuming tasks
• session management method calls (logon, logout, reset, etc.)

in the session event listener calling thread. Please do it from another thread. If this method throws an exception:

• session FIX version >= FIX 4.2 - the business level reject is sent automatically to the counterparty with the reason from the thrown exception
• session FIX version < 4.2 - the session level reject is sent automatically to the counterparty with the reason from the thrown exception
• session continues to operate normally

Specified by:

onInboundApplicationMessage in interface Session.InboundApplicationMessageListener

Parameters:

sender - event source

args - event data