Package org.apache.activemq.broker

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

81
82
83
84
85
86
87
88
89
90
91
            broker.setUseJmx(false);
            broker.setDataDirectory(dataDir);
            broker.addConnector("vm://localhost");
            broker.addConnector("tcp://0.0.0.0:" + mqport);
            broker.setSchedulerSupport(true);
            broker.start();
        }

        EmbeddedServer server = new EmbeddedServer(appPort, appPath);
        server.start();
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
                BrokerService broker = new BrokerService();
                synchronized (this) {                                    
                    broker.setPersistenceAdapter(new MemoryPersistenceAdapter());                   
                    broker.setTmpDataDirectory(new File("./target"));
                    broker.addConnector(brokerUrl);
                    broker.start();
                    Thread.sleep(200);
                    notifyAll();
                }
                synchronized (this) {
                    while (!shutdownBroker) {
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
      try {
      BrokerService broker = new BrokerService();
      broker.setPersistent(false);
      broker.setUseJmx(false);
      broker.addConnector("tcp://localhost:61619");
      broker.start();

      // ActiveMQModuleActivator.startBroker();
      scaDomain = SCADomain.newInstance("helloworldjmsservice.composite");

      try {
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
                        if (brokerFactoryHandler != null) {
                            broker = brokerFactoryHandler.createBroker(brokerURI);
                        } else {
                            broker = BrokerFactory.createBroker(brokerURI);
                        }
                        broker.start();
                    } catch (URISyntaxException e) {
                        throw IOExceptionSupport.create(e);
                    }
                    BROKERS.put(host, broker);
                }
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
    public void testRequestReply() throws Exception {
        BrokerService broker = new BrokerService();
        broker.addConnector("tcp://localhost:61616");
        broker.setPersistent(false);
        broker.setTimeBeforePurgeTempDestinations(1000);
        broker.start();

        DefaultCamelContext context = new DefaultCamelContext();
        JmsComponent jmsComponent = new JmsComponent();

        /**
 
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
         * is invalid now
         */
        Thread.sleep(5000);

        System.in.read();
        broker.start(true);

        /**
         * Before the fix to this issue this call will throw a spring UncategorizedJmsException
         * which contains an InvalidJmsDestination
         */
 
View Full Code Here
326
327
328
329
330
331
332
333
334
335
336
            Map<String, BrokerServiceWrapper> brokerServices = getBrokerServices();
            BrokerService brokerService = brokerServices.get(sBrokerName).getBrokerService();
            if (brokerService.isStarted()) {
                return;
            }
            brokerService.start(true);
            brokerService.waitUntilStarted();
            if (!brokerService.isStarted()) {
                throw new PortletException(getLocalizedString(actionRequest,
                        "jmsmanager.broker.failStartBrokerNoReason", sBrokerName));
            }
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
        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
116
117
118
119
120
121
122
123
124
125
126
        }
       
        BrokerService restartedBroker = createAndConfigureBroker(new URI("broker:(tcp://localhost:61616,stomp://localhost:61613)/BrokerA"));
        bridgeAndConfigureBrokers("BrokerA", "BrokerB");
        bridgeAndConfigureBrokers("BrokerA", "BrokerC");
        restartedBroker.start();
        waitForBridgeFormation();
       
        Thread.sleep(3000);

        assertEquals("Destination", 0, brokers.get("BrokerA").broker.getAdminView().getTemporaryQueues().length);
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
    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();
        }

        Thread.sleep(maxSetupTime);
    }
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.