public class ProducerExample {
public static void main(String[] args) throws Exception {
Producer producer = new Producer("localhost:15555");
producer.createMQ("my_topic");
Message message = new Message();
message.setTopic("my_topic");
message.setBody("Hello, Zbus!".getBytes());
producer.sendSync(message);
producer.close();
}
}
public class ConsumerExample {
public static void main(String[] args) throws Exception {
Consumer consumer = new Consumer("localhost:15555");
consumer.declareTopic("my_topic");
consumer.start((message, mqClient) -> {
System.out.println("Received message: " + new String(message.getBody()));
});
Thread.sleep(5000);
consumer.close();
}
}
