File |
Line |
org\sim0mq\message\modelcontroller\MC1StatusMessage.java |
66 |
org\sim0mq\message\modelcontroller\MC2AckNakMessage.java |
61 |
public final String getStatus()
{
return this.status;
}
/**
* @return error
*/
public final String getError()
{
return this.error;
}
/**
* @return messagetype
*/
public static final String getMessageType()
{
return MESSAGETYPE;
}
/** {@inheritDoc} */
@Override
public short getNumberOfPayloadFields()
{
return 3;
}
/** {@inheritDoc} */
@Override
public Object[] createObjectArray()
{
return new Object[] {getMagicNumber(), getSimulationRunId(), getSenderId(), getReceiverId(), getMessageTypeId(),
getMessageId(), getMessageStatus(), getNumberOfPayloadFields(), getReplyToId(), this.status, this.error};
}
/** {@inheritDoc} */
@Override
public byte[] createByteArray() throws Sim0MQException, SerializationException
{
return SimulationMessage.encodeUTF8(getSimulationRunId(), getSenderId(), getReceiverId(), getMessageTypeId(),
getMessageId(), getMessageStatus(), getReplyToId(), this.status, this.error);
}
/**
* Build a message from an Object[] that was received.
* @param fields Object[]; the fields in the message
* @param intendedReceiverId id of the intended receiver
* @return a Sim0MQ message
* @throws Sim0MQException when number of fields is not correct
*/
public static MC1StatusMessage createMessage(final Object[] fields, final Object intendedReceiverId) throws Sim0MQException |
File |
Line |
org\sim0mq\message\federatestarter\FS1RequestStatusMessage.java |
39 |
org\sim0mq\message\federatestarter\FS3KillModelMessage.java |
37 |
org\sim0mq\message\federationmanager\FM4SimStartMessage.java |
38 |
org\sim0mq\message\federationmanager\FM5RequestStatus.java |
40 |
org\sim0mq\message\federationmanager\FM7SimResetMessage.java |
38 |
org\sim0mq\message\federationmanager\FM9KillAllMessage.java |
38 |
public FS1RequestStatusMessage(final Object simulationRunId, final Object senderId, final Object receiverId,
final long messageId) throws Sim0MQException, NullPointerException
{
super(simulationRunId, senderId, receiverId, MESSAGETYPE, messageId, MessageStatus.NEW);
}
/**
* @return messagetype
*/
public static final String getMessageType()
{
return MESSAGETYPE;
}
/** {@inheritDoc} */
@Override
public short getNumberOfPayloadFields()
{
return 0;
}
/** {@inheritDoc} */
@Override
public Object[] createObjectArray()
{
return new Object[] {getMagicNumber(), getSimulationRunId(), getSenderId(), getReceiverId(), getMessageTypeId(),
getMessageId(), getMessageStatus(), getNumberOfPayloadFields()};
}
/** {@inheritDoc} */
@Override
public byte[] createByteArray() throws Sim0MQException, SerializationException
{
return SimulationMessage.encodeUTF8(getSimulationRunId(), getSenderId(), getReceiverId(), getMessageTypeId(),
getMessageId(), getMessageStatus());
}
/**
* Build a message from an Object[] that was received.
* @param fields Object[]; the fields in the message
* @param intendedReceiverId id of the intended receiver
* @return a Sim0MQ message
* @throws Sim0MQException when number of fields is not correct
*/
public static FS1RequestStatusMessage createMessage(final Object[] fields, final Object intendedReceiverId) |