Examples of throwFirstException()

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

62
63
64
65
66
67
68
69
70
71
72
    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()

208
209
210
211
212
213
214
215
216
217
218
        }
        finally {
            ServiceStopper ss = new ServiceStopper();
            ss.stop(localBroker);
            ss.stop(remoteBroker);
            ss.throwFirstException();
        }
    }

    protected void serviceRemoteException(IOException error) {
        log.error("Network connection between " + localBroker + " and " + remoteBroker + " shutdown: " + error.getMessage(), error);
View Full Code Here

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

82
83
84
85
86
87
88
89
90
91
92
        }
        for (Iterator<ProxyConnection> iter = connections.iterator(); iter.hasNext();) {
            LOG.info("Connector stopped: Stopping proxy.");
            ss.stop(iter.next());
        }
        ss.throwFirstException();
        LOG.info("Proxy Connector " + getName() + " Stopped");
    }

    // Properties
    // -------------------------------------------------------------------------
View Full Code Here

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

629
630
631
632
633
634
635
636
637
638
639
                    stopper.onException(hook, e);
                }
            }
        }
       
        stopper.throwFirstException();
    }
   
    public boolean checkQueueSize(String queueName) {
        long count = 0;
        long queueSize = 0;
View Full Code Here

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

103
104
105
106
107
108
109
110
111
        }
        shuttingDown.set(true);
        ServiceStopper ss = new ServiceStopper();
        ss.stop(localTransport);
        ss.stop(remoteTransport);
        ss.throwFirstException();
    }
   
}
View Full Code Here

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

82
83
84
85
86
87
88
89
90
91
92
        }
        for (Iterator iter = connections.iterator(); iter.hasNext();) {
            log.info("Connector stopped: Stopping proxy.");
            ss.stop((Service) iter.next());
        }
        ss.throwFirstException();
        log.info("Proxy Connector " + getName() + " Stopped");
    }
   
    // Properties
    // -------------------------------------------------------------------------
View Full Code Here

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

183
184
185
186
187
188
189
190
191
192
193
    public void stop() throws Exception {
        started = false;
        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()

278
279
280
281
282
283
284
285
286
287
288
        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()

303
304
305
306
307
308
309
310
311
312
313
                    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()

550
551
552
553
554
555
556
557
558
559
560
                } catch (Throwable e) {
                    stopper.onException(hook, e);
                }
            }
        }
        stopper.throwFirstException();
    }
   
        public boolean checkQueueSize(String queueName) {
        long count = 0;
        long queueSize = 0;
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.