protected static final String MY_SINK = "my-sink";
protected static final String MY_SOURCE = "my-source";
protected static final int TIMEOUT_SEC = 10;
protected static final String MY_SINK = "my-sink";
protected static final String MY_SOURCE = "my-source";
protected static final int TIMEOUT_SEC = 10;
* @param source topic from which the simulator should receive messages
* @return a new topic server/simulator
*/
* @param source topic from which the simulator should receive messages
* @return a new topic server/simulator
*/