Skip to content

Commit 60e00bb

Browse files
committed
use autoDelete and not exclusive for gen queues
1 parent 680166c commit 60e00bb

4 files changed

Lines changed: 5 additions & 6 deletions

File tree

OpenFlow/src/amqpwrapper.ts

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -337,9 +337,8 @@ export class amqpwrapper extends events.EventEmitter {
337337
q.QueueOptions = Object.assign({}, (QueueOptions != null ? QueueOptions : this.AssertQueueOptions));
338338
if (NoderedUtil.IsNullEmpty(queue)) queue = "";
339339
if (queue.startsWith("amq.")) queue = "";
340-
// if (NoderedUtil.IsNullEmpty(queue)) q.QueueOptions.autoDelete = true;
341-
if (NoderedUtil.IsNullEmpty(queue)) q.QueueOptions.exclusive = true;
342-
// if (NoderedUtil.IsNullEmpty(queue)) q.QueueOptions.autoDelete = true;
340+
// if (NoderedUtil.IsNullEmpty(queue)) q.QueueOptions.exclusive = true;
341+
if (NoderedUtil.IsNullEmpty(queue)) q.QueueOptions.autoDelete = true;
343342
q.ok = await this.channel.assertQueue(queue, q.QueueOptions);
344343
if (q && q.ok) {
345344
this.queues.push(q);

OpenFlowNodeRED/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@openiap/nodered",
3-
"version": "1.3.75",
3+
"version": "1.3.76",
44
"description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
55
"main": "index.js",
66
"scripts": {

VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
1.3.75
1+
1.3.76

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@openiap/openflow",
3-
"version": "1.3.75",
3+
"version": "1.3.76",
44
"description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
55
"main": "index.js",
66
"scripts": {

0 commit comments

Comments
 (0)