Copyright update

[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 57445bd6655bdc65c32095555cedde451f66fcb1..bd664b805cf2667904f94ff31dd3303536f008df 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
@@ -1,4 +1,11 @@
-/* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */
+/*
+ * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
 package org.opendaylight.openflowjava.protocol.impl.clients;
 
 import io.netty.buffer.ByteBuf;
@@ -8,13 +15,20 @@ import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
+/**
+ * Class representing sending message event
+ * 
+ * @author michal.polkorab
+ */
 public class SendEvent implements ClientEvent {
 
     protected static final Logger LOGGER = LoggerFactory.getLogger(SendEvent.class);
     protected byte[] msgToSend;
     protected ChannelHandlerContext ctx;
 
+    /**
+     * @param msgToSend message to be sent
+     */
     public SendEvent(byte[] msgToSend) {
         this.msgToSend = msgToSend;
     }
@@ -22,26 +36,18 @@ 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;
     }
 
+    /**
+     * @param ctx context which will be used for sending messages (SendEvents)
+     */
     public void setCtx(ChannelHandlerContext ctx) {
         this.ctx = ctx;
     }