|
|
|
@ -29,12 +29,12 @@ import java.nio.charset.Charset;
|
|
|
|
|
@Slf4j |
|
|
|
|
public class WebHandler extends SimpleChannelInboundHandler<WebSocketFrame> { |
|
|
|
|
|
|
|
|
|
private Logger logger = LoggerFactory.getLogger(getClass()); |
|
|
|
|
private final Logger logger = LoggerFactory.getLogger(getClass()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private CtrCntrlTaskService taskService; |
|
|
|
|
private CtrHistoryShareContext context; |
|
|
|
|
private ObjectMapper objectMapper; |
|
|
|
|
private final CtrCntrlTaskService taskService; |
|
|
|
|
private final CtrHistoryShareContext context; |
|
|
|
|
private final ObjectMapper objectMapper; |
|
|
|
|
|
|
|
|
|
public WebHandler() { |
|
|
|
|
this.taskService = (CtrCntrlTaskService) ContextUtils.getBean("ctrCntrlTaskService"); |
|
|
|
@ -42,7 +42,8 @@ public class WebHandler extends SimpleChannelInboundHandler<WebSocketFrame> {
|
|
|
|
|
this.objectMapper = JsonUtils.getObjectMapper(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
ChannelCollection cc = new ChannelCollection(); |
|
|
|
|
private final ChannelCollection cc = new ChannelCollection(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception { |
|
|
|
|