AutoCLose

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);
+        }
+    }
 }