Remove unused test

Author: magne

test/e2e/declare_consumer.test.ts

@@ -1,14 +1,19 @@
 import { expect } from "chai"
+import { randomUUID } from "crypto"
+import { readFileSync } from "fs"
+import path from "path"
 import { Client, Publisher } from "../../src"
 import {
+  AmqpByte,
   Message,
   MessageAnnotations,
   MessageApplicationProperties,
-  MessageProperties,
   MessageHeader,
-  AmqpByte,
+  MessageProperties,
 } from "../../src/publisher"
 import { Offset } from "../../src/requests/subscribe_request"
+import { BufferDataReader } from "../../src/response_decoder"
+import { getMaxSharedConnectionInstances, range } from "../../src/util"
 import {
   createClient,
   createConsumer,
@@ -17,20 +22,14 @@ import {
   createStreamName,
 } from "../support/fake_data"
 import { Rabbit, RabbitConnectionResponse } from "../support/rabbit"
-import { getMaxSharedConnectionInstances, range } from "../../src/util"
-import { BufferDataReader } from "../../src/response_decoder"
 import {
+  decodeMessageTesting,
   eventually,
   expectToThrowAsync,
-  username,
-  password,
-  createClassicPublisher,
-  decodeMessageTesting,
   getTestNodesFromEnv,
+  password,
+  username,
 } from "../support/util"
-import { readFileSync } from "fs"
-import path from "path"
-import { randomUUID } from "crypto"
 
 describe("declare consumer", () => {
   let streamName: string
@@ -242,32 +241,6 @@ describe("declare consumer", () => {
     await eventually(async () => expect(messageAnnotations).eql([annotations]))
   }).timeout(10000)
 
-  it("messageAnnotations are ignored by a classic driver", async () => {
-    const messageAnnotations: MessageAnnotations[] = []
-    const annotations = createAnnotations()
-    const classicPublisher = await createClassicPublisher()
-    await classicPublisher.ch.assertQueue("testQ", {
-      exclusive: false,
-      durable: true,
-      autoDelete: false,
-      arguments: {
-        "x-queue-type": "stream", // Mandatory to define stream queue
-      },
-    })
-
-    classicPublisher.ch.sendToQueue("testQ", Buffer.from("Hello"), {
-      headers: {
-        messageAnnotations: annotations,
-      },
-    })
-
-    await eventually(async () => {
-      expect(messageAnnotations).to.be.empty
-      await classicPublisher.ch.close()
-      await classicPublisher.conn.close()
-    })
-  }).timeout(10000)
-
   it("messageAnnotations with bytes are read correctly", async () => {
     const messageAnnotations: MessageAnnotations[] = []
     const annotations = { test: new AmqpByte(123) }