Message message = new Message("topic", "Hello World!"); Producer producer = new Producer("localhost:15555"); producer.offer(message); Consumer consumer = new Consumer("localhost:15555"); consumer.start(); Message message = consumer.receive(); System.out.println(message.getBody()); Consumer consumer = new Consumer("localhost:15555"); consumer.subscribe("topic"); while (true) { Message message = consumer.receive(); System.out.println(message.getBody()); } zbus.host=localhost zbus.port=15555 zbus.topic=testTopic zbus.groups=group1,group2