36 as a library user i want to create an exchange of non built in type (#46)

* added support for custom exchange types

* fixed tests

* added volume in container definition for github action

Author: apietroni51

.github/workflows/main.yml

@@ -29,6 +29,8 @@ jobs:
         ports:
           - 5672:5672
           - 15672:15672
+        volumes:
+          - ./conf/:/etc/rabbitmq/
 
     steps:
       - uses: actions/checkout@v3

conf/enabled_plugins

@@ -0,0 +1 @@
+[rabbitmq_stream_management,rabbitmq_consistent_hash_exchange].

docker-compose.yml

@@ -10,3 +10,5 @@ services:
     environment:
       RABBITMQ_DEFAULT_USER: "rabbit"
       RABBITMQ_DEFAULT_PASS: "rabbit"
+    volumes:
+      - ./conf/:/etc/rabbitmq/

src/exchange.ts

@@ -4,15 +4,15 @@ export type ExchangeOptions = {
   arguments: Record<string, string>
   auto_delete: boolean
   durable: boolean
-  type: ExchangeType
+  type: ExchangeType | string
 }
 
 export interface ExchangeInfo {
   name: string
   arguments: Record<string, string>
   autoDelete: boolean
   durable: boolean
-  type: ExchangeType
+  type: ExchangeType | string
 }
 
 export interface Exchange {

src/management.ts

@@ -200,6 +200,7 @@ export class AmqpManagement implements Management {
           type: options.type ?? "direct",
           durable: options.durable ?? true,
           auto_delete: options.auto_delete ?? false,
+          arguments: options.arguments ?? {},
         })
         .build()
 

test/e2e/management.test.ts

@@ -114,6 +114,21 @@ describe("Management", () => {
     })
   })
 
+  test("create an exchange with custom type", async () => {
+    const customType = "x-consistent-hash" // requires plugin rabbitmq_consistent_hash_exchange enabled
+    const exchange = await management.declareExchange(exchangeName, {
+      type: customType,
+      auto_delete: true,
+      durable: false,
+    })
+
+    await eventually(async () => {
+      const exchangeInfo = await getExchangeInfo(exchange.getInfo.name)
+      expect(exchangeInfo.ok).to.eql(true)
+      expect(exchangeInfo.body.type).to.eql(customType)
+    })
+  })
+
   test("delete an exchange through the management", async () => {
     await createExchange(exchangeName)
     await eventually(async () => {