作者 crossoverJie

:truck: Moving or renaming files.

package com.crossoverjie.cim.client.handle;
import com.crossoverjie.cim.client.thread.HeartBeatJob;
import com.crossoverjie.cim.client.thread.ReConnectJob;
import com.crossoverjie.cim.client.util.SpringBeanFactory;
import com.crossoverjie.cim.common.constant.Constants;
import com.crossoverjie.cim.common.protocol.CIMRequestProto;
... ... @@ -76,7 +76,7 @@ public class CIMClientHandle extends SimpleChannelInboundHandler<CIMResponseProt
if (scheduledExecutorService == null){
scheduledExecutorService = SpringBeanFactory.getBean("scheduledTask",ScheduledExecutorService.class) ;
}
scheduledExecutorService.scheduleAtFixedRate(new HeartBeatJob(ctx),0,10, TimeUnit.SECONDS) ;
scheduledExecutorService.scheduleAtFixedRate(new ReConnectJob(ctx),0,10, TimeUnit.SECONDS) ;
}
@Override
... ...
... ... @@ -14,15 +14,15 @@ import org.slf4j.LoggerFactory;
* Date: 2019-01-20 21:35
* @since JDK 1.8
*/
public class HeartBeatJob implements Runnable {
public class ReConnectJob implements Runnable {
private final static Logger LOGGER = LoggerFactory.getLogger(HeartBeatJob.class);
private final static Logger LOGGER = LoggerFactory.getLogger(ReConnectJob.class);
private ChannelHandlerContext context ;
private HeartBeatHandler heartBeatHandler ;
public HeartBeatJob(ChannelHandlerContext context) {
public ReConnectJob(ChannelHandlerContext context) {
this.context = context;
this.heartBeatHandler = SpringBeanFactory.getBean(ClientHeartBeatHandlerImpl.class) ;
}
... ...