Method MQConsumer

ZezeJava/ZezeJava/src/main/java/Zeze/MQ/MQConsumer.java:20–31

(String topic, MQListener listener)

	}

	public MQConsumer(String topic, MQListener listener) {
		this.listener = listener;

		MQ.masterAgent.startAndWaitConnectionReady();
		var servers = MQ.masterAgent.openMQ(topic);
		this.info = servers.getInfo();
		for (var server : servers.getServers()) {
			managers.add(MQ.mqAgent.getOrAddConnector(server.getHost(), server.getPort()));
		}
		this.sessionId = servers.getSessionId();
		MQ.mqAgent.subscribe(topic, sessionId, this, managers);
	}

	public long getSessionId() {
		return sessionId;