Examples of throwFirstException()

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

301
302
303
304
305
306
307
308
309
310
311
        for (Iterator<TransportConnection> iter = connections.iterator(); iter.hasNext();) {
            TransportConnection c = iter.next();
            ss.stop(c);
        }
        server = null;
        ss.throwFirstException();
        LOG.info("Connector " + getName() + " Stopped");
    }

    // Implementation methods
    // -------------------------------------------------------------------------
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

342
343
344
345
346
347
348
349
350
351
352
                    // Release the started Latch since another thread could be
                    // stuck waiting for it to start up.
                    startedLatch.countDown();
                    startedLatch.countDown();
                    localStartedLatch.countDown();
                    ss.throwFirstException();
                }
            }
            if (remoteBrokerInfo != null) {
                brokerService.getBroker().removeBroker(null, remoteBrokerInfo);
                brokerService.getBroker().networkBridgeStopped(remoteBrokerInfo);
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

177
178
179
180
181
182
183
184
185
186
187
            remoteBroker.oneway(new ShutdownInfo());
        } finally {
            ServiceStopper ss = new ServiceStopper();
            ss.stop(localBroker);
            ss.stop(remoteBroker);
            ss.throwFirstException();
        }
    }

    public void serviceRemoteException(Throwable error) {
        LOG.info("Unexpected remote exception: " + error);
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

307
308
309
310
311
312
313
314
315
316
317
                    ss.stop(th.transport);
                }
            }

            LOG.debug("Stopped: " + this);
            ss.throwFirstException();
        }
        reconnectTask.shutdown();
    }

  public int getMinAckCount() {
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

230
231
232
233
234
235
236
237
238
239
240
            LOG.debug("Caught exception stopping", e);
        } finally {
            ServiceStopper ss = new ServiceStopper();
            ss.stop(localBroker);
            ss.stop(remoteBroker);
            ss.throwFirstException();
        }
    }
   
    public void stopBeforeConnected()throws Exception{
        masterActive.set(false);
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

209
210
211
212
213
214
215
216
217
218
219
    public void stop() throws Exception {
        started = false;
        this.scheduler.cancel(purgeInactiveDestinationsTask);
        ServiceStopper ss = new ServiceStopper();
        doStop(ss);
        ss.throwFirstException();
        // clear the state
        clientIdSet.clear();
        connections.clear();
        destinations.clear();
        brokerInfos.clear();
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

98
99
100
101
102
103
104
105
106
107
108
                connection = null;
            } catch (JMSException e) {
                stopper.onException(this, e);
            }
        }
        stopper.throwFirstException();
    }

    // Properties
    // -------------------------------------------------------------------------
    public String getBrokerUrl() {
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

291
292
293
294
295
296
297
298
299
300
301
        for (Iterator<TransportConnection> iter = connections.iterator(); iter.hasNext();) {
            TransportConnection c = iter.next();
            ss.stop(c);
        }
        ss.throwFirstException();
        LOG.info("Connector " + getName() + " Stopped");
    }

    // Implementation methods
    // -------------------------------------------------------------------------
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

64
65
66
67
68
69
70
71
72
73
74
    @Override
    public void stop() throws Exception {
        ServiceStopper ss = new ServiceStopper();
        ss.stop(discoveryAgent);
        ss.stop(next);
        ss.throwFirstException();
    }

    public void onServiceAdd(DiscoveryEvent event) {
        String url = event.getServiceName();
        if (url != null) {
View Full Code Here

Examples of org.apache.activemq.util.ServiceStopper.throwFirstException()

415
416
417
418
419
420
421
422
423
424
425
                    // Release the started Latch since another thread could be
                    // stuck waiting for it to start up.
                    startedLatch.countDown();
                    startedLatch.countDown();
                    localStartedLatch.countDown();
                    ss.throwFirstException();
                }
            }
            LOG.info(configuration.getBrokerName() + " bridge to " + remoteBrokerName + " stopped");
            remoteBrokerNameKnownLatch.countDown();
        }
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.