biz.onixs.cme.ilink3.testing

Class TestUtility

java.lang.Object

biz.onixs.cme.ilink3.testing.TestUtility

public class TestUtility
extends Object

Provides tools and methods for setting up test environments, interacting with emulators, and managing asynchronous tasks in tests.

Field Summary

Fields

Modifier and Type	Field and Description
static String	NewOrderSingle

Constructor Summary

Constructors

Constructor and Description
TestUtility() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	checkStorageState(String name, long inSeqNum, long outSeqNum, long previousSeqNum, boolean negotiated)
void	checkStorageSummary(String name, long[] expectedOutSeqNumbers, long[] expectedInSeqNumbers)
void	checkTestTasks() Asserts test results by checking each task in the `tasks` collection for stored exceptions.
void	closeServerSocketEmulators()
void	connectToEmulator(Session session, int port) Connects a Session object to an emulator by performing a logon operation.
IMessage	createBusinessReject()
Emulator	createEmulatorAcceptor() Creates a new Emulator object configured with a default port and adds it to tracking.
IMessage	createEstablishment(long uuid, long requestTimestamp, int keepAliveInterval)
IMessage	createEstablishmentReject(long uuid, long requestTimestamp)
IMessage	createExecutionReportTradeOutright(long uuid, long orderId, boolean retransmission)
IMessage	createMassQuote()
IMessage	createMassQuoteAck(long uuid, boolean retransmission)
IMessage	createNegotiationReject(long uuid, long requestTimestamp)
IMessage	createNegotiationResponse(long uuid, long requestTimestamp)
IMessage	createNotApplied(long uuid, long fromSeqNo, int msgCount)
IMessage	createOrder(int orderRequestID)
IMessage	createRetransmission(IMessage request)
IMessage	createRetransmission(long uuid, long lastUUID, long requestTimestamp, long fromSeqNo, int msgCount)
IMessage	createRetransmitReject(IMessage request, int errorCodes, String reason)
IMessage	createRetransmitReject(long uuid, long lastUUID, long requestTimestamp, int errorCodes, String reason)
IMessage	createSequence(long uuid, long nextSeqNo, int keepAliveLapsed)
IMessage	createTerminate(long uuid, long requestTimestamp, String reason, int errorCode)
IMessage	createUnknownMessage(int templateId)
void	disconnectEmulators() Disconnects all emulators in the `emulators` collection.
ByteDecoder	getDecoder()
static int	getFreePort() Obtains a free port by attempting to create a temporary ServerSocket.
HandlerSettings	getHandlerSettings()
MessageSchema	getMessageSchema()
SessionSettings	getSessionSettings()
TestSettings	getTestSettings()
void	interruptTestTasks() Iterates through active threads and issues an interrupt signal.
void	launchEmulatorTask(TestTask testTask) Launches a TestTask by creating a new thread and adding it to tracking.
void	setTemplateFile(String templateFile)
void	waitTestTasks() Waits for all tasks in the `tasks` collection to signal completion.

Methods inherited from class java.lang.Object

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

Field Detail

NewOrderSingle

public static final String NewOrderSingle

See Also:

Constant Field Values

Constructor Detail

TestUtility

public TestUtility()

Default constructor. Initializes configuration and loads message templates.

Method Detail

getHandlerSettings

public HandlerSettings getHandlerSettings()

getTestSettings

public TestSettings getTestSettings()

getSessionSettings

public SessionSettings getSessionSettings()

createEmulatorAcceptor

public Emulator createEmulatorAcceptor()

Creates a new Emulator object configured with a default port and adds it to tracking.

Returns:

The newly created Emulator object.

connectToEmulator

public void connectToEmulator(Session session,
                              int port)

Connects a Session object to an emulator by performing a logon operation.

Parameters:

session - The Session object to be connected.

port - The port number of the emulator.

launchEmulatorTask

public final void launchEmulatorTask(TestTask testTask)

Launches a TestTask by creating a new thread and adding it to tracking.

Parameters:

testTask - The TestTask to be executed.

interruptTestTasks

public void interruptTestTasks()

Iterates through active threads and issues an interrupt signal.

waitTestTasks

public void waitTestTasks()

Waits for all tasks in the `tasks` collection to signal completion.

checkTestTasks

public void checkTestTasks()
                    throws Throwable

Asserts test results by checking each task in the `tasks` collection for stored exceptions. Throws an exception if any errors are encountered.

Throws:

Throwable - Throws an exception if any of the completed tasks had a stored error.

disconnectEmulators

public void disconnectEmulators()

Disconnects all emulators in the `emulators` collection. Handles potential exceptions gracefully.

getFreePort

public static int getFreePort()

Obtains a free port by attempting to create a temporary ServerSocket.

Returns:

An available port number.

getDecoder

public ByteDecoder getDecoder()

getMessageSchema

public MessageSchema getMessageSchema()

createBusinessReject

public IMessage createBusinessReject()

createOrder

public IMessage createOrder(int orderRequestID)

createNegotiationResponse

public IMessage createNegotiationResponse(long uuid,
                                          long requestTimestamp)

createNegotiationReject

public IMessage createNegotiationReject(long uuid,
                                        long requestTimestamp)

createEstablishment

public IMessage createEstablishment(long uuid,
                                    long requestTimestamp,
                                    int keepAliveInterval)

createEstablishmentReject

public IMessage createEstablishmentReject(long uuid,
                                          long requestTimestamp)

createNotApplied

public IMessage createNotApplied(long uuid,
                                 long fromSeqNo,
                                 int msgCount)

createRetransmission

public IMessage createRetransmission(IMessage request)

createRetransmission

public IMessage createRetransmission(long uuid,
                                     long lastUUID,
                                     long requestTimestamp,
                                     long fromSeqNo,
                                     int msgCount)

createRetransmitReject

public IMessage createRetransmitReject(IMessage request,
                                       int errorCodes,
                                       String reason)

createRetransmitReject

public IMessage createRetransmitReject(long uuid,
                                       long lastUUID,
                                       long requestTimestamp,
                                       int errorCodes,
                                       String reason)

createExecutionReportTradeOutright

public IMessage createExecutionReportTradeOutright(long uuid,
                                                   long orderId,
                                                   boolean retransmission)

createMassQuote

public IMessage createMassQuote()

createMassQuoteAck

public IMessage createMassQuoteAck(long uuid,
                                   boolean retransmission)

createTerminate

public IMessage createTerminate(long uuid,
                                long requestTimestamp,
                                String reason,
                                int errorCode)

createSequence

public IMessage createSequence(long uuid,
                               long nextSeqNo,
                               int keepAliveLapsed)

createUnknownMessage

public IMessage createUnknownMessage(int templateId)

closeServerSocketEmulators

public void closeServerSocketEmulators()

checkStorageState

public void checkStorageState(String name,
                              long inSeqNum,
                              long outSeqNum,
                              long previousSeqNum,
                              boolean negotiated)
                       throws IOException

Throws:

IOException

checkStorageSummary

public void checkStorageSummary(String name,
                                long[] expectedOutSeqNumbers,
                                long[] expectedInSeqNumbers)
                         throws IOException

Throws:

IOException

setTemplateFile

public void setTemplateFile(String templateFile)