File |
Line |
org\sim0mq\demo\mm1\MM1FederationManager.java |
32 |
org\sim0mq\demo\mm1\MM1FederationManager20.java |
51 |
{
if (args.length < 5)
{
System.err.println("Use as FederationManager federationName federationManagerPortNumber "
+ "federateStarterIPorName federateStarterPortNumber modelFolder");
System.exit(-1);
}
String federationName = args[0];
String fmsPort = args[1];
int fmPort = 0;
try
{
fmPort = Integer.parseInt(fmsPort);
}
catch (NumberFormatException nfe)
{
System.err.println("Use as FederationManager fedName fmPort fsIP fsPort modelFolder, where fmPort is a number");
System.exit(-1);
}
if (fmPort == 0 || fmPort > 65535)
{
System.err.println("fmPort should be between 1 and 65535");
System.exit(-1);
}
String fsServerNameOrIP = args[2];
String fsPortString = args[3];
int fsPort = 0;
try
{
fsPort = Integer.parseInt(fsPortString);
}
catch (NumberFormatException nfe)
{
System.err.println("Use as FederationManager fedName fmPort fsIP fsPort modelFolder, where fmPort is a number");
System.exit(-1);
}
if (fsPort == 0 || fsPort > 65535)
{
System.err.println("fsPort should be between 1 and 65535");
System.exit(-1);
}
String mm1ModelFolder = args[4]; |
File |
Line |
org\sim0mq\demo\mm1\MM1Queue41Application.java |
249 |
org\sim0mq\demo\mm1\MM1Queue41Application.java |
301 |
}
}
catch (Exception e)
{
status = false;
error = e.getMessage();
}
byte[] mc2Message = new MC2AckNakMessage(this.federationRunId, this.modelId, message.getSenderId(),
++this.messageCount, message.getMessageId(), status, error).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc2Message, 0);
System.out.println("Sent MC.2");
System.out.flush();
}
/**
* Process FM.3 message and send MC.2 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the FM3 message
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processSetParameter(final String identity, final FM3SetParameterMessage message) |
File |
Line |
org\sim0mq\demo\mm1\MM1Queue41Application.java |
250 |
org\sim0mq\demo\mm1\MM1Queue41Application.java |
302 |
org\sim0mq\demo\mm1\MM1Queue41Application.java |
339 |
}
catch (Exception e)
{
status = false;
error = e.getMessage();
}
byte[] mc2Message = new MC2AckNakMessage(this.federationRunId, this.modelId, message.getSenderId(),
++this.messageCount, message.getMessageId(), status, error).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc2Message, 0);
System.out.println("Sent MC.2");
System.out.flush();
}
/**
* Process FM.3 message and send MC.2 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the FM3 message
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processSetParameter(final String identity, final FM3SetParameterMessage message) |