import io.zbus.mq.Producer;
import io.zbus.mq.Protocol.MqMode;
import io.zbus.mq.Protocol.MqType;
public class ProducerExample {
public static void main(String[] args) throws Exception {
Producer producer = new Producer("localhost:15555");
producer.open();
String message = "New order";
producer.close();
}
}
import io.zbus.mq.Consumer;
import io.zbus.mq.Consumer.ConsumerHandler;
import io.zbus.mq.Protocol.MqMode;
import io.zbus.mq.Protocol.MqType;
public class ConsumerExample {
public static void main(String[] args) throws Exception {
Consumer consumer = new Consumer("localhost:15555");
consumer.start(new ConsumerHandler() {
public void handle(byte[] message) throws Exception {
System.out.println("Received message: " + new String(message));
}
});
}
}
zbus.address=localhost:15555
zbus.topic=order
