camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject [1/4] git commit: CAMEL-7799 Remove the useless timer from NettyProducer
Date Wed, 10 Sep 2014 14:17:43 GMT
Repository: camel
Updated Branches:
  refs/heads/master 3c99fa97d -> 456f75bd2


CAMEL-7799 Remove the useless timer from NettyProducer


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/456f75bd
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/456f75bd
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/456f75bd

Branch: refs/heads/master
Commit: 456f75bd2017a3f1ab147c3d7b438501c533a605
Parents: db6baef
Author: Willem Jiang <willem.jiang@gmail.com>
Authored: Wed Sep 10 21:49:40 2014 +0800
Committer: Willem Jiang <willem.jiang@gmail.com>
Committed: Wed Sep 10 21:49:55 2014 +0800

----------------------------------------------------------------------
 .../org/apache/camel/component/netty4/NettyProducer.java     | 8 --------
 1 file changed, 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/456f75bd/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
index 53b777f..7f54990 100644
--- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
+++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java
@@ -63,7 +63,6 @@ public class NettyProducer extends DefaultAsyncProducer {
     private CamelLogger noReplyLogger;
     private EventLoopGroup workerGroup;
     private ObjectPool<Channel> pool;
-    private Timer timer;
     private Map<Channel, NettyCamelState> nettyCamelStatesMap = new ConcurrentHashMap<Channel,
NettyCamelState>();
 
     public NettyProducer(NettyEndpoint nettyEndpoint, NettyConfiguration configuration) {
@@ -122,8 +121,6 @@ public class NettyProducer extends DefaultAsyncProducer {
             }
         }
 
-        timer = new HashedWheelTimer();
-
         // setup pipeline factory
         ClientInitializerFactory factory = configuration.getClientPipelineFactory();
         if (factory != null) {
@@ -161,11 +158,6 @@ public class NettyProducer extends DefaultAsyncProducer {
             pool = null;
         }
 
-        if (timer != null) {
-            timer.stop();
-            timer = null;
-        }
-
         super.doStop();
     }
 


Mime
View raw message