Title: Zbus: A Technology Framework Principle Applied in Java Libraries
Introduction:
import io.zbus.mq.Producer;
import io.zbus.mq.Consumer;
import io.zbus.mq.MessageHandler;
import io.zbus.mq.Message;
public class ZbusExample {
public static void main(String[] args) throws Exception {
Producer producer = new Producer("tcp://127.0.0.1:15555");
Consumer consumer = new Consumer("tcp://127.0.0.1:15555");
MessageHandler messageHandler = new MessageHandler() {
public void handle(Message message) throws Exception {
System.out.println("Received message: " + message.getBodyString());
}
};
consumer.start();
consumer.declareTopic("topicName");
consumer.setMessageHandler(messageHandler);
producer.publish("topicName", "Hello, Zbus!");
producer.close();
consumer.close();
}
}
broker = tcp://127.0.0.1:15555
brokers = tcp://127.0.0.1:15555,tcp://127.0.0.1:15556,tcp://127.0.0.1:15557
tracker = http://tracker.com/track
