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.modelcontroller |
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,
boolean modelController) |
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 |
---|---|
FS1RequestStatusMessage |
FS1RequestStatusMessage.Builder.build()
Build the object.
|
FS2FederateStartedMessage |
FS2FederateStartedMessage.Builder.build()
Build the object.
|
FS3KillModelMessage |
FS3KillModelMessage.Builder.build()
Build the object.
|
FS4FederateKilledMessage |
FS4FederateKilledMessage.Builder.build()
Build the object.
|
FS5FederatesKilledMessage |
FS5FederatesKilledMessage.Builder.build()
Build the object.
|
byte[] |
FS1RequestStatusMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FS2FederateStartedMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FS3KillModelMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FS4FederateKilledMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FS5FederatesKilledMessage.createByteArray()
Create a byte array of the fields.
|
static FS1RequestStatusMessage |
FS1RequestStatusMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FS2FederateStartedMessage |
FS2FederateStartedMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FS3KillModelMessage |
FS3KillModelMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FS4FederateKilledMessage |
FS4FederateKilledMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FS5FederatesKilledMessage |
FS5FederatesKilledMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
Constructor and Description |
---|
FS1RequestStatusMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
FS2FederateStartedMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String instanceId,
String status,
int modelPort,
String error) |
FS3KillModelMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
FS4FederateKilledMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String instanceId,
boolean status,
String error) |
FS5FederatesKilledMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
boolean status,
String error) |
Modifier and Type | Method and Description |
---|---|
FM1StartFederateMessage |
FM1StartFederateMessage.Builder.build()
Build the object.
|
FM2SimRunControlMessage |
FM2SimRunControlMessage.Builder.build()
Build the object.
|
FM3SetParameterMessage |
FM3SetParameterMessage.Builder.build()
Build the object.
|
FM4SimStartMessage |
FM4SimStartMessage.Builder.build()
Build the object.
|
FM5RequestStatus |
FM5RequestStatus.Builder.build()
Build the object.
|
FM6RequestStatisticsMessage |
FM6RequestStatisticsMessage.Builder.build()
Build the object.
|
FM7SimResetMessage |
FM7SimResetMessage.Builder.build()
Build the object.
|
FM8KillFederateMessage |
FM8KillFederateMessage.Builder.build()
Build the object.
|
FM9KillAllMessage |
FM9KillAllMessage.Builder.build()
Build the object.
|
byte[] |
FM1StartFederateMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM2SimRunControlMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM3SetParameterMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM4SimStartMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM5RequestStatus.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM6RequestStatisticsMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM7SimResetMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM8KillFederateMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
FM9KillAllMessage.createByteArray()
Create a byte array of the fields.
|
static FM1StartFederateMessage |
FM1StartFederateMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM2SimRunControlMessage |
FM2SimRunControlMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM3SetParameterMessage |
FM3SetParameterMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM4SimStartMessage |
FM4SimStartMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM5RequestStatus |
FM5RequestStatus.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM6RequestStatisticsMessage |
FM6RequestStatisticsMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM7SimResetMessage |
FM7SimResetMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM8KillFederateMessage |
FM8KillFederateMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static FM9KillAllMessage |
FM9KillAllMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
Constructor and Description |
---|
FM1StartFederateMessage(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) |
FM2SimRunControlMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
Object runDuration,
Object warmupDuration,
Object offsetTime,
double speed,
int numberReplications,
int numberRandomStreams,
Map<Object,Long> streamMap) |
FM3SetParameterMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String parameterName,
Object parameterValue) |
FM4SimStartMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
FM5RequestStatus(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
FM6RequestStatisticsMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String variableName) |
FM7SimResetMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
FM8KillFederateMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String instanceId) |
FM9KillAllMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId) |
Modifier and Type | Method and Description |
---|---|
MC1StatusMessage |
MC1StatusMessage.Builder.build()
Build the object.
|
MC2AckNakMessage |
MC2AckNakMessage.Builder.build()
Build the object.
|
MC3StatisticsMessage |
MC3StatisticsMessage.Builder.build()
Build the object.
|
MC4StatisticsErrorMessage |
MC4StatisticsErrorMessage.Builder.build()
Build the object.
|
byte[] |
MC1StatusMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
MC2AckNakMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
MC3StatisticsMessage.createByteArray()
Create a byte array of the fields.
|
byte[] |
MC4StatisticsErrorMessage.createByteArray()
Create a byte array of the fields.
|
static MC1StatusMessage |
MC1StatusMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static MC2AckNakMessage |
MC2AckNakMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static MC3StatisticsMessage |
MC3StatisticsMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
static MC4StatisticsErrorMessage |
MC4StatisticsErrorMessage.createMessage(Object[] fields,
Object intendedReceiverId)
Build a message from an Object[] that was received.
|
Constructor and Description |
---|
MC1StatusMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
long uniqueId,
String status,
String error) |
MC2AckNakMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
long uniqueId,
boolean status,
String error) |
MC3StatisticsMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String variableName,
Object variableValue) |
MC4StatisticsErrorMessage(Object simulationRunId,
Object senderId,
Object receiverId,
long messageId,
String variableName,
String error) |
Copyright © 2016–2019 Delft University of Technology. All rights reserved.