Ordered message execution ensured

[openflowjava.git] / simple-client / src / main / java / org / opendaylight / openflowjava / protocol / impl / clients / SendEvent.java

diff --git a/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/SendEvent.java b/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/SendEvent.java
index d0ec8b9f560769905c00b3fed8c6150c8e1f98b7..e59bce0775eb5d6a3734ce53e2e5bd3b80983887 100644 (file)
--- a/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/SendEvent.java
+++ b/simple-client/src/main/java/org/opendaylight/openflowjava/protocol/impl/clients/SendEvent.java
@@ -29,22 +29,11 @@ public class SendEvent implements ClientEvent {
     @Override
     public boolean eventExecuted() {
         LOGGER.debug("sending message");
-        Thread thread = new Thread(new Runnable() {
-            @Override
-            public void run() {
-                LOGGER.debug("start of run");
-                ByteBuf buffer = ctx.alloc().buffer();
-                buffer.writeBytes(msgToSend);
-                ctx.writeAndFlush(buffer);
-                LOGGER.debug(">> " + ByteBufUtils.bytesToHexString(msgToSend));
-            }
-        });
-        thread.start();
-        try {
-            thread.join();
-        } catch (InterruptedException e) {
-            LOGGER.error(e.getMessage(), e);
-        }
+        LOGGER.debug("start of run");
+        ByteBuf buffer = ctx.alloc().buffer();
+        buffer.writeBytes(msgToSend);
+        ctx.writeAndFlush(buffer);
+        LOGGER.debug(">> " + ByteBufUtils.bytesToHexString(msgToSend));
         LOGGER.debug("message sent");
         return true;
     }