Unbind queue before worker termination

ba-st · Sep 3, 2024 · 0892135 · 0892135
1 parent 94a9cbd
commit 0892135
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/source/Ansible-RabbitMQ-Tests/RabbitMQClientTest.class.st b/source/Ansible-RabbitMQ-Tests/RabbitMQClientTest.class.st
@@ -216,7 +216,10 @@ RabbitMQClientTest >> runWorkerNamed: aName consumingFrom: aQueueName bindedTo:
                              ]
                            processingPayloadWith: aProcessingBlock.
                worker bindQueueTo: anExchange routedBy: aRoutingKey.
-               [ worker start ] ensure: [ worker stop ]
+               [ worker start ] ensure: [
+                   worker unbindQueueTo: anExchange routedBy: aRoutingKey.
+                   worker stop
+                 ]
              ] newProcess.
   process
     name: aName;

diff --git a/source/Ansible-RabbitMQ/RabbitMQWorker.class.st b/source/Ansible-RabbitMQ/RabbitMQWorker.class.st
@@ -41,7 +41,7 @@ RabbitMQWorker class >> configuredBy: aConfigurationAction processingPayloadWith
       processingMessagesWith: [ :message | aPayloadProcessor value: message body ]
 ]
 
-{ #category : 'Configuring' }
+{ #category : 'configuring' }
 RabbitMQWorker >> bindQueueTo: anExchange routedBy: aRoutingKey [
 
   self
@@ -144,3 +144,9 @@ RabbitMQWorker >> startProcessing [
         ]
   ] repeat
 ]
+
+{ #category : 'configuring' }
+RabbitMQWorker >> unbindQueueTo: anExchange routedBy: aRoutingKey [
+
+  channel queueUnbind: self queueName exchange: anExchange routingKey: aRoutingKey
+]