code: @Override
  	public void bufferAvailable(Buffer buffer) throws Exception {
  		this.bufferBroker.offer(buffer);
  		this.channelHandlerContext.channel().eventLoop().execute(this.bufferAvailabilityChangedTask);
  	}
docs: Notifies the IO thread that a Buffer has become available again.
  <p/>
  This method will be called from outside the Netty IO thread. The caller will be the buffer pool from which the
  available buffer comes (i.e. the InputGate).
  <p/>
  We have to make sure that the available buffer is handed over to the IO thread in a safe manner.