Method openMQ

ZezeJava/ZezeJava/src/main/java/Zeze/MQ/MQ.java:38–42 · view source on GitHub ↗

(String topic)

Source from the content-addressed store, hash-verified

36	}
37
38	public static MQ openMQ(String topic) throws Exception {
39	masterAgent.startAndWaitConnectionReady();
40	mqAgent.start();
41	return new MQ(masterAgent.openMQ(topic));
42	}
43
44	/*
45	public static MQ alterMQ(String topic, int partition) {

MQProducerMethod · 0.95

MQConsumerMethod · 0.45

startMethod · 0.65

startAndWaitConnectionReadyMethod · 0.45

no test coverage detected