Modifier and Type | Method and Description |
---|---|
List<RecordsInfo> |
RecordsGenerator.processMessage(IMessage msg)
Process
IMessage and generates fields records of CME Audit Trail spreadsheet. |
Modifier and Type | Method and Description |
---|---|
List<RecordsInfo> |
RecordsGenerator.processMessages(List<IMessage> msgs)
Process collection of
IMessage and generates fields records of CME Audit Trail spreadsheet. |
Modifier and Type | Method and Description |
---|---|
IMessage |
MessageFactory.createMessage()
Factory method to create new flat message.
|
Modifier and Type | Method and Description |
---|---|
List<IMessage> |
Session.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber)
Returns outbound messages with the specified sequence number interval.
|
Modifier and Type | Method and Description |
---|---|
Session |
Session.send(IMessage message)
Sends SBE message.
|
Session |
Session.warmUp(IMessage message)
Warms up the sending path.
|
Modifier and Type | Method and Description |
---|---|
IMessage |
TerminateInReplyOnEstablishException.getReceivedMsg()
Received message.
|
IMessage |
EstablishmentRejectException.getRejectMsg()
Received reject message.
|
IMessage |
NegotiationRejectException.getRejectMsg()
Received reject message.
|
Constructor and Description |
---|
BusinessRejectInReplyOnEstablishException(IMessage receivedMsg) |
EstablishmentRejectException(IMessage rejectMsg) |
NegotiationRejectException(IMessage rejectMsg) |
TerminateInReplyOnEstablishException(IMessage receivedMsg) |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageFilter.filter(IMessage message)
Returns whether this message must be filtered.
|
boolean |
NullMessageFilter.filter(IMessage message) |
boolean |
TypeMessageFilter.filter(IMessage message) |
Modifier and Type | Method and Description |
---|---|
IMessage |
MessageEventArgs.getMsg()
Returns event-related message.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageEventArgs.setMsg(IMessage msg) |
Constructor and Description |
---|
InboundApplicationMessageArgs(IMessage msg)
Creates event data.
|
InboundSessionMessageArgs(IMessage msg)
Creates event data.
|
NotAppliedArgs(IMessage msg)
Creates event data.
|
NotAppliedArgs(IMessage msg,
long fromSeqNo,
int msgCount)
Creates event data.
|
OutboundApplicationMessageArgs(IMessage msg)
Creates event data.
|
OutboundSessionMessageArgs(IMessage msg)
Creates event data.
|
Modifier and Type | Method and Description |
---|---|
List<IMessage> |
AsyncFileSessionStorage.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber) |
List<IMessage> |
FileBasedSessionStorage.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber) |
List<IMessage> |
MemoryBasedSessionStorage.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber) |
List<IMessage> |
NullSessionStorage.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber) |
List<IMessage> |
SessionStorage.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber)
Returns outbound messages with the specified sequence number interval.
|
List<IMessage> |
TimingSessionStorage.getOutboundMessages(long beginSequenceNumber,
long endSequenceNumber) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncFileSessionStorage.storeInboundMessage(IMessage message,
long msgSeqNum) |
void |
FileBasedSessionStorage.storeInboundMessage(IMessage message,
long msgSeqNum) |
void |
MemoryBasedSessionStorage.storeInboundMessage(IMessage message,
long msgSeqNum) |
void |
NullSessionStorage.storeInboundMessage(IMessage message,
long msgSeqNum) |
void |
SessionStorage.storeInboundMessage(IMessage message,
long msgSeqNum)
Stores inbound message.
|
void |
TimingSessionStorage.storeInboundMessage(IMessage message,
long msgSeqNum) |
void |
AsyncFileSessionStorage.storeOutboundMessage(IMessage message,
long msgSeqNum,
boolean warmUp) |
void |
FileBasedSessionStorage.storeOutboundMessage(IMessage message,
long msgSeqNum,
boolean warmUp) |
void |
MemoryBasedSessionStorage.storeOutboundMessage(IMessage message,
long msgSeqNum,
boolean warmUp) |
void |
NullSessionStorage.storeOutboundMessage(IMessage message,
long msgSeqNum,
boolean warmUp) |
void |
SessionStorage.storeOutboundMessage(IMessage message,
long msgSeqNum,
boolean warmUp)
Stores outbound message.
|
void |
TimingSessionStorage.storeOutboundMessage(IMessage message,
long msgSeqNum,
boolean warmUp) |
Modifier and Type | Method and Description |
---|---|
IMessage |
Emulator.acceptEstablishment()
Accepts an "Establish" message and automatically sends a corresponding establishment response.
|
IMessage |
Emulator.acceptEstablishment(long outgoingSequenceNumber)
Accepts an "Establish" message and automatically sends a corresponding establishment response.
|
IMessage |
Emulator.acceptEstablishment(long outgoingSequenceNumber,
long expectedIncomingSequenceNumber,
long previousUuid,
long previousSeqNo)
Accepts an "Establish" message, allows setting expected sequence numbers and previous UUID/SeqNo.
|
IMessage |
Emulator.acceptEstablishmentWithoutResponse()
Accepts an "Establish" message, used to confirm session setup after negotiation.
|
IMessage |
Emulator.acceptNegotiation()
Accepts a "Negotiate" message and automatically sends a corresponding negotiation response.
|
IMessage |
Emulator.acceptNegotiationWithoutResponse()
Receives a "Negotiate" message, used at the start of a communication session.
|
IMessage |
Emulator.acceptSequence(int keepAliveIntervalLapsed)
Accepts a sequence message, including checking the KeepAliveLapsed status.
|
IMessage |
Emulator.acceptTerminate()
Accepts a "Terminate" message and sends a confirmation response.
|
IMessage |
Emulator.acceptTerminateWithoutResponse()
Accepts a "Terminate" message without sending any response.
|
IMessage |
TestUtility.createBusinessReject() |
IMessage |
TestUtility.createEstablishment(long uuid,
long requestTimestamp,
int keepAliveInterval) |
IMessage |
TestUtility.createEstablishmentReject(long uuid,
long requestTimestamp) |
IMessage |
Emulator.createExecutionReportTradeOutright(long orderId,
boolean retransmission) |
IMessage |
TestUtility.createExecutionReportTradeOutright(long uuid,
long orderId,
boolean retransmission) |
IMessage |
TestUtility.createMassQuote() |
IMessage |
Emulator.createMassQuoteAck(boolean retransmission) |
IMessage |
TestUtility.createMassQuoteAck(long uuid,
boolean retransmission) |
IMessage |
TestUtility.createNegotiationReject(long uuid,
long requestTimestamp) |
IMessage |
TestUtility.createNegotiationResponse(long uuid,
long requestTimestamp) |
IMessage |
TestUtility.createNotApplied(long uuid,
long fromSeqNo,
int msgCount) |
IMessage |
TestUtility.createOrder(int orderRequestID) |
IMessage |
TestUtility.createRetransmission(IMessage request) |
IMessage |
TestUtility.createRetransmission(long uuid,
long lastUUID,
long requestTimestamp,
long fromSeqNo,
int msgCount) |
IMessage |
TestUtility.createRetransmitReject(IMessage request,
int errorCodes,
String reason) |
IMessage |
TestUtility.createRetransmitReject(long uuid,
long lastUUID,
long requestTimestamp,
int errorCodes,
String reason) |
IMessage |
TestUtility.createSequence(long uuid,
long nextSeqNo,
int keepAliveLapsed) |
IMessage |
TestUtility.createTerminate(long uuid,
long requestTimestamp,
String reason,
int errorCode) |
IMessage |
TestUtility.createUnknownMessage(int templateId) |
IMessage |
Emulator.receiveMessage()
Receives the next available message.
|
IMessage |
Emulator.receiveMessage(int inSeqNum)
Receives a message, asserting that it has the expected sequence number.
|
IMessage |
Emulator.receiveMessage(int inSeqNum,
int templateId)
Receives a message, asserting that it has the expected sequence number and template ID.
|
IMessage |
Emulator.receiveOrder(int inSeqNum)
Receives a "NewOrderSingle" message and verifies its sequence number.
|
IMessage |
Emulator.receiveRetransmitRequest(long fromSeqNo,
long msgCount)
Receives a "RetransmitRequest" message, verifying the provided sequence numbers.
|
IMessage |
Emulator.receiveSequence(int nextSeqNo)
Receives a "Sequence" message and verifies its sequence number.
|
IMessage |
Emulator.rejectEstablishment()
Accepts an "Establish" message and automatically sends a rejection response.
|
IMessage |
Emulator.rejectNegotiation()
Accepts a "Negotiate" message and automatically sends a rejection response.
|
IMessage |
Emulator.terminate()
Initiates a "Terminate" sequence and waits for the corresponding Terminate response.
|
IMessage |
Emulator.terminateWithoutResponse(String text)
Initiates a "Terminate" sequence (with customizable text) without waiting for a response.
|
IMessage |
Emulator.terminateWithoutResponse(String text,
int errorCode)
Initiates a "Terminate" sequence (with customizable text) without waiting for a response.
|
IMessage |
Emulator.waitUntilTerminate(Emulator.MessageListener listener)
Waits for a "Terminate" message and provides a way to process other incoming messages during the wait.
|
Modifier and Type | Method and Description |
---|---|
IMessage |
TestUtility.createRetransmission(IMessage request) |
IMessage |
TestUtility.createRetransmitReject(IMessage request,
int errorCodes,
String reason) |
void |
Emulator.MessageListener.onMessageReceived(IMessage msg) |
void |
Emulator.send(IMessage msg)
Sends an IMessage object.
|
void |
Emulator.send(IMessage msg,
long seqNum)
Sends an IMessage object with sequence number.
|
void |
Emulator.sendRetransmission(IMessage request)
Sends a "Retransmission" message is sent in response to a valid Retransmit Request.
|
Modifier and Type | Class and Description |
---|---|
class |
Message
Base class for the FIX message.
|
Modifier and Type | Method and Description |
---|---|
IMessage |
IMessage.clone()
Creates a copy of the message instance, including part of underlying byte array with message data.
|
IMessage |
Message.clone()
Creates a copy of the message instance, including part of underlying byte array with message data.
|
abstract IMessage |
ByteDecoder.decode(byte[] data,
int offset,
int size)
This function does the following:
1.
|
abstract IMessage |
ByteDecoder.decodePreCreatedMessage(byte[] data,
int offset,
int size)
This function does the following:
1.
|
abstract IMessage |
ByteDecoder.encode(byte[] data,
int offset,
int size,
int templateId)
This function does the following:
1.
|
abstract IMessage |
ByteDecoder.encodePreCreatedMessage(byte[] data,
int offset,
int size,
int templateId)
This function does the following:
1.
|
Copyright © 2005–2024 Onix Solutions. All rights reserved.