Message message = new Message(); message.setTopic("topic"); message.setBody("Hello World!"); Producer producer = new Producer(); producer.bind("localhost:15555"); producer.publish(message); Consumer consumer = new Consumer(); consumer.bind("localhost:15555"); consumer.subscribe("topic", (message) -> { System.out.println("Received message: " + message.getBody()); }); zbus.serverAddress=localhost:15555 zbus.queueSize=1000 zbus.messageTTL=60000 Config config = new Config("zbus.properties"); Producer producer = new Producer(config); Consumer consumer = new Consumer(config);