Fix test

Author: acogoluegnes

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

@@ -22,8 +22,6 @@
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.WriteListener;
-import io.netty.buffer.ByteBuf;
-import io.netty.buffer.ByteBufAllocator;
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.UUID;
@@ -89,40 +87,4 @@ public void publishByteBuffer() throws Exception {
       this.channel.basicCancel(ctag);
     }
   }
-
-  @Test
-  public void publish() throws Exception {
-    int size = 50_000;
-    byte[] masterData = new byte[size];
-    ThreadLocalRandom.current().nextBytes(masterData);
-    ConnectionFactory cf = TestUtils.connectionFactory();
-    ByteBufAllocator allocator = ByteBufAllocator.DEFAULT;
-    try (Connection connection = cf.newConnection()) {
-      AtomicReference<CountDownLatch> consumingLatch = new AtomicReference<>();
-      AtomicReference<byte[]> dataRef = new AtomicReference<>();
-      String ctag =
-          this.channel.basicConsume(
-              queue,
-              true,
-              (consumerTag, delivery) -> {
-                dataRef.set(delivery.getBody());
-                consumingLatch.get().countDown();
-              },
-              consumerTag -> {});
-      Channel publishingChannel = connection.createChannel();
-      boolean keepGoing = true;
-      while (keepGoing) {
-        ByteBuf buf = allocator.directBuffer(size);
-        //        ByteBuf buf = allocator.heapBuffer(size);
-        buf.writeBytes(masterData);
-        consumingLatch.set(new CountDownLatch(1));
-        publishingChannel.basicPublish("", queue, null, buf.nioBuffer());
-        assertTrue(
-            consumingLatch.get().await(10, TimeUnit.SECONDS), "deliver should have been called");
-        buf.release();
-      }
-
-      this.channel.basicCancel(ctag);
-    }
-  }
 }