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/refactor-openwire Commit: df4469092bcef68c05f9933fea1d7c8f2a409ff5 Parents: 623b1b9 Author: Clebert Suconic <[email protected]> Authored: Thu Feb 4 12:15:25 2016 -0500 Committer: Andy Taylor <[email protected]> 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 --------------------------------------------------------
