Package org.opentrafficsim.sim0mq.swing

Class Sim0MQPublisherTest

java.lang.Object

org.opentrafficsim.sim0mq.swing.Sim0MQPublisherTest

public class Sim0MQPublisherTest
extends Object

Unit tests. This requires half of OTS in the imports because it sets up a simulation and runs that for a couple of seconds.

Copyright (c) 2020-2020 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved.
BSD-style license. See OpenTrafficSim License.

$LastChangedDate: 2020-02-13 11:08:16 +0100 (Thu, 13 Feb 2020) $, @version $Revision: 6383 $, by $Author: pknoppers $,

Author:

Peter Knoppers

Constructor Summary

Constructors

Constructor	Description
Sim0MQPublisherTest()

Method Summary

Modifier and Type	Method	Description
static byte[][]	readMessages(org.zeromq.ZMQ.Socket socket)	Read as many messages from a ZMQ socket as are available.
void	testSim0MQPublisher()	Test code.
void	verifyAckNack(byte[] got, String field5, int field6, Boolean expectedValue, String expectedDescription)	Verify an ACK or a NACK message.
void	waitAndEatMessagesUntilConversationId(List<byte[]> receivedMessages, double maximumSeconds, int conversationId)	Wait for incoming messages up to one that has a specified conversation id, or until 1000 times time out.
void	waitAndVerifyAckNack(List<byte[]> receivedMessages, double maximumSeconds, String field5, int field6, Boolean expectedValue, String expectedDescription)	Wait for an incoming message and verify that it is an ACK or a NACK.

Methods inherited from class java.lang.Object

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

Constructor Detail

Sim0MQPublisherTest

public Sim0MQPublisherTest()

Method Detail

verifyAckNack

public void verifyAckNack(byte[] got,
                          String field5,
                          int field6,
                          Boolean expectedValue,
                          String expectedDescription)
                   throws Sim0MQException,
                          SerializationException

Verify an ACK or a NACK message.

Parameters:

got - byte[]; the not-yet-decoded message that is expected to decode into an ACK or a NACK

field5 - String; expected content for the message type id field

field6 - int; expected content for the message id field

expectedValue - Boolean; expected Boolean value for the first payload field (field 8)

expectedDescription - String; expected String value for the second and last payload field (field 9)

Throws:

Sim0MQException - when that happens, this test has failed

SerializationException - when that happens this test has failed

waitAndVerifyAckNack

public void waitAndVerifyAckNack(List<byte[]> receivedMessages,
                                 double maximumSeconds,
                                 String field5,
                                 int field6,
                                 Boolean expectedValue,
                                 String expectedDescription)
                          throws Sim0MQException,
                                 SerializationException,
                                 InterruptedException

Wait for an incoming message and verify that it is an ACK or a NACK.

Parameters:

receivedMessages - List<byte[]>; the list where incoming messages should appear

maximumSeconds - double; maximum time to wait

field5 - String; expected content for the message type id field

field6 - int; expected content for the message id field

expectedValue - Boolean; expected Boolean value for the first payload field (field 8)

expectedDescription - String; expected String value for the second and last payload field (field 9)

Throws:

Sim0MQException - when that happens, this test has failed

SerializationException - when that happens this test has failed

InterruptedException - when that happens this test has failed

testSim0MQPublisher

public void testSim0MQPublisher()
                         throws IOException,
                                SimRuntimeException,
                                NamingException,
                                DSOLException,
                                OTSDrawingException,
                                Sim0MQException,
                                SerializationException,
                                InterruptedException,
                                URISyntaxException

Test code.

Throws:

IOException - if that happens uncaught; this test has failed

NamingException - if that happens uncaught; this test has failed

SimRuntimeException - if that happens uncaught; this test has failed

DSOLException - if that happens uncaught; this test has failed

OTSDrawingException - if that happens uncaught; this test has failed

SerializationException - if that happens uncaught; this test has failed

Sim0MQException - if that happens uncaught; this test has failed

InterruptedException - if that happens uncaught; this test has failed

URISyntaxException - if network.xml file not found

waitAndEatMessagesUntilConversationId

public void waitAndEatMessagesUntilConversationId(List<byte[]> receivedMessages,
                                                  double maximumSeconds,
                                                  int conversationId)
                                           throws Sim0MQException,
                                                  SerializationException,
                                                  InterruptedException

Wait for incoming messages up to one that has a specified conversation id, or until 1000 times time out.

Parameters:

receivedMessages - List<byte[]>; the list to monitor

maximumSeconds - double; how long to wait (in seconds)

conversationId - int; the conversation id to wait for

Throws:

Sim0MQException - when that happens, this test has failed

SerializationException - when that happens, this test has failed

InterruptedException - when that happens, this test has failed

readMessages

public static byte[][] readMessages(org.zeromq.ZMQ.Socket socket)

Read as many messages from a ZMQ socket as are available. Do NOT block when there are no (more) messages to read.

Parameters:

socket - ZMQ.Socket; the socket

Returns:

byte[][]; the read messages