Added queue delete

kegaretail · Oct 20, 2017 · ed4756e · ed4756e
1 parent e188454
commit ed4756e
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/android/src/main/java/nl/kega/reactnativerabbitmq/RabbitMqConnection.java b/android/src/main/java/nl/kega/reactnativerabbitmq/RabbitMqConnection.java
@@ -198,9 +198,19 @@ public void unbindQueue(String exchange_name, String queue_name) {
     }
 
     @ReactMethod
-    public void removeQueue() {
-
+    public void removeQueue(String queue_name) {
+        RabbitMqQueue found_queue = null;
+        for (RabbitMqQueue queue : queues) {
+		    if (Objects.equals(queue_name, queue.name)){
+                found_queue = queue;
+            }
+        }
+
+        if (!found_queue.equals(null)){
+            found_queue.delete();
+        }
     }
+
     /*
     @ReactMethod
     public void publishToQueue(String message, String exchange_name, String routing_key) {

diff --git a/lib/Queue.js b/lib/Queue.js
@@ -67,6 +67,10 @@ export class Queue {
         this.rabbitmqconnection.unbindQueue(exchange.name, this.name, routing_key);    
     }
 
+    delete(){
+        this.rabbitmqconnection.removeQueue(this.name);    
+    }
+
     close() {
         DeviceEventEmitter.removeListener('RabbitMqQueueEvent', this.handleEvent.bind(this));
         this.callbacks = [];