From fd0c336600f26a0b1dc8cf0c91ff29a3075ced18 Mon Sep 17 00:00:00 2001
From: "selva.andre" <selva.andre@gmail.com>
Date: Wed, 5 Sep 2012 20:50:56 +0200
Subject: [PATCH] Re-enabled ignored test, moved from ServerIntegrationTests

---
 .../server/ServerIntegrationFuseTest.java     |  4 ++--
 .../server/ServerIntegrationTest.java         | 20 -------------------
 2 files changed, 2 insertions(+), 22 deletions(-)

diff --git a/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java b/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java
index 515b7408..a55bcf9f 100644
--- a/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java
+++ b/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java
@@ -42,7 +42,7 @@ public class ServerIntegrationFuseTest {
         }
     }
 
-    @Ignore
+    @Test
     public void testSubscribe() throws Exception {
 //        startServer();
         MQTT mqtt = new MQTT();
@@ -61,7 +61,7 @@ public class ServerIntegrationFuseTest {
         connection.disconnect().await();
     }
 
-    @Ignore
+    @Test
     public void testPublishWithQoS1() throws Exception {
         MQTT mqtt = new MQTT();
         mqtt.setHost("localhost", Server.PORT);
diff --git a/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationTest.java b/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationTest.java
index de8107a2..d174bc04 100644
--- a/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationTest.java
+++ b/parser/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationTest.java
@@ -42,26 +42,6 @@ public class ServerIntegrationTest {
         }
     }
     
-    @Test
-    public void testSubscribe_FSClient() throws Exception {
-//        startServer();
-        MQTT mqtt = new MQTT();
-        mqtt.setHost("localhost", Server.PORT);
-        mqtt.setClientId("TestClient");
-        FutureConnection connection = mqtt.futureConnection();
-        connection.connect().await();
-
-        Topic[] topics = {new Topic("/topic", QoS.AT_MOST_ONCE)};
-        Future<byte[]> futSub = connection.subscribe(topics);
-
-        connection.publish("/topic", "Test my payload".getBytes(), QoS.AT_MOST_ONCE, false).await();
-
-        byte[] qoses = futSub.await();
-        assertEquals(1, qoses.length);
-        connection.disconnect().await();
-    }
-    
-    
     @Test
     public void testSubscribe() throws IOException, InterruptedException {
 //        startServer();