activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From andytay...@apache.org
Subject [2/2] activemq-artemis git commit: Removing unecessary concurrent collection. Replacing by regular one
Date Thu, 04 Feb 2016 18:32:11 GMT
Removing unecessary concurrent collection. Replacing by regular one


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/df446909
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/df446909
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/df446909

Branch: refs/heads/master
Commit: df4469092bcef68c05f9933fea1d7c8f2a409ff5
Parents: 623b1b9
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Thu Feb 4 12:15:25 2016 -0500
Committer: Andy Taylor <andy.tayls67@gmail.com>
Committed: Thu Feb 4 18:31:31 2016 +0000

----------------------------------------------------------------------
 .../artemis/core/remoting/impl/netty/NettyConnection.java       | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/df446909/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java
index cc3b65a..6608b54 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java
@@ -17,8 +17,9 @@
 package org.apache.activemq.artemis.core.remoting.impl.netty;
 
 import java.net.SocketAddress;
+import java.util.Deque;
 import java.util.Map;
-import java.util.concurrent.ConcurrentLinkedDeque;
+import java.util.concurrent.LinkedBlockingDeque;
 import java.util.concurrent.Semaphore;
 
 import io.netty.buffer.ByteBuf;
@@ -70,7 +71,7 @@ public class NettyConnection implements Connection {
 
    /** if {@link #isWritable(ReadyListener)} returns false, we add a callback
     *  here for when the connection (or Netty Channel) becomes available again. */
-   private final ConcurrentLinkedDeque<ReadyListener> readyListeners = new ConcurrentLinkedDeque<>();
+   private final Deque<ReadyListener> readyListeners = new LinkedBlockingDeque<>();
 
    // Static --------------------------------------------------------
 


Mime
View raw message