在ActiveMQ的配置文件中,使用XML格式声明
并为它们分配一个唯一的名称,并设置persistenceEnabled属性为'true”。
示例代码如下:
或者在代码中使用Java代码来实现,例如:
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
NetworkConnector connector = new DiscoveryNetworkConnector(new URI("static:tcp://remotehost:61616"));
connector.setName("exampleConnector");
connector.setDuplex(true);
connector.setNetworkTTL(5);
connector.setDynamicOnly(true);
connector.setFailover(false);
connector.setDecreaseNetworkConsumerPriority(true);
connector.setSuppressDuplicateQueueSubscriptions(true);
connector.setReconnectDelay(1000);
connector.setMaxReconnectDelay(10000);
connector.setPersistenceEnabled(true);
BrokerService broker = new BrokerService();
broker.addNetworkConnector(connector);
broker.start();
这样即可在重启ActiveMQ之后使连接器仍然存在。