List of throwFirstException() Examples

Examples of throwFirstException()

org.apache.activemq.util.ServiceStopper.throwFirstException()
Throws the first exception that was thrown if there was one.

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


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

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

            LOG.debug("Caught exception stopping", e);
        } 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()

                connection = null;
            } catch (JMSException e) {
                stopper.onException(this, e);
            }
        }
        stopper.throwFirstException();
    }


    // the following methods ensure that we are created on startup and the
    // lifecycles respected
    // TODO there must be a simpler way?

View Full Code Here

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


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

                } catch ( Throwable e ) {
                    stopper.onException(hook, e);
                }
            }
        }
        stopper.throwFirstException();
    }


    /**
     * A helper method to block the caller thread until the broker has been
     * stopped

View Full Code Here

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

                    // 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 (wasDisposedAlready) {
                LOG.debug(configuration.getBrokerName() + " bridge to " + remoteBrokerName + " stopped");
            } else {

View Full Code Here

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


    public void stop() throws Exception {
        started = false;
        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()

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

            }
        }


        MDC.remove("activemq.broker");


        stopper.throwFirstException();
    }


    public boolean checkQueueSize(String queueName) {
        long count = 0;
        long queueSize = 0;

View Full Code Here

0 1 2 3 4 5

TOP

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.