diff --git a/central-ejb/src/main/java/uy/edu/fing/tse/central/business/mq/MessageConsumer.java b/central-ejb/src/main/java/uy/edu/fing/tse/central/business/mq/MessageConsumer.java
index e76ecaac4f9cb3eefb747b9093ea9c471eeff0c4..c22e493e5ad0d07a488797f2f6fa0a27f34b1907 100644
--- a/central-ejb/src/main/java/uy/edu/fing/tse/central/business/mq/MessageConsumer.java
+++ b/central-ejb/src/main/java/uy/edu/fing/tse/central/business/mq/MessageConsumer.java
@@ -9,6 +9,7 @@ import org.slf4j.LoggerFactory;
 import uy.edu.fing.tse.central.business.BusinessLocal;
 
 import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
 import javax.ejb.EJB;
 import javax.ejb.Singleton;
 import javax.ejb.Startup;
@@ -79,4 +80,13 @@ public class MessageConsumer {
             }
         });
     }
+
+    @PreDestroy
+    public void stop() {
+        try {
+            channel.close();
+        } catch (IOException | TimeoutException e) {
+            throw new RuntimeException("Error al cerrar la coneccion con MQ", e);
+        }
+    }
 }