Package org.apache.activemq.network

Examples of org.apache.activemq.network.NetworkConnector.addStaticallyIncludedDestination()

124
125
126
127
128
129
130
131
132
133
134
    protected void restartBroker(String brokerName) throws Exception {
        destroyBroker("BrokerA");
        BrokerService broker = createBroker(new URI("broker:(tcp://localhost:61616)/BrokerA?persistent=true&useJmx=false"));
        broker.setBrokerId("BrokerA");
        NetworkConnector aTOb = bridgeBrokers(brokers.get("BrokerA").broker, brokers.get("BrokerB").broker, false, 2, true, true);
        aTOb.addStaticallyIncludedDestination(queue);
        broker.start();
        broker.waitUntilStarted();
        waitForBridgeFormation();
    }
View Full Code Here
247
248
249
250
251
252
253
254
255
256
257
    private NetworkConnector bridge(BrokerService from, BrokerService to) throws Exception {
        TransportConnector toConnector = to.getTransportConnectors().get(0);
        NetworkConnector bridge =
                from.addNetworkConnector("static://" + toConnector.getPublishableConnectString());
        bridge.addStaticallyIncludedDestination(sendQ);
        bridge.addStaticallyIncludedDestination(replyQWildcard);
        return bridge;
    }

    private BrokerService configureBroker(String brokerName) throws Exception {
        BrokerService broker = new BrokerService();
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
        }
    }

    protected NetworkConnector bridgeBrokersWithIncludedDestination(String localBrokerName, String remoteBrokerName, ActiveMQDestination included, ActiveMQDestination excluded) throws Exception {
        NetworkConnector nc = bridgeBrokers(localBrokerName, remoteBrokerName, false, 4, true);
        nc.addStaticallyIncludedDestination(included);
        if (excluded != null) {
            nc.addExcludedDestination(excluded);
        }
        nc.setPrefetchSize(1);
        return nc;
View Full Code Here
30
31
32
33
34
35
36
37
38
39
40
        // Setup destination
        ActiveMQDestination dest = createDestination("TEST", false);
        ActiveMQDestination dest1 = createDestination("TEST1", false);

        NetworkConnector bridgeAB =bridgeBrokers("BrokerA", "BrokerB", true);
        bridgeAB.addStaticallyIncludedDestination(dest);
        bridgeAB.setStaticBridge(true);

        startAllBrokers();
        waitForBridgeFormation();
View Full Code Here
489
490
491
492
493
494
495
496
497
498
499
        // Create queue
        ActiveMQDestination dest = createDestination("TEST.FOO", false);

        // statically include our destination
        networkConnector.addStaticallyIncludedDestination(dest);

        // Run brokers
        startAllBrokers();

        waitForBridgeFormation();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.