Minor edit

Author: acogoluegnes

src/main/java/com/rabbitmq/client/impl/NettyFrameHandlerFactory.java

@@ -394,11 +394,12 @@ private void doWriteFrame(Frame frame) throws IOException {
         end.writeByte(AMQP.FRAME_END);
 
         ByteBuf composite = Unpooled.wrappedBuffer(header, body, end);
-        this.channel.writeAndFlush(composite);
+        // this is for basicPublish, the channel will be flushed later
+        this.channel.write(composite, this.channel.voidPromise());
       } else {
         ByteBuf bb = this.channel.alloc().buffer(frame.size());
         frame.writeToByteBuf(bb);
-        this.channel.writeAndFlush(bb);
+        this.channel.writeAndFlush(bb, this.channel.voidPromise());
       }
     }
 

src/test/java/com/rabbitmq/client/test/PublishWithByteBufferTest.java

@@ -48,7 +48,7 @@ protected void releaseResources() throws IOException {
   }
 
   @Test
-  public void basicConsumeDeliverCancel() throws Exception {
+  public void publishByteBuffer() throws Exception {
     int frameMax = 10_000;
     int size = frameMax * 4;
     byte[] masterData = new byte[size];