Method testMQ

ZezeJava/ZezeJavaTest/src/MQ/TestMQ.java:13–48

()

public class TestMQ {
	@Test
	public void testMQ() throws Exception {
		Task.tryInitThreadPool();

		var master = new Zeze.MQ.Master.Main("mqmaster.xml");
		var manager0 = new MQManager("mqmanager0", "mqmanager0.xml");
		var manager1 = new MQManager("mqmanager1", "mqmanager1.xml");
		var manager2 = new MQManager("mqmanager2", "mqmanager2.xml");
		MQProducer producer = null;
		MQConsumer consumer = null;
		try {
			master.start();
			manager0.start();
			manager1.start();
			manager2.start();
			var topic = "topicTest";
			try {
				MQ.createMQ(topic, 6, new BOptions.Data(BOptions.Single));
			} catch (Exception ex) {
				// skip
			}
			producer = new MQProducer(topic);
			producer.sendMessage(new BMessage.Data());

			consumer = new MQConsumer(topic, pushMessage -> System.out.println("consumer " + pushMessage.getTopic()));
		} finally {
			if (producer != null)
				producer.close();
			if (consumer != null)
				consumer.close();
			manager0.stop();
			manager1.stop();
			manager2.stop();
			master.stop();
		}
	}
}