this.trafCOD = new TrafCOD(controllerName, URLResource.getResource("/TrafCODDemo1/simpleTest.tfc"),
getSimulator(), this.controllerDisplayPanel);
this.trafCOD.addListener(this, TrafficController.TRAFFICCONTROL_CONTROLLER_EVALUATING);
this.trafCOD.addListener(this, TrafficController.TRAFFICCONTROL_CONTROLLER_WARNING);
this.trafCOD.addListener(this, TrafficController.TRAFFICCONTROL_CONFLICT_GROUP_CHANGED);
this.trafCOD.addListener(this, TrafficController.TRAFFICCONTROL_STATE_CHANGED);
this.trafCOD.addListener(this, TrafficController.TRAFFICCONTROL_VARIABLE_CREATED);
this.trafCOD.addListener(this, TrafficController.TRAFFICCONTROL_TRACED_VARIABLE_UPDATED);
// Subscribe the TrafCOD machine to trace command events that we emit
addListener(this.trafCOD, TrafficController.TRAFFICCONTROL_SET_TRACING);
// fireEvent(TrafficController.TRAFFICCONTROL_SET_TRACING, new Object[] {controllerName, "TGX", 8, true});
// fireEvent(TrafficController.TRAFFICCONTROL_SET_TRACING, new Object[] {controllerName, "XR1", 11, true});
// fireEvent(TrafficController.TRAFFICCONTROL_SET_TRACING, new Object[] {controllerName, "TD1", 11, true});
// fireEvent(TrafficController.TRAFFICCONTROL_SET_TRACING, new Object[] {controllerName, "TGX", 11, true});
// fireEvent(TrafficController.TRAFFICCONTROL_SET_TRACING, new Object[] {controllerName, "TL", 11, true});
// System.out.println("demo: emitting a SET TRACING event for all variables related to stream 11");
// fireEvent(TrafficController.TRAFFICCONTROL_SET_TRACING, new Object[] { controllerName, "", 11, true });
// this.trafCOD.traceVariablesOfStream(TrafficController.NO_STREAM, true);
// this.trafCOD.traceVariablesOfStream(11, true);
// this.trafCOD.traceVariable("MRV", 11, true);
}
catch (Exception exception)
{
exception.printStackTrace();
}
}
/** {@inheritDoc} */
@Override
public final OTSRoadNetwork getNetwork()
{
return this.network;
}
/**
* @return trafCOD
*/
public final TrafCOD getTrafCOD()
{
return this.trafCOD;
}
/**
* @return controllerDisplayPanel
*/
public final JPanel getControllerDisplayPanel()
{
return this.controllerDisplayPanel;
}
/** {@inheritDoc} */
@Override
public void notify(final EventInterface event) throws RemoteException
{
EventType type = event.getType();
Object[] payload = (Object[]) event.getContent();
if (TrafficController.TRAFFICCONTROL_CONTROLLER_EVALUATING.equals(type))
{
// System.out.println("Evalution starts at " + getSimulator().getSimulatorTime());
return;
}
else if (TrafficController.TRAFFICCONTROL_CONFLICT_GROUP_CHANGED.equals(type))
{
System.out.println("Conflict group changed from " + ((String) payload[1]) + " to " + ((String) payload[2]));
}
else if (TrafficController.TRAFFICCONTROL_TRACED_VARIABLE_UPDATED.equals(type))
{
System.out.println(String.format("Variable changed %s <- %d %s", payload[1], payload[4], payload[5]));
}
else if (TrafficController.TRAFFICCONTROL_CONTROLLER_WARNING.equals(type))
{
System.out.println("Warning " + payload[1]);
}
else
{
System.out.print("TrafCODDemo received event of type " + event.getType() + ", payload [");
String separator = "";
for (Object o : payload)
{
System.out.print(separator + o);
separator = ",";
}
System.out.println("]");
}
}
}
} 