import org.zbus.mq.Producer; import org.zbus.mq.Protocol.MqMode; import org.zbus.mq.Protocol.SerializationType; public class ZbusExample { public static void main(String[] args) throws Exception { Producer producer = new Producer("127.0.0.1:15555"); producer.declareMq("test", MqMode.QUEUE); producer.setSerializationType(SerializationType.JSON); producer.sendSync("test", "Hello, Zbus!"); producer.close(); } }