Optimize Netty frame writing

Author: acogoluegnes

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

@@ -384,22 +384,28 @@ private void doWriteFrame(Frame frame) throws IOException {
       ByteBuffer bbPayload = frame.getByteBufferPayload();
       if (bbPayload != null) {
         int payloadSize = bbPayload.remaining();
-        ByteBuf header = this.channel.alloc().buffer(7);
-        header.writeByte(frame.getType());
-        header.writeShort(frame.getChannel());
-        header.writeInt(payloadSize);
-
-        ByteBuf body = Unpooled.wrappedBuffer(bbPayload);
-
-        ByteBuf end = this.channel.alloc().buffer(1);
-        end.writeByte(AMQP.FRAME_END);
-
-        ByteBuf composite = Unpooled.wrappedBuffer(header, body, end);
-        this.channel.writeAndFlush(composite, this.channel.voidPromise());
+        int totalSize = 7 + payloadSize + 1;
+        ByteBuf bb = this.channel.alloc().buffer(totalSize);
+        try {
+          bb.writeByte(frame.getType());
+          bb.writeShort(frame.getChannel());
+          bb.writeInt(payloadSize);
+          bb.writeBytes(bbPayload);
+          bb.writeByte(AMQP.FRAME_END);
+          this.channel.writeAndFlush(bb, this.channel.voidPromise());
+        } catch (RuntimeException e) {
+          bb.release();
+          throw e;
+        }
       } else {
         ByteBuf bb = this.channel.alloc().buffer(frame.size());
-        frame.writeToByteBuf(bb);
-        this.channel.writeAndFlush(bb, this.channel.voidPromise());
+        try {
+          frame.writeToByteBuf(bb);
+          this.channel.writeAndFlush(bb, this.channel.voidPromise());
+        } catch (RuntimeException | IOException e) {
+          bb.release();
+          throw e;
+        }
       }
     }