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

[AMQ-9447] Added Logic to check underlying transport connector limits

This commit is contained in:
AM-19 2024-03-31 23:45:00 +05:30
parent a611b143da
commit e6d316ef42
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
activemq-broker/src/main/java/org/apache/activemq/broker/jmx/HealthView.java
View File

@ -29,8 +29,10 @@ import javax.management.openmbean.TabularDataSupport;
import javax.management.openmbean.TabularType; import javax.management.openmbean.TabularType;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.TransportConnector;
import org.apache.activemq.broker.scheduler.JobSchedulerStore; import org.apache.activemq.broker.scheduler.JobSchedulerStore;
import org.apache.activemq.store.PersistenceAdapter; import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.transport.tcp.TcpTransportServer;
import org.apache.activemq.usage.SystemUsage; import org.apache.activemq.usage.SystemUsage;
public class HealthView implements HealthViewMBean { public class HealthView implements HealthViewMBean {
@ -167,6 +169,25 @@ public class HealthView implements HealthViewMBean {
} }
} }
/**
* Check The Transport Connector limits
*/
if (brokerService != null && !brokerService.getTransportConnectors().isEmpty()) {
for(TransportConnector tc: brokerService.getTransportConnectors()) {
if(tc.getServer() instanceof TcpTransportServer) {
int connectionUsage = (int) (((TcpTransportServer)tc.getServer()).getCurrentTransportCount().get() * 100 ) / ((TcpTransportServer)tc.getServer()).getMaximumConnections();
if(((TcpTransportServer)tc.getServer()).getCurrentTransportCount().get() >= ((TcpTransportServer)tc.getServer()).getMaximumConnections()) {
String message = "Exceeded the maximum number of allowed client connections: " + ((TcpTransportServer)tc.getServer()).getMaximumConnections();
answer.add(new HealthStatus("org.apache.activemq.transport.tcp.TcpTransportServer", "ERROR", message, tc.getName()));
} else if(connectionUsage > 90) {
String message = "The Current connection count is within " + connectionUsage + "% of MaximumConnections limit";
answer.add(new HealthStatus("org.apache.activemq.transport.tcp.TcpTransportServer", "WARNING", message, tc.getName()));
}
}
}
}
StringBuilder currentState = new StringBuilder(); StringBuilder currentState = new StringBuilder();
if (answer != null && !answer.isEmpty()) { if (answer != null && !answer.isEmpty()) {
currentState.append("Getting Worried {"); currentState.append("Getting Worried {");