From 6428d39ce5f91fb20e526c7d6bf984482697e882 Mon Sep 17 00:00:00 2001
From: andrea <andrea@samarcanda>
Date: Thu, 26 Dec 2013 12:49:38 +0100
Subject: [PATCH] Forced some delay in server shutdown to give time the
 ProcessorEvent to shutdown correclty (it's asynch operation)

---
 .../main/java/org/dna/mqtt/moquette/server/Server.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/broker/src/main/java/org/dna/mqtt/moquette/server/Server.java b/broker/src/main/java/org/dna/mqtt/moquette/server/Server.java
index 78e230dd..cedab003 100644
--- a/broker/src/main/java/org/dna/mqtt/moquette/server/Server.java
+++ b/broker/src/main/java/org/dna/mqtt/moquette/server/Server.java
@@ -2,6 +2,7 @@ package org.dna.mqtt.moquette.server;
 
 import java.io.File;
 import java.io.IOException;
+import java.util.logging.Level;
 import org.dna.mqtt.moquette.messaging.spi.impl.SimpleMessaging;
 //import org.dna.mqtt.moquette.server.mina.MinaAcceptor;
 import org.dna.mqtt.moquette.server.netty.NettyAcceptor;
@@ -44,10 +45,19 @@ public class Server {
         m_acceptor.initialize(messaging);
     }
     
+    /**
+     * It's an asynchronous method, it's only a request to stop
+     */
     public void stopServer() {
         System.out.println("Server stopping...");
         messaging.stop();
         m_acceptor.close();
         System.out.println("Server stopped");
+        try {
+            //sleep one second to give the disruptor
+            Thread.sleep(100);
+        } catch (InterruptedException ex) {
+            LOG.error(null, ex);
+        }
     }
 }