|
|
@@ -23,14 +23,7 @@ import java.util.Enumeration;
|
|
|
public class ArtemisListenerService {
|
|
|
|
|
|
@Autowired
|
|
|
- OperationMessageService operationMessageService;
|
|
|
-
|
|
|
- // 网关来的消息
|
|
|
- @JmsListener(destination = "/gateway/#", containerFactory = MQConstant.TopicListenerContainerFactory)
|
|
|
- @JmsListener(destination = ".v1.gateway.#", containerFactory = MQConstant.TopicListenerContainerFactory)
|
|
|
- public void receiveGateWayMessage(Message message) {
|
|
|
- operationMessageService.handlerGateWayMessage(message);
|
|
|
- }
|
|
|
+ private OperationMessageService operationMessageService;
|
|
|
|
|
|
// 设备来的消息
|
|
|
@JmsListener(destination = "/device/#", containerFactory = MQConstant.TopicListenerContainerFactory)
|
|
|
@@ -54,7 +47,6 @@ public class ArtemisListenerService {
|
|
|
if (!topicName.equals("$sys.mqtt.sessions")) {
|
|
|
return;
|
|
|
}
|
|
|
-
|
|
|
String messageId = message.getJMSMessageID();
|
|
|
String clientId = message.getStringProperty("_AMQ_LVQ_NAME");
|
|
|
log.info("receiveMessage {} 消息监听clientId: {}", messageId, clientId);
|