|
@@ -6,6 +6,7 @@ import com.persagy.dmp.starter.alarm.communication.mq.DmpMessage;
|
|
|
import com.persagy.dmp.starter.alarm.service.NettyAlarmService;
|
|
|
import com.persagy.dmp.starter.alarm.util.StringUtil;
|
|
|
import io.netty.channel.Channel;
|
|
|
+import io.netty.channel.ChannelHandler;
|
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
|
import io.netty.channel.group.ChannelGroup;
|
|
@@ -32,6 +33,7 @@ import java.util.stream.Collectors;
|
|
|
* @version: V1.0
|
|
|
*/
|
|
|
@Slf4j
|
|
|
+@ChannelHandler.Sharable
|
|
|
public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
|
|
|
|
|
|
public static final String allProjects = "allProjects";
|