From 80466f6c5fe82f00e83da5e66d9f8b3724190c13 Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Mon, 30 Jul 2012 23:27:58 +0200 Subject: [PATCH] Added main client test --- .../org/dna/mqtt/moquette/client/Client.java | 16 ++++----- .../org/dna/mqtt/moquette/client/Main.java | 36 +++++++++++++++++++ .../server/ServerIntegrationTest.java | 1 - 3 files changed, 44 insertions(+), 9 deletions(-) create mode 100644 parser/src/main/java/org/dna/mqtt/moquette/client/Main.java diff --git a/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java b/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java index dfbbe297..0c5f91f8 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java @@ -101,22 +101,22 @@ public final class Client { int retries = 0; //TODO perhaps by proto deinifinition should be an implicit retry policy - for (; retries < m_connectRetries; retries++) { +// for (; retries < m_connectRetries; retries++) { try { ConnectFuture future = m_connector.connect(new InetSocketAddress(m_hostname, m_port)); LOG.fine("Client waiting to connect to server"); future.awaitUninterruptibly(); m_session = future.getSession(); - break; +// break; } catch (RuntimeIoException e) { LOG.log(Level.FINE, "Failed to connect, retry " + retries + " of ("+m_connectRetries+")", e); } - try { - Thread.sleep(1000); - } catch (InterruptedException ex) { - LOG.log(Level.SEVERE, "Error while sleeping for retry", ex); - } - } +// try { +// Thread.sleep(1000); +// } catch (InterruptedException ex) { +// LOG.log(Level.SEVERE, "Error while sleeping for retry", ex); +// } +// } if (retries == m_connectRetries) { throw new MQTTException("Can't connect to the server after " + retries + "retries"); diff --git a/parser/src/main/java/org/dna/mqtt/moquette/client/Main.java b/parser/src/main/java/org/dna/mqtt/moquette/client/Main.java new file mode 100644 index 00000000..2586cd10 --- /dev/null +++ b/parser/src/main/java/org/dna/mqtt/moquette/client/Main.java @@ -0,0 +1,36 @@ +package org.dna.mqtt.moquette.client; + +import java.io.IOException; +import java.util.logging.Logger; +import org.dna.mqtt.moquette.server.Server; + +/** + * + * @author andrea + */ +public class Main { + private static final Logger LOG = Logger.getLogger(Main.class.getName()); + + static boolean received; + + public static void main(String[] args) throws IOException { + Client client = new Client("localhost", Server.PORT); + client.connect(); + + + client.subscribe("/topic", new IPublishCallback() { + + public void published(String topic, byte[] message) { + LOG.info("Received publush notification"); + received = true; + } + }); + + client.publish("/topic", "Test my payload".getBytes()); + client.close(); + + + assert received; + } + +} 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 8890ae09..ac1641f9 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 @@ -15,7 +15,6 @@ import org.junit.Before; */ public class ServerIntegrationTest { - IoConnector connector; boolean received; Server server;