//package org.jeecg.modules.pm.handler;
//
//
//import com.google.protobuf.ByteString;
//import lombok.extern.slf4j.Slf4j;
//import org.jeecg.modules.pm.entity.eps.EventDis;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.jms.annotation.JmsListener;
//import org.springframework.jms.core.JmsMessagingTemplate;
//import org.springframework.stereotype.Component;
//
//import javax.jms.BytesMessage;
//import javax.jms.Message;
//
///**
// * @author: JJww
// * @Date:2022/3/23
// */
//@Slf4j
//@Component
//public class EventMessageListener {
//
//    @JmsListener(destination = "openapi.vss.topic", containerFactory = "topicListener")
//    public void vssMessageListener(Message msg) throws Exception {
//
//        try {
//            // cms里发送的消息为BytesMessage，此处不做判断亦可
//            if (msg instanceof BytesMessage) {
//                BytesMessage bytesMessage = (BytesMessage) msg;
//                long length = bytesMessage.getBodyLength();
//                byte[] bt = new byte[(int) length];
//                // 将BytesMessage转换为byte类型
//                bytesMessage.readBytes(bt);
//                // 壳文件字段，EventDis类为event_dis.proto文件解析而来，CommEventLog类为事件壳文件类
//                EventDis.CommEventLog parseFrom = EventDis.CommEventLog.parseFrom(bt);
//                // 输出壳文件字段
//                // System.out.println(parseFrom.toString());
//                // 扩展字段，此字段为设备上报事件内容，部分事件需要使用pb文件再次解析
//                ByteString extInfo = parseFrom.getExtInfo();
//                // 输出扩展字段
//                // System.out.println(extInfo.toStringUtf8());
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//}
