Package org.apache.activemq.broker

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

58
59
60
61
62
63
64
65
66
67
68
    }
   
    @Test
    public void testMbeanPresenceOnNetworkBrokerRestart() throws Exception {
        BrokerService broker = createBroker();
        broker.start();
        assertEquals(1, countMbeans(broker, "Connector", 30000));
        assertEquals(0, countMbeans(broker, "Connection"));
        BrokerService networkedBroker = null;
        for (int i=0; i<numRestarts; i++) {      
            networkedBroker = createNetworkedBroker();
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
        assertEquals(1, countMbeans(broker, "Connector", 30000));
        assertEquals(0, countMbeans(broker, "Connection"));
        BrokerService networkedBroker = null;
        for (int i=0; i<numRestarts; i++) {      
            networkedBroker = createNetworkedBroker();
            networkedBroker.start();
            assertEquals(1, countMbeans(networkedBroker, "NetworkBridge", 2000));
            assertEquals(1, countMbeans(broker, "NetworkBridge", 2000));
            assertEquals(1, countMbeans(broker, "Connection"));
            networkedBroker.stop();
            networkedBroker.waitUntilStopped();
View Full Code Here
102
103
104
105
106
107
108
109
110
111
   
    protected void createSlave() throws Exception {
      BrokerFactoryBean brokerFactory = new BrokerFactoryBean(new ClassPathResource(getSlaveXml()));
        brokerFactory.afterPropertiesSet();
        BrokerService broker = brokerFactory.getBroker();
        broker.start();
        slave.set(broker);
        slaveStarted.countDown();
    }
}
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    @Test
    public void testMbeanPresenceOnBrokerRestart() throws Exception {
       
        BrokerService networkedBroker = createNetworkedBroker();
        networkedBroker.start();
        assertEquals(1, countMbeans(networkedBroker, "Connector", 30000));
        assertEquals(0, countMbeans(networkedBroker, "Connection"));
       
        BrokerService broker = null;
        for (int i=0; i<numRestarts; i++) {
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
        assertEquals(0, countMbeans(networkedBroker, "Connection"));
       
        BrokerService broker = null;
        for (int i=0; i<numRestarts; i++) {
            broker = createBroker();
            broker.start();
            assertEquals(1, countMbeans(networkedBroker, "NetworkBridge", 5000));
            assertEquals("restart number: " + i, 1, countMbeans(broker, "Connection", 10000));
           
            broker.stop();
            broker.waitUntilStopped();
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
public class MasterSlaveProducerFlowControlTest extends ProducerFlowControlTest {
    static final Logger LOG = LoggerFactory.getLogger(MasterSlaveProducerFlowControlTest.class);
    BrokerService slave;
    protected BrokerService createBroker() throws Exception {
        BrokerService service = super.createBroker();
        service.start();
       
        slave = new BrokerService();
        slave.setBrokerName("Slave");
        slave.setPersistent(false);
        slave.setUseJmx(false);
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
                    // add transport as a service so that it is bound on start, after store started               
                    final TransportConnector tConnector = new TransportConnector();
                    tConnector.setUri(new URI(brokerUrl));
                    broker.addConnector(tConnector);
                   
                    broker.start();
                    slave.set(broker);
                    slaveStarted.countDown();
                } catch (Exception e) {
                    e.printStackTrace();
                }
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
    protected void startAllBrokers() throws Exception {
        Collection<BrokerItem> brokerList = brokers.values();
        for (Iterator<BrokerItem> i = brokerList.iterator(); i.hasNext();) {
            BrokerService broker = i.next().broker;
            broker.start();
            broker.waitUntilStarted();
        }

        Thread.sleep(maxSetupTime);
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
        BrokerService broker = new BrokerService();
        TransportConnector tcp = broker.addConnector("tcp://localhost:0?transport.closeAsync=false");
        String group = "GR-" +  System.currentTimeMillis();
        URI discoveryUri = new URI("multicast://default?group=" + group);
        tcp.setDiscoveryUri(discoveryUri);
        broker.start();
        broker.waitUntilStarted();
       
        Vector<String> existingNames = new Vector<String>();
        Thread[] threads = getThreads();
        for (Thread t : threads) {
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
        BrokerPlugin[] plugins = new BrokerPlugin[1];
        plugins[0] = new StatisticsBrokerPlugin();
        answer.setPlugins(plugins);
        answer.setDeleteAllMessagesOnStartup(true);
        answer.addConnector("tcp://localhost:0");
        answer.start();
        return answer;
    }
   
    protected BrokerService createBroker(String uri) throws Exception {
        LOG.info("Loading broker configuration from the classpath with URI: " + uri);
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.