// Path: mappingrpc-connector/src/main/java/github/mappingrpc/core/constant/ClientDaemonThreadEventType.java
// public class ClientDaemonThreadEventType {
// 	public static final byte noEvent = 0;
// 
// 	@Deprecated
// 	public static final byte channelConnecting = 1;
// 
// 	@Deprecated
// 	public static final byte channelConnected = 2;
// 	public static final byte channelDisconnected = 3;
// 	public static final byte closeDaemonThread = 4;
// }
// 
// Path: mappingrpc-connector/src/main/java/github/mappingrpc/core/event/ClientDaemonThreadEvent.java
// public class ClientDaemonThreadEvent {
// 	private byte eventType = ClientDaemonThreadEventType.noEvent;
// 
// 	public ClientDaemonThreadEvent(byte eventType) {
// 		this.eventType = eventType;
// 	}
// 
// 	public byte getEventType() {
// 		return eventType;
// 	}
// 
// 	public void setEventType(byte eventType) {
// 		this.eventType = eventType;
// 	}
// }


import github.mappingrpc.core.constant.ClientDaemonThreadEventType;
import github.mappingrpc.core.event.ClientDaemonThreadEvent;
import io.netty.channel.ChannelDuplexHandler;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.channel.ChannelHandlerContext;
import java.util.concurrent.BlockingQueue;
package github.mappingrpc.core.io.commonhandler;



@Sharable
public class DisconnectDetectHandler extends ChannelDuplexHandler {
// Path: mappingrpc-connector/src/main/java/github/mappingrpc/core/constant/ClientDaemonThreadEventType.java
// public class ClientDaemonThreadEventType {
// 	public static final byte noEvent = 0;
// 
// 	@Deprecated
// 	public static final byte channelConnecting = 1;
// 
// 	@Deprecated
// 	public static final byte channelConnected = 2;
// 	public static final byte channelDisconnected = 3;
// 	public static final byte closeDaemonThread = 4;
// }
// 
// Path: mappingrpc-connector/src/main/java/github/mappingrpc/core/event/ClientDaemonThreadEvent.java
// public class ClientDaemonThreadEvent {
// 	private byte eventType = ClientDaemonThreadEventType.noEvent;
// 
// 	public ClientDaemonThreadEvent(byte eventType) {
// 		this.eventType = eventType;
// 	}
// 
// 	public byte getEventType() {
// 		return eventType;
// 	}
// 
// 	public void setEventType(byte eventType) {
// 		this.eventType = eventType;
// 	}
// }


// Path: mappingrpc-connector/src/main/java/github/mappingrpc/core/io/commonhandler/DisconnectDetectHandler.java
import github.mappingrpc.core.constant.ClientDaemonThreadEventType;
import github.mappingrpc.core.event.ClientDaemonThreadEvent;
import io.netty.channel.ChannelDuplexHandler;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.channel.ChannelHandlerContext;
import java.util.concurrent.BlockingQueue;

package github.mappingrpc.core.io.commonhandler;



@Sharable
public class DisconnectDetectHandler extends ChannelDuplexHandler {
	private BlockingQueue<ClientDaemonThreadEvent> nettyEventToOuter;