You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/02/27 19:24:12 UTC
activemq-artemis git commit: ARTEMIS-1002 Use default
PooledBufferAllocator in ActiveMQBuffers
Repository: activemq-artemis
Updated Branches:
refs/heads/1.x e79524683 -> fbdac0c97
ARTEMIS-1002 Use default PooledBufferAllocator in ActiveMQBuffers
(cherry picked from commit dc40f60e6bce0baedf2eb5e777f820b8a7ee7f92)
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/fbdac0c9
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/fbdac0c9
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/fbdac0c9
Branch: refs/heads/1.x
Commit: fbdac0c97dfb60d61994079d94aeeaac1b6a5295
Parents: e795246
Author: Martyn Taylor <mt...@redhat.com>
Authored: Mon Feb 27 12:48:39 2017 +0000
Committer: Clebert Suconic <cl...@apache.org>
Committed: Mon Feb 27 14:24:04 2017 -0500
----------------------------------------------------------------------
.../java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java | 2 +-
.../core/remoting/impl/netty/PartialPooledByteBufAllocator.java | 2 +-
.../amqp/client/transport/PartialPooledByteBufAllocator.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fbdac0c9/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
index 849c921..32f9279 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQBuffers.java
@@ -28,7 +28,7 @@ import org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper;
public final class ActiveMQBuffers {
- private static final PooledByteBufAllocator ALLOCATOR = new PooledByteBufAllocator();
+ private static final PooledByteBufAllocator ALLOCATOR = PooledByteBufAllocator.DEFAULT;
/**
* Creates a <em>self-expanding</em> ActiveMQBuffer with the given initial size
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fbdac0c9/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/PartialPooledByteBufAllocator.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/PartialPooledByteBufAllocator.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/PartialPooledByteBufAllocator.java
index d6b9251..5e67952 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/PartialPooledByteBufAllocator.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/PartialPooledByteBufAllocator.java
@@ -28,7 +28,7 @@ import io.netty.buffer.UnpooledByteBufAllocator;
*/
public class PartialPooledByteBufAllocator implements ByteBufAllocator {
- private static final ByteBufAllocator POOLED = new PooledByteBufAllocator(false);
+ private static final ByteBufAllocator POOLED = PooledByteBufAllocator.DEFAULT;
private static final ByteBufAllocator UNPOOLED = new UnpooledByteBufAllocator(false);
public static final PartialPooledByteBufAllocator INSTANCE = new PartialPooledByteBufAllocator();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fbdac0c9/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/PartialPooledByteBufAllocator.java
----------------------------------------------------------------------
diff --git a/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/PartialPooledByteBufAllocator.java b/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/PartialPooledByteBufAllocator.java
index 988e501..12f5568 100644
--- a/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/PartialPooledByteBufAllocator.java
+++ b/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/PartialPooledByteBufAllocator.java
@@ -28,7 +28,7 @@ import io.netty.buffer.UnpooledByteBufAllocator;
*/
public class PartialPooledByteBufAllocator implements ByteBufAllocator {
- private static final ByteBufAllocator POOLED = new PooledByteBufAllocator(false);
+ private static final ByteBufAllocator POOLED = PooledByteBufAllocator.DEFAULT;
private static final ByteBufAllocator UNPOOLED = new UnpooledByteBufAllocator(false);
public static final PartialPooledByteBufAllocator INSTANCE = new PartialPooledByteBufAllocator();