MultiplexedChannel implements Channel { protected void queueData(final byte[] data) { if (data != null && data.length > 0) { this.pendingData.offer(data); } } MultiplexedChannel(); @Override SocketAddress getLocalAddress(); @Override String getLocalHost(); @Override int getLocalPort(); String getRemoteHost(); int getRemotePort(); @Deprecated void setTransport(final DatagramChannel channel); @Override boolean hasPendingData(); @Override void receive(); @Override void send(); @Override boolean isOpen(); @Override boolean isConnected(); @Override void bind(SocketAddress address); @Override void connect(SocketAddress address); @Override void disconnect(); @Override void open(); @Override void open(DatagramChannel dataChannel); @Override void close();  }
@Test public void testQueueData() { MultiplexedChannel channel = new MultiplexedChannel(); channel.queueData("hello".getBytes()); assertTrue(channel.hasPendingData()); }