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

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

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

        BrokerRegistry.getInstance().unbind(getBrokerName());
        VMTransportFactory.stopped(getBrokerName());
        stopped.set(true);
        stoppedLatch.countDown();
        LOG.info("ActiveMQ JMS Message Broker (" + getBrokerName() + ", " + brokerId + ") stopped");
        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()


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

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


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

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

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

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

                    // 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

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.