Package org.apache.activemq.broker

Examples of org.apache.activemq.broker.BrokerService.start()

220
221
222
223
224
225
226
227
228
229
230
        brokerA1 = slave;
        ExecutorService executor = Executors.newCachedThreadPool();
        executor.execute(new Runnable() {
            public void run() {
                try {
                    slave.start();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
    protected BrokerService createBroker(String uri) throws Exception {
        // Start up a broker with a tcp connector.
        BrokerService service = new BrokerService();
        service.setPersistent(false);
        connector = service.addConnector(uri);
        service.start();

        return service;
    }

    protected BrokerService createSslBroker(String uri) throws Exception {
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
    uri = "static:(tcp://localhost:61618)?initialReconnectDelay=100";
    network = broker.addNetworkConnector(uri);
        network.setDynamicOnly(true);
        network.setStaticallyIncludedDestinations(list);
    broker.setUseShutdownHook(false);
    broker.start();
    Thread.sleep(1000 * 3600);
    }

   

View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    protected BrokerService createBrokerA(String uri) throws Exception {
        BrokerService answer = new BrokerService();
        answer.setUseJmx(false);
        configureConsumerBroker(answer, uri);
        answer.start();
        return answer;
    }

    protected void configureConsumerBroker(BrokerService answer, String uri) throws Exception {
        answer.setBrokerName(BROKER_A_NAME);
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
    protected BrokerService createBrokerB(String uri) throws Exception {
        BrokerService answer = new BrokerService();
        answer.setUseJmx(false);
        configureNetwork(answer, uri);
        answer.start();
        return answer;
    }

    protected void configureNetwork(BrokerService answer, String uri) throws Exception {
        answer.setBrokerName(BROKER_B_NAME);
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        broker.setDedicatedTaskRunner(true);
        broker.setPersistent(false);
        broker.addConnector("tcp://localhost:61616");
        NetworkConnector networkConnector = broker.addNetworkConnector("static:(tcp://wrongHostname1:61617,tcp://wrongHostname2:61618)?useExponentialBackOff=false");
        networkConnector.setDuplex(true);
        broker.start();
       
        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(new URI(VM_BROKER_URI));
        Connection connection = cf.createConnection("system", "manager");
        connection.start();
       
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
        broker = new BrokerService();
        broker.setSchedulerSupport(true);
        broker.setDedicatedTaskRunner(true);
        broker.setPersistent(false);
        broker.addConnector("tcp://localhost:61616?wireFormat.maxInactivityDuration=1000&wireFormat.maxInactivityDurationInitalDelay=1000");
        broker.start();

        cf = new ActiveMQConnectionFactory("tcp://localhost:61616?wireFormat.maxInactivityDuration=1000&wireFormat.maxInactivityDurationInitalDelay=1000");
        connection = cf.createConnection("system", "manager");
        connection.start();
        connection.close();
View Full Code Here
172
173
174
175
176
177
178
179
180
181
182
    }

    protected BrokerService createBroker() throws Exception {
        BrokerService answer = new BrokerService();
        configureBroker(answer);
        answer.start();
        return answer;
    }

    protected void configureBroker(BrokerService answer) throws Exception {
        answer.setPersistent(false);
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
        BrokerService brokerA = brokers.get("BrokerA").broker;
        bridgeBroker(brokerA, brokerBUri);
        bridgeBroker(brokerA, brokerCUri);

        LOG.info("starting A, no blocking on failed network connectors");
        brokerA.start();

        LOG.info("starting C transport connector");
        BrokerService brokerC = brokers.get("BrokerC").broker;
        brokerC.addConnector(brokerCUri);
        brokerC.start();
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
        brokerA.start();

        LOG.info("starting C transport connector");
        BrokerService brokerC = brokers.get("BrokerC").broker;
        brokerC.addConnector(brokerCUri);
        brokerC.start();

        assertTrue("got bridge to C", waitForBridgeFormation(brokerA, 1, 1));
        LOG.info("Got bridge A->C");

        LOG.info("starting B transport connector");
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.