Examples of throwFirstException()

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()

282
283
284
285
286
287
288
289
290
291
292
        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()

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()

185
186
187
188
189
190
191
192
193
194
195
    public void stop() throws Exception {
        stopped = true;
        ServiceStopper ss = new ServiceStopper();
        doStop(ss);
        ss.throwFirstException();
    }
   
    public PolicyMap getDestinationPolicy(){
        return brokerService != null ? brokerService.getDestinationPolicy() : null;
    }
View Full Code Here

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

305
306
307
308
309
310
311
312
313
314
315
        log.debug("Caught exception stopping", e);
      } finally {
        ServiceStopper ss = new ServiceStopper();
        ss.stop(localBroker);
        ss.stop(remoteBroker);
        ss.throwFirstException();
      }
    }
        log.debug(localBrokerName+ " bridge to " + remoteBrokerName + " stopped");
    }
   
View Full Code Here

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

207
208
209
210
211
212
213
214
215
216
217
    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()

293
294
295
296
297
298
299
300
301
302
303
                  ss.stop(th.transport);
                }
            }
           
            log.debug("Stopped: "+this);
            ss.throwFirstException();
        }
        reconnectTask.shutdown();
    }

    public long getInitialReconnectDelay() {
View Full Code Here

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

246
247
248
249
250
251
252
253
254
255
256
       
        for (Iterator iter = connections.iterator(); iter.hasNext();) {
            TransportConnection c = (TransportConnection) 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()

173
174
175
176
177
178
179
180
181
182
183
            remoteBroker.oneway(new ShutdownInfo());
        } finally {
            ServiceStopper ss = new ServiceStopper();
            ss.stop(localBroker);
            ss.stop(remoteBroker);
            ss.throwFirstException();
        }
    }
   
    protected void serviceRemoteException(IOException error) {
        log.info("Unexpected remote exception: "+error);
View Full Code Here

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

465
466
467
468
469
470
471
472
473
474
475
            stopper.stop(getManagementContext());
        }

        log.info("ActiveMQ JMS Message Broker (" + getBrokerName()+", "+brokerId+") stopped");

        stopper.throwFirstException();
    }

  protected void stopAllConnectors(ServiceStopper stopper) {
   
    for (Iterator iter = getNetworkConnectors().iterator(); iter.hasNext();) {
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.