diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml index add4a511..a1c487f8 100644 --- a/.github/workflows/test.yml +++ b/.github/workflows/test.yml @@ -15,7 +15,7 @@ jobs: matrix: node-version: [18.x, 20.x, 22.x] mongodb-version: [5.0, 6.0] - rabbit-version: [3.12.5] + rabbit-version: [3.12.5, 4.2.1] redis-version: [7.0] kafka-version: [4.1.1] diff --git a/docker-compose.yml b/docker-compose.yml index 39ad1e52..75e9dc76 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -33,7 +33,7 @@ services: retries: 5 rabbitmq: - image: rabbitmq:${RABBITMQ_VERSION:-3.12.5}-management + image: rabbitmq:${RABBITMQ_VERSION:-4.1.2}-management container_name: rabbitmq ports: - 5672:5672 diff --git a/docs/integrations/rabbitmq.md b/docs/integrations/rabbitmq.md index 7e51f1a1..62802a1f 100644 --- a/docs/integrations/rabbitmq.md +++ b/docs/integrations/rabbitmq.md @@ -17,7 +17,7 @@ eg: module.exports = { queue: { url: 'amqp://localhost', - frameMax: 0x1000, // default frameMax in bytes + frameMax: 0x2000, // default frameMax in bytes prefetch: 100, connectDelay: 5000 // delay when retrying connections in ms } diff --git a/examples/rabbitmq-example/config.js b/examples/rabbitmq-example/config.js index e51593ec..da8c9870 100644 --- a/examples/rabbitmq-example/config.js +++ b/examples/rabbitmq-example/config.js @@ -8,7 +8,7 @@ module.exports = { queue: { prefetch: 100, url: 'amqp://127.0.0.1', - frameMax: 0x1000, + frameMax: 0x2000, maxRetries: 0, retryDelay: 1000, connectDelay: 5000 diff --git a/test/initializers/rabbitmq/index.test.ts b/test/initializers/rabbitmq/index.test.ts index 1192aa10..eca457bf 100644 --- a/test/initializers/rabbitmq/index.test.ts +++ b/test/initializers/rabbitmq/index.test.ts @@ -22,7 +22,7 @@ describe('Test rabbitmq connection', function () { queue: { prefetch: 100, url: 'amqp://localhost', - frameMax: 0x1000, + frameMax: 0x2000, maxRetries: 0, retryDelay: 1000, connectDelay: 5000 @@ -70,7 +70,7 @@ describe('Test rabbitmq connection', function () { getRabbit(config, orkaOptions); stub.args.should.eql([ [ - 'amqp://localhost?frameMax=4096', + 'amqp://localhost?frameMax=8192', { prefetch: 100, prefix: 'test', @@ -89,7 +89,7 @@ describe('Test rabbitmq connection', function () { const rabbit = getRabbit(config, orkaOptions); stub.args.should.eql([ [ - 'amqp://localhost?frameMax=4096', + 'amqp://localhost?frameMax=8192', { prefetch: 100, prefix: 'test',