Repository: activemq-6 Updated Branches: refs/heads/master bdac90d6b -> ce0c3d9e6
Log POODLE WARN just once Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/be3622dd Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/be3622dd Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/be3622dd Branch: refs/heads/master Commit: be3622dd04b6c3723b8603437e2be75579c7fbd3 Parents: bdac90d Author: jbertram <[email protected]> Authored: Mon Mar 16 14:01:54 2015 -0500 Committer: Clebert Suconic <[email protected]> Committed: Tue Mar 31 11:52:06 2015 -0400 ---------------------------------------------------------------------- .../activemq/core/remoting/impl/netty/NettyAcceptor.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/be3622dd/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java index 3c59a03..87e1ab0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java @@ -32,6 +32,7 @@ import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicBoolean; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.Channel; @@ -347,6 +348,8 @@ public class NettyAcceptor implements Acceptor context = null; // Unused } + final AtomicBoolean warningPrinted = new AtomicBoolean(false); + ChannelInitializer<Channel> factory = new ChannelInitializer<Channel>() { @Override @@ -405,11 +408,15 @@ public class NettyAcceptor implements Acceptor { if (s.equals("SSLv3") || s.equals("SSLv2Hello")) { - ActiveMQServerLogger.LOGGER.disallowedProtocol(s); + if (!warningPrinted.get()) + { + ActiveMQServerLogger.LOGGER.disallowedProtocol(s); + } continue; } set.add(s); } + warningPrinted.set(true); engine.setEnabledProtocols(set.toArray(new String[0])); SslHandler handler = new SslHandler(engine);
