Participant (Java FIX Engine Package 2.7.1 API)

java.lang.Object
- biz.onixs.fix.benchmark.session.Participant

All Implemented Interfaces:: Session.InboundSessionMessageListener, Session.OutboundApplicationMessageListener, Session.OutboundSessionMessageListener, Session.StateChangeListener

Direct Known Subclasses:: Acceptor, Initiator

public abstract class Participant
extends Object
implements Session.StateChangeListener, Session.OutboundApplicationMessageListener, Session.InboundSessionMessageListener, Session.OutboundSessionMessageListener

Field Summary

Fields
Modifier and Type Field and Description

static String ACCEPTOR_ID

static String INITIATOR_ID

Fields
Modifier and Type	Field and Description
`static String`	`ACCEPTOR_ID`
`static String`	`INITIATOR_ID`

Constructor Summary

Constructors
Constructor and Description

Participant()

Constructors
Constructor and Description
`Participant()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`CountDownLatch`	`getCompleted()`
`String`	`getFixVersionId()`
`long`	`getLogStatNumber()`
`long`	`getMessageNum()`
`int`	`getNumber()`
`Session`	`getSession()`
`String`	`getStorageTypeId()`
`long`	`getTotalMessageNum()`
`long`	`getWarmUpMessageNum()`
`void`	`onInboundSessionMessage(Object sender, Session.InboundSessionMessageArgs args)` This method is called when an session-level message is received from the counterparty.
`void`	`onOutboundApplicationMessage(Object sender, Session.OutboundApplicationMessageArgs args)` This method is called right before an application-level message is queued for sending.
`void`	`onOutboundSessionMessage(Object sender, Session.OutboundSessionMessageArgs args)` This method is called right before a session-level message is queued for sending.
`void`	`onStateChange(Object sender, Session.StateChangeArgs args)` This method is called when a session state is changed.
`void`	`send(FlatMessage message)`
`void`	`send(Message message)`
`void`	`setFixVersionId(String fixVersionId)`
`void`	`setLogStatNumber(long logStatNumber)`
`void`	`setMessageNum(long messageNum)`
`void`	`setNumber(int number)`
`void`	`setReceivingThreadAffinity(int[] receivingThreadAffinity)`
`void`	`setSendingThreadAffinity(int[] sendingThreadAffinity)`
`void`	`setStorageTypeId(String storageTypeId)`
`void`	`setWarmUpMessageNum(long warmUpMessageNum)`
`void`	`start()`
`void`	`stop()`
`void`	`waitCompletion()`

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - ACCEPTOR_ID
```
public static final String ACCEPTOR_ID
```
    See Also:
    
    Constant Field Values
  - INITIATOR_ID
```
public static final String INITIATOR_ID
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - Participant
```
public Participant()
```
- Method Detail
  - getCompleted
```
public CountDownLatch getCompleted()
```
  - getFixVersionId
```
public String getFixVersionId()
```
  - setFixVersionId
```
public void setFixVersionId(String fixVersionId)
```
  - getSession
```
public Session getSession()
```
  - getStorageTypeId
```
public String getStorageTypeId()
```
  - setStorageTypeId
```
public void setStorageTypeId(String storageTypeId)
```
  - getNumber
```
public int getNumber()
```
  - setNumber
```
public void setNumber(int number)
```
  - getWarmUpMessageNum
```
public long getWarmUpMessageNum()
```
  - setWarmUpMessageNum
```
public void setWarmUpMessageNum(long warmUpMessageNum)
```
  - getMessageNum
```
public long getMessageNum()
```
  - setMessageNum
```
public void setMessageNum(long messageNum)
```
  - getLogStatNumber
```
public long getLogStatNumber()
```
  - setLogStatNumber
```
public void setLogStatNumber(long logStatNumber)
```
  - getTotalMessageNum
```
public long getTotalMessageNum()
```
  - setReceivingThreadAffinity
```
public void setReceivingThreadAffinity(int[] receivingThreadAffinity)
```
  - setSendingThreadAffinity
```
public void setSendingThreadAffinity(int[] sendingThreadAffinity)
```
  - start
```
public void start()
```
  - stop
```
public void stop()
```
  - waitCompletion
```
public void waitCompletion()
```
  - send
```
public void send(Message message)
```
  - send
```
public void send(FlatMessage message)
```
  - onStateChange
```
public void onStateChange(Object sender,
                          Session.StateChangeArgs args)
```
    Description copied from interface: Session.StateChangeListener
    This method is called when a session state is changed.
    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.
    Specified by:
    
    onStateChange in interface Session.StateChangeListener
    
    Parameters:
    
    sender - event source
    
    args - event data
  - onOutboundApplicationMessage
```
public void onOutboundApplicationMessage(Object sender,
                                         Session.OutboundApplicationMessageArgs args)
```
    Description copied from interface: Session.OutboundApplicationMessageListener
    This method is called right before an application-level message is queued for sending. The event gives you access to the actual message object (not copy). Thus it can be amended according to the specific application needs.
    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.
    Specified by:
    
    onOutboundApplicationMessage in interface Session.OutboundApplicationMessageListener
    
    Parameters:
    
    sender - event source
    
    args - event data
  - onInboundSessionMessage
```
public void onInboundSessionMessage(Object sender,
                                    Session.InboundSessionMessageArgs args)
```
    Description copied from interface: Session.InboundSessionMessageListener
    This method is called when an session-level message is received from the counterparty. If this method throws an exception then the session is closed with logout.
    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.
    Specified by:
    
    onInboundSessionMessage in interface Session.InboundSessionMessageListener
    
    Parameters:
    
    sender - event source
    
    args - event data
  - onOutboundSessionMessage
```
public void onOutboundSessionMessage(Object sender,
                                     Session.OutboundSessionMessageArgs args)
```
    Description copied from interface: Session.OutboundSessionMessageListener
    This method is called right before a session-level message is queued for sending. The event gives you access to the actual message object (not copy). Thus the message can be amended according to the specific application needs.
    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.
    Specified by:
    
    onOutboundSessionMessage in interface Session.OutboundSessionMessageListener
    
    Parameters:
    
    sender - event source
    
    args - event data

Class Participant

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

ACCEPTOR_ID

INITIATOR_ID

Constructor Detail

Participant

Method Detail

getCompleted

getFixVersionId

setFixVersionId

getSession

getStorageTypeId

setStorageTypeId

getNumber

setNumber

getWarmUpMessageNum

setWarmUpMessageNum

getMessageNum

setMessageNum

getLogStatNumber

setLogStatNumber

getTotalMessageNum

setReceivingThreadAffinity

setSendingThreadAffinity

start

stop

waitCompletion

send

send

onStateChange

onOutboundApplicationMessage

onInboundSessionMessage

onOutboundSessionMessage