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 supports multi-broker networking capabilities for scalable, distributed messaging architectures with automatic discovery and load balancing.
public abstract class NetworkConnector extends DefaultBrokerService implements Service {
public void setUri(URI uri);
public void setDiscoveryUri(URI discoveryUri);
public void setDuplex(boolean duplex);
public void setNetworkTTL(int networkTTL);
public void start() throws Exception;
public void stop() throws Exception;
}
public class DiscoveryNetworkConnector extends NetworkConnector {
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent);
}public class DemandForwardingBridge implements NetworkBridge {
public void setLocalBroker(Broker localBroker);
public void setRemoteBroker(Transport remoteBroker);
public void start() throws Exception;
public void stop() throws Exception;
}public interface DiscoveryAgent extends Service {
void setDiscoveryListener(DiscoveryListener listener);
void registerService(String name) throws IOException;
void serviceFailed(DiscoveryEvent event) throws IOException;
}Install with Tessl CLI
npx tessl i tessl/maven-org-apache-activemq--activemq-all