| 
						
						
							
								
							
						
						
					 | 
					 | 
					@ -19,7 +19,6 @@ import java.nio.ByteBuffer; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.nio.channels.ClosedChannelException; | 
					 | 
					 | 
					 | 
					import java.nio.channels.ClosedChannelException; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.nio.channels.NotYetConnectedException; | 
					 | 
					 | 
					 | 
					import java.nio.channels.NotYetConnectedException; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.nio.channels.SocketChannel; | 
					 | 
					 | 
					 | 
					import java.nio.channels.SocketChannel; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.util.concurrent.ConcurrentHashMap; | 
					 | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.util.concurrent.ConcurrentLinkedQueue; | 
					 | 
					 | 
					 | 
					import java.util.concurrent.ConcurrentLinkedQueue; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.util.concurrent.atomic.AtomicBoolean; | 
					 | 
					 | 
					 | 
					import java.util.concurrent.atomic.AtomicBoolean; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					import java.util.concurrent.locks.ReentrantLock; | 
					 | 
					 | 
					 | 
					import java.util.concurrent.locks.ReentrantLock; | 
				
			
			
		
	
	
		
		
			
				
					| 
						
						
						
							
								
							
						
					 | 
					 | 
					@ -41,8 +40,6 @@ public abstract class AbstractConnection implements | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    protected long lastKeepAliveTime = System.currentTimeMillis(); | 
					 | 
					 | 
					 | 
					    protected long lastKeepAliveTime = System.currentTimeMillis(); | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    protected long lastOpcode = -1; | 
					 | 
					 | 
					 | 
					    protected long lastOpcode = -1; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    protected ConcurrentLinkedQueue<ByteBuffer> outbox = new ConcurrentLinkedQueue<>(); | 
					 | 
					 | 
					 | 
					    protected ConcurrentLinkedQueue<ByteBuffer> outbox = new ConcurrentLinkedQueue<>(); | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    protected ByteBuffer outBuf = null; | 
					 | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    protected ConcurrentHashMap<Long, Byte> cacheList; | 
					 | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    protected long nextWriteTime = 0L; | 
					 | 
					 | 
					 | 
					    protected long nextWriteTime = 0L; | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					
 | 
					 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    //Opcode tracking
 | 
					 | 
					 | 
					 | 
					    //Opcode tracking
 | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					 | 
					
  |