|
|
|
@ -41,6 +41,7 @@ import org.springframework.amqp.rabbit.annotation.Queue;
|
|
|
|
|
import org.springframework.amqp.rabbit.annotation.QueueBinding; |
|
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
|
import java.util.HashMap; |
|
|
|
@ -88,6 +89,7 @@ public class ZbomNodeDataPushListener {
|
|
|
|
|
exchange = @Exchange(name = FactoryDataConstants.Mq.Exchanges.NODE_DATA_PUSH, type = ExchangeTypes.TOPIC), |
|
|
|
|
key = FactoryDataConstants.Mq.RoutingKeys.ZBOM_NODE_DATA_PUSH |
|
|
|
|
)) |
|
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
|
public void nodeDataPush(String msg) { |
|
|
|
|
// {"brand":"ZBOM","node":"TRANSFER_WAREHOUSE_DEPART","operator":"","operatorTime":"","content":[{"packageCode":"1423090693445"}]}
|
|
|
|
|
log.info("zb接收到节点数据推送:{}", msg); |
|
|
|
|