High performance Apache 2.0 licensed Message Broker supporting JMS, AMQP, MQTT, and HTTP protocols with comprehensive enterprise features including persistence, security, clustering, and Spring integration.
—
ActiveMQ provides comprehensive JMX-based management interfaces for monitoring broker health, performance, and configuration in production environments.
public interface BrokerViewMBean {
String getBrokerId();
String getBrokerName();
long getTotalEnqueueCount();
long getTotalDequeueCount();
long getTotalConsumerCount();
void gc() throws Exception;
void resetStatistics();
}
public class BrokerView implements BrokerViewMBean {
public String getBrokerVersion();
public boolean isStatisticsEnabled();
public void setStatisticsEnabled(boolean statisticsEnabled);
}public interface QueueViewMBean extends DestinationViewMBean {
long getQueueSize();
void purge() throws Exception;
boolean removeMessage(String messageId) throws Exception;
CompositeData[] browse() throws OpenDataException;
}
public interface TopicViewMBean extends DestinationViewMBean {
int getConsumerCount();
long getEnqueueCount();
long getDequeueCount();
}public interface ConnectionViewMBean {
String getConnectionId();
String getRemoteAddress();
String getUserName();
void stop() throws Exception;
long getEnqueueCount();
long getDequeueCount();
}Install with Tessl CLI
npx tessl i tessl/maven-org-apache-activemq--activemq-all