From 1135c89deb50a080152f9086fc7b741c415ecd54 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期三, 12 二月 2025 17:00:14 +0800 Subject: [PATCH] 通信中间件增加功能: 1、实现消息心中; 2、开阀报、关阀报、报警数据都会在消息中间件存入消息; 3、在消息中心注册消息接收者,消息中心周期性向消息接收者推送消息。 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationPrefixedDataAvailable.java | 11 +++++++---- 1 files changed, 7 insertions(+), 4 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationPrefixedDataAvailable.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationPrefixedDataAvailable.java index e86b049..288ba08 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationPrefixedDataAvailable.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationPrefixedDataAvailable.java @@ -9,11 +9,14 @@ @Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) public @interface AnnotationPrefixedDataAvailable { - /** - * 鎵�灞炲崗璁悕绉� - */ + /** + * 鎵�灞炲崗璁悕绉� + */ String protocolName() default "" ; - + /** + * 鎵�灞炲崗璁増鏈彿 + */ + short protocolVersion() default -1 ; /** * 閰嶇疆鏄惁鍚姩 * @return -- Gitblit v1.8.0