biz.onixs.fix.benchmark.session

Class ThroughputAcceptor

java.lang.Object

biz.onixs.fix.benchmark.session.Participant

biz.onixs.fix.benchmark.session.Acceptor

biz.onixs.fix.benchmark.session.ThroughputAcceptor

All Implemented Interfaces:

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

public class ThroughputAcceptor
extends Acceptor
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
ThroughputAcceptor()

Method Summary

Modifier and Type	Method and Description
void	onInboundApplicationMessage(Object sender, Session.InboundApplicationMessageArgs args) This method is called when an application-level message is received from the counterparty.

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

start

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

ThroughputAcceptor

public ThroughputAcceptor()

Method Detail

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