From f9682b802f848b91b6a12aa6c99cec028b552997 Mon Sep 17 00:00:00 2001 From: Timothy Bish Date: Tue, 12 Apr 2016 16:28:23 -0400 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-6127 LOG at info level for when broker is being stopped and a new connection is not being accepted. --- .../org/apache/activemq/broker/TransportConnector.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java index 5e9c645272..ac9661924d 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java @@ -239,9 +239,12 @@ public class TransportConnector implements Connector, BrokerServiceAware { } private void onAcceptError(Exception error, String remoteHost) { - LOG.error("Could not accept connection " + (remoteHost == null ? "" : "from " + remoteHost) + ": " - + error); - LOG.debug("Reason: " + error, error); + if (brokerService != null && brokerService.isStopping()) { + LOG.info("Could not accept connection during shutdown {} : {}", (remoteHost == null ? "" : "from " + remoteHost), error); + } else { + LOG.error("Could not accept connection {} : {}", (remoteHost == null ? "" : "from " + remoteHost), error); + LOG.debug("Reason: " + error, error); + } } }); getServer().setBrokerInfo(brokerInfo); @@ -560,6 +563,7 @@ public class TransportConnector implements Connector, BrokerServiceAware { /** * @return the updateClusterFilter */ + @Override public String getUpdateClusterFilter() { return this.updateClusterFilter; }