Examples of stop()

Examples of org.apache.activemq.apollo.broker.Broker.stop()

62
63
64
65
66
67
68
69
70
71
72
        System.out.println("Stopping the broker.");
       
        //
        // The broker stops asynchronously. The runnable is invoked once
        // the broker if fully stopped.
        broker.stop(new Runnable(){
            public void run() {
                System.out.println("The broker has now stopped.");
            }
        });
       
View Full Code Here

Examples of org.apache.activemq.apollo.transport.Transport.stop()

38
39
40
41
42
43
44
45
46
47
48
  public void autoCreateBroker() throws Exception {
    Transport connect = TransportFactory.connect("vm://test1");
        connect.setDispatchQueue(Dispatch.createQueue());
    connect.start();
    assertNotNull(connect);
    connect.stop();
  }
 
  @Test(expected=IOException.class)
  public void noAutoCreateBroker() throws Exception {
    TransportFactory.connect("vm://test2?create=false");
View Full Code Here

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

114
115
116
117
118
119
120
121
122
123
124
    public synchronized void doStop() throws Exception {
        if (brokerService != null) {
            BrokerService temp = brokerService;
            brokerService = null;
            try {
                temp.stop();
            } catch (JMSException ignored) {
                // just a lame exception ActiveMQ likes to throw on shutdown
                if (!(ignored.getCause() instanceof TransportDisposedIOException)) {
                    throw ignored;
                }
View Full Code Here

Examples of org.apache.activemq.broker.Connection.stop()

265
266
267
268
269
270
271
272
273
274
275
                LOG.warn("Stealing link for clientId {} From Connection {}", clientId, oldContext.getConnection());
                if (connection instanceof TransportConnection) {
                    TransportConnection transportConnection = (TransportConnection) connection;
                    transportConnection.stopAsync();
                } else {
                    connection.stop();
                }
            } else {
                LOG.error("No Connection found for {}", oldContext);
            }
        }
View Full Code Here

Examples of org.apache.activemq.broker.StubConnection.stop()

291
292
293
294
295
296
297
298
299
300
301
        // Close the consumer on the remote broker
        connection2.send(consumerInfo3.createRemoveCommand());
       
        connection1.stop();
        connection2.stop();
    }
   
    protected BrokerService createBroker() throws Exception {
        localBroker = new BrokerService();
        localBroker.setBrokerName("localhost");
View Full Code Here

Examples of org.apache.activemq.broker.TransportConnector.stop()

130
131
132
133
134
135
136
137
138
139
140
    public synchronized void doStop() throws Exception {
        if (transportConnector != null) {
            TransportConnector temp = transportConnector;
            transportConnector = null;
            temp.stop();
        }
    }

    public synchronized void doFail() {
        if (transportConnector != null) {
View Full Code Here

Examples of org.apache.activemq.camel.component.ActiveMQComponent.stop()

352
353
354
355
356
357
358
359
360
361
362
            route.getConsumer().stop();
            route.getEndpoint().stop();
          }

          ActiveMQComponent amqc = (ActiveMQComponent) context.getComponent("activemq");
          amqc.stop();
          amqc.shutdown();

          if (logger == null) {
            System.out.println("Stopping Camel Context");
          } else {
View Full Code Here

Examples of org.apache.activemq.leveldb.replicated.ElectingLevelDBStore.stop()

92
93
94
95
96
97
98
99
100
101
102
                LOG.info("Checking master state");
                assertEquals(expected_list, getMessages(ms));

                // mid way, lets kill the master..
                LOG.info("Killing Master.");
                master.stop();

                // At least one of the remaining stores should complete starting.
                LOG.info("Waiting for slave takeover...");
                f = waitFor(60 * 1000, pending_starts.toArray(new CountDownFuture[pending_starts.size()]));
                assertTrue(f!=null);
View Full Code Here

Examples of org.apache.activemq.leveldb.replicated.MasterLevelDBStore.stop()

81
82
83
84
85
86
87
88
89
90
91
        // Restart and the op should complete.
        slave = createSlave(master, slaveDir);
        slave.start();
        assertTrue(f.await(2, TimeUnit.SECONDS));

        master.stop();
        slave.stop();

    }

    private CountDownFuture asyncAddMessage(final MessageStore ms, final String body) {
View Full Code Here

Examples of org.apache.activemq.leveldb.replicated.SlaveLevelDBStore.stop()

71
72
73
74
75
76
77
78
79
80
81
        CountDownFuture f = asyncAddMessage(ms, "m1");
        assertTrue(f.await(1, TimeUnit.SECONDS));

        // If the slave goes offline, then updates should once again
        // not complete.
        slave.stop();

        f = asyncAddMessage(ms, "m2");
        assertFalse(f.await(2, TimeUnit.SECONDS));

        // Restart and the op should complete.
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.