Package | Description |
---|---|
org.sim0mq.federatestarter |
Lightweight executable to start a federate on a local node as a (sub)process.
|
org.sim0mq.message |
Message infrastructure for ZeroMQ.
|
org.sim0mq.message.federatestarter |
Messages sent by the FederateStarter.
|
org.sim0mq.message.federationmanager |
Messages sent by the FederationManager.
|
org.sim0mq.message.model |
Messages sent by a model (or federate).
|
Modifier and Type | Method and Description |
---|---|
static void |
FederateStarter.main(String[] args)
Start listening on the given port for messages to start components.
|
Constructor and Description |
---|
FederateStarter(int fsPort,
Properties softwareProperties,
int startPort,
int endPort) |
Modifier and Type | Method and Description |
---|---|
abstract Sim0MQMessage |
Sim0MQMessage.Builder.build()
Build the object.
|
abstract Sim0MQReply |
Sim0MQReply.Builder.build()
Build the object.
|
static void |
Sim0MQMessage.check(Object[] fields,
int expectedPayloadFields,
String expectedMessageType,
Object intendedReceiverId)
Check the consistency of a message from an Object[] that was received.
|
abstract byte[] |
Sim0MQMessage.createByteArray()
Create a byte array of the fields.
|
static Object[] |
SimulationMessage.decode(byte[] bytes)
Decode the message into an object array.
|
static byte[] |
SimulationMessage.encodeReplyUTF16(String identity,
Object simulationRunId,
Object senderId,
Object receiverId,
Object messageTypeId,
long messageId,
MessageStatus messageStatus,
Object... content)
Encode the object array into a reply message.
|
static byte[] |
SimulationMessage.encodeReplyUTF8(String identity,
Object simulationRunId,
Object senderId,
Object receiverId,
Object messageTypeId,
long messageId,
MessageStatus messageStatus,
Object... content)
Encode the object array into a reply message.
|
static byte[] |
SimulationMessage.encodeUTF16(Object simulationRunId,
Object senderId,
Object receiverId,
Object messageTypeId,
long messageId,
MessageStatus messageStatus,
Object... content)
Encode the object array into a message.
|
static byte[] |
SimulationMessage.encodeUTF8(Object simulationRunId,
Object senderId,
Object receiverId,
Object messageTypeId,
long messageId,
MessageStatus messageStatus,
Object... content)
Encode the object array into a message.
|
Constructor and Description |
---|
Sim0MQMessage(Object simulationRunId,
Object senderId,
Object receiverId,
Object messageTypeId,
long messageId,
MessageStatus messageStatus)
Encode the object array into a message.
|
Sim0MQReply(Object simulationRunId,
Object senderId,
Object receiverId,
Object messageTypeId,
long messageId,
MessageStatus messageStatus,
long replyToId)
Encode the object array into a message.
|
Modifier and Type | Method and Description |
---|---|
Sim0MQMessage |
FederateStartedMessage.Builder.build()
Build the object.
|
Sim0MQMessage |
RequestStatusMessage.Builder.build()
Build the object.
|
byte[] |
FederateStartedMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
RequestStatusMessage.createByteArray()
Create a byte array of the fields.
|
static FederateStartedMessage |
FederateStartedMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static RequestStatusMessage |
RequestStatusMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
Constructor and Description |
---|
FederateStartedMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String instanceId,
String status,
int modelPort,
String error) |
RequestStatusMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
Modifier and Type | Method and Description |
---|---|
Sim0MQMessage |
SimRunControlMessage.Builder.build()
Build the object.
|
Sim0MQMessage |
StartFederateMessage.Builder.build()
Build the object.
|
byte[] |
SimRunControlMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
StartFederateMessage.createByteArray()
Create a byte array of the fields.
|
static SimRunControlMessage |
SimRunControlMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static StartFederateMessage |
StartFederateMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
Constructor and Description |
---|
SimRunControlMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
Object runTime,
Object warmupTime,
Object offsetTime,
double speed,
int numberReplications,
int numberRandomStreams,
Map<Object,Long> streamMap) |
StartFederateMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String instanceId,
String softwareCode,
String argsBefore,
String modelPath,
String argsAfter,
String workingDirectory,
String redirectStdin,
String redirectStdout,
String redirectStderr,
boolean deleteWorkingDirectory,
boolean deleteStdout,
boolean deleteStderr) |
Modifier and Type | Method and Description |
---|---|
Sim0MQMessage |
StatusMessage.Builder.build()
Build the object.
|
byte[] |
StatusMessage.createByteArray()
Create a byte array of the fields.
|
static StatusMessage |
StatusMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
Constructor and Description |
---|
StatusMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
long uniqueId,
String status,
String error) |
Copyright © 2016–2019 Delft University of Technology. All rights reserved.