Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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.
This commit is contained in:
Timothy Bish 2016-04-12 16:28:23 -04:00
parent 332a8225fa
commit f9682b802f
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
View File

@ -239,10 +239,13 @@ public class TransportConnector implements Connector, BrokerServiceAware {
} }
private void onAcceptError(Exception error, String remoteHost) { private void onAcceptError(Exception error, String remoteHost) {
LOG.error("Could not accept connection " + (remoteHost == null ? "" : "from " + remoteHost) + ": " if (brokerService != null && brokerService.isStopping()) {
+ error); 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); LOG.debug("Reason: " + error, error);
} }
}
}); });
getServer().setBrokerInfo(brokerInfo); getServer().setBrokerInfo(brokerInfo);
getServer().start(); getServer().start();
@ -560,6 +563,7 @@ public class TransportConnector implements Connector, BrokerServiceAware {
/** /**
* @return the updateClusterFilter * @return the updateClusterFilter
*/ */
@Override
public String getUpdateClusterFilter() { public String getUpdateClusterFilter() {
return this.updateClusterFilter; return this.updateClusterFilter;
} }