Add missing changes from the master branch

src/main/java/org/jboss/netty/channel/socket/nio/AbstractNioChannel.java

@@ -115,6 +115,15 @@ abstract class AbstractNioChannel<C extends SelectableChannel & WritableByteChan
         this.channel = ch;
     }
 
+    /**
+     * Return the {@link AbstractNioWorker} that handle the IO of the
+     * {@link AbstractNioChannel}
+     * 
+     * @return worker
+     */
+    public AbstractNioWorker getWorker() {
+        return worker;
+    }
     public InetSocketAddress getLocalAddress() {
         InetSocketAddress localAddress = this.localAddress;
         if (localAddress == null) {

src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramChannel.java

@@ -33,7 +33,7 @@ import java.nio.channels.DatagramChannel;
 /**
  * Provides an NIO based {@link io.netty.channel.socket.DatagramChannel}.
  */
-final class NioDatagramChannel extends AbstractNioChannel<DatagramChannel>
+public final class NioDatagramChannel extends AbstractNioChannel<DatagramChannel>
                                 implements org.jboss.netty.channel.socket.DatagramChannel {
 
     /**
@@ -61,7 +61,11 @@ final class NioDatagramChannel extends AbstractNioChannel<DatagramChannel>
         }
     }
 
-
+    @Override
+    public NioDatagramWorker getWorker() {
+        return (NioDatagramWorker) super.getWorker();
+    }
+    
     public boolean isBound() {
         return isOpen() && channel.socket().isBound();
     }

src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java

@@ -43,6 +43,10 @@ class NioSocketChannel extends AbstractNioChannel<SocketChannel>
         config = new DefaultNioSocketChannelConfig(socket.socket());
     }
 
+    @Override
+    public NioWorker getWorker() {
+        return (NioWorker) super.getWorker();
+    }
 
     public NioSocketChannelConfig getConfig() {
         return config;