Added cachedThreadPool in ConnectionAdapter

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / core / DelegatingInboundHandler.java

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java
index 44366ee32dedb03e59d2c347bfbe7585d9f6e193..9ef3b73e8be8b16d668c278b8f06a621e86c486b 100644 (file)
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/DelegatingInboundHandler.java
@@ -34,12 +34,7 @@ public class DelegatingInboundHandler extends ChannelInboundHandlerAdapter {
     public void channelRead(ChannelHandlerContext ctx, final Object msg)\r
             throws Exception {\r
         LOGGER.debug("Reading");\r
-        new Thread(new Runnable() {\r
-            @Override\r
-            public void run() {\r
-                consumer.consume((DataObject) msg);\r
-            }\r
-        }).start();\r
+        consumer.consume((DataObject) msg);\r
     }\r
     \r
     @Override\r