source: branches/objectmq_old/test/stopBroker/BrokerKillerImpl.java

package stopBroker;

import omq.client.annotation.AsyncMethod;
import omq.common.broker.Broker;
import omq.server.RemoteObject;

public class BrokerKillerImpl extends RemoteObject implements BrokerKiller {

        /**
         * 
         */
        private static final long serialVersionUID = 1L;

        @Override
        @AsyncMethod
        public void killServerBroker() throws Exception {
                System.out.println("Kill broker");

                // A remote method cannot stop the Broker because the stop method is
                // thought to wait for the methods finish before it stops. For this
                // reason it actually cannot stop itself
                new Thread() {
                        public void run() {
                                try {
                                        Thread.sleep(1000);
                                        Broker.stopBroker();
                                } catch (Exception e) {
                                        e.printStackTrace();
                                }
                        };
                }.start();

        }

}