Package org.apache.activemq.network

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

56
57
58
59
60
61
62
63
64
65
66
    service.setUseJmx(true);
    NetworkConnector connector = service.addNetworkConnector("multicast://default");
    service.start();
   
    service.removeNetworkConnector(connector);
    connector.stop();
    service.stop();
  }
 
  public void testAddRemoveNetworkWithoutJMX() throws Exception {
    BrokerService service = new BrokerService();
View Full Code Here
68
69
70
71
72
73
74
75
76
    service.setUseJmx(false);
    NetworkConnector connector = service.addNetworkConnector("multicast://default");
    service.start();
   
    service.removeNetworkConnector(connector);
    connector.stop();
    service.stop();
  }
}
View Full Code Here
381
382
383
384
385
386
387
388
389
390
391
                MAX_TEST_TIME, TimeUnit.MILLISECONDS);

        // Restart the network connector and verify that the bridge is
        // re-established. The pause between start/stop is to account for the
        // asynchronous closure.
        nc.stop();
        Thread.sleep(STOP_DELAY);
        nc.start();

        waitForBridge(broker1.getBrokerName(), broker2.getBrokerName(),
                MAX_TEST_TIME, TimeUnit.MILLISECONDS);
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
        service.setUseJmx(true);
        NetworkConnector connector = service.addNetworkConnector("multicast://default?group=group-"+System.currentTimeMillis());
        service.start();

        service.removeNetworkConnector(connector);
        connector.stop();
        service.stop();
    }

    public void testAddRemoveNetworkWithoutJMX() throws Exception {
        BrokerService service = new BrokerService();
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
        service.setUseJmx(false);
        NetworkConnector connector = service.addNetworkConnector("multicast://default?group=group-"+System.currentTimeMillis());
        service.start();

        service.removeNetworkConnector(connector);
        connector.stop();
        service.stop();
    }
   
    public void testSystemUsage()
    {
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
        return brokerService.removeConnector(connector);
    }

    public boolean removeNetworkConnector(String connectorName) throws Exception {
        NetworkConnector connector = brokerService.getNetworkConnectorByName(connectorName);
        connector.stop();
        return brokerService.removeNetworkConnector(connector);
    }

    public void addTopic(String name) throws Exception {
        broker.addDestination(getConnectionContext(broker.getContextBroker()), new ActiveMQTopic(name));
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
        service.setUseJmx(true);
        NetworkConnector connector = service.addNetworkConnector("multicast://default?group=group-"+System.currentTimeMillis());
        service.start();

        service.removeNetworkConnector(connector);
        connector.stop();
        service.stop();
    }

    public void testAddRemoveNetworkWithoutJMX() throws Exception {
        BrokerService service = new BrokerService();
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
        service.setUseJmx(false);
        NetworkConnector connector = service.addNetworkConnector("multicast://default?group=group-"+System.currentTimeMillis());
        service.start();

        service.removeNetworkConnector(connector);
        connector.stop();
        service.stop();
    }
   
    public void testSystemUsage()
    {
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
    public boolean removeNetworkConnector(String connectorName) throws Exception {
        NetworkConnector connector = brokerService.getNetworkConnectorByName(connectorName);
        if (connector == null) {
            throw new NoSuchElementException("Not connector matched the given name: " + connectorName);
        }
        connector.stop();
        return brokerService.removeNetworkConnector(connector);
    }

    public void addTopic(String name) throws Exception {
        safeGetBroker().getContextBroker().addDestination(BrokerSupport.getConnectionContext(safeGetBroker().getContextBroker()), new ActiveMQTopic(name),true);
View Full Code Here
372
373
374
375
376
377
378
379
380
381
382
                MAX_TEST_TIME, TimeUnit.MILLISECONDS);

        // Restart the network connector and verify that the bridge is
        // re-established. The pause between start/stop is to account for the
        // asynchronous closure.
        nc.stop();
        Thread.sleep(STOP_DELAY);
        nc.start();

        waitForBridge(broker1.getBrokerName(), broker2.getBrokerName(),
                MAX_TEST_TIME, TimeUnit.MILLISECONDS);
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.