super(msgService, NAMESPACE_WEATHER, TYPE, QUERY);
}
public static void main(String[] args) throws Exception {
//Create communication channel
SerializingMessageService msgService = ProducerBase.connectToMaster();
WeatherBerlin tsp = new WeatherBerlin(msgService);
// start producer
tsp.start();