biz.onixs.fix.benchmark.session

Class LatencyInitiator

java.lang.Object

biz.onixs.fix.benchmark.session.Participant

biz.onixs.fix.benchmark.session.Initiator

biz.onixs.fix.benchmark.session.LatencyInitiator

All Implemented Interfaces:

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

public class LatencyInitiator
extends Initiator
implements Session.InboundApplicationMessageListener

Field Summary

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

ACCEPTOR_ID, INITIATOR_ID

Constructor Summary

Constructors

Constructor and Description
LatencyInitiator()

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	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

LatencyInitiator

public LatencyInitiator()

Method Detail

isPrintHistogram

public boolean isPrintHistogram()

setPrintHistogram

public void setPrintHistogram(boolean printHistogram)

start

public void start()

Overrides:

start in class Initiator

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