String ServerPort = this.eventSubscriptionConfig.getServerPort();
String messageInfo = this.eventSubscriptionConfig.getMessageInfo();
MessageReceiver reciver = null;
try {
reciver = new MessageReceiver("tcp://" + serverAddress + ":" + ServerPort + "");
FlowMessageListener listener = new FlowMessageListener();
reciver.addTopicListener(messageInfo, listener);
log.info("Message监听启动成功!\n");
} catch (JMSException e) {
log.error("Message监听启动失败!\n",e);
}