or run

npx @tessl/cli init
Log in

Version

Tile

Overview

Evals

Files

Files

docs

connection-pooling.mdembedded-broker.mdindex.mdjms-client.mdmanagement-monitoring.mdmessages-destinations.mdnetwork-clustering.mdpersistence-storage.mdsecurity.mdspring-integration.mdtransport-protocols.md

network-clustering.mddocs/

0

# Network Clustering

1

2

ActiveMQ supports multi-broker networking capabilities for scalable, distributed messaging architectures with automatic discovery and load balancing.

3

4

## Capabilities

5

6

### Network Connectors

7

8

```java { .api }

9

public abstract class NetworkConnector extends DefaultBrokerService implements Service {

10

public void setUri(URI uri);

11

public void setDiscoveryUri(URI discoveryUri);

12

public void setDuplex(boolean duplex);

13

public void setNetworkTTL(int networkTTL);

14

public void start() throws Exception;

15

public void stop() throws Exception;

16

}

17

18

public class DiscoveryNetworkConnector extends NetworkConnector {

19

public void setDiscoveryAgent(DiscoveryAgent discoveryAgent);

20

}

21

```

22

23

### Network Bridges

24

25

```java { .api }

26

public class DemandForwardingBridge implements NetworkBridge {

27

public void setLocalBroker(Broker localBroker);

28

public void setRemoteBroker(Transport remoteBroker);

29

public void start() throws Exception;

30

public void stop() throws Exception;

31

}

32

```

33

34

### Discovery Agents

35

36

```java { .api }

37

public interface DiscoveryAgent extends Service {

38

void setDiscoveryListener(DiscoveryListener listener);

39

void registerService(String name) throws IOException;

40

void serviceFailed(DiscoveryEvent event) throws IOException;

41

}

42

```