Examples of quiesce()


Examples of com.sun.messaging.jmq.jmsserver.BrokerStateHandler.quiesce()

            logger.log(Logger.ERROR, this.getClass().getName() + ": " + errMsg);
  } else  {
        try {
            BrokerStateHandler bsh = Globals.getBrokerStateHandler();
            bsh.quiesce();
        } catch (Exception ex) {
            errMsg = ex.toString();
            status = Status.ERROR;
        }
        }
View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.BrokerStateHandler.quiesce()

  BrokerStateHandler bsh = Globals.getBrokerStateHandler();

  logger.log(Logger.INFO, "Quiesce request received by MBean " + getMBeanName());

  try  {
      bsh.quiesce();
  } catch (BrokerException e)  {
      handleOperationException(BrokerOperations.QUIESCE, e);
  }
    }
View Full Code Here

Examples of org.apache.aries.quiesce.manager.QuiesceManager.quiesce()

    //participant
   
    QuiesceManager quiesceMgr = getOsgiService(QuiesceManager.class);
    List<Bundle> bundleList = new ArrayList<Bundle>();
    bundleList.add(bapi);
    quiesceMgr.quiesce(500,bundleList);
    Thread.sleep(1000);
   
    //blog api bundle should now be stopped, but others should still be running
    assertTrue("Blog api bundle should have been quiesced, but it's state is "+bapi.getState(), bapi.getState() != bapi.ACTIVE);
  assertEquals(bweb.ACTIVE, bweb.getState());
View Full Code Here

Examples of org.apache.aries.quiesce.manager.QuiesceManager.quiesce()

 
  bundleList.add(bweb);
  bundleList.add(bbiz);
  bundleList.add(bper);
 
  quiesceMgr.quiesce(500,bundleList);
    Thread.sleep(1000);
   
    //all blog bundles should now be stopped
    assertTrue("Blog api bundle should have been quiesced, but it's state is "+bapi.getState(), bapi.getState() != bapi.ACTIVE);
    assertTrue("Blog web bundle should have been quiesced, but it's state is "+bweb.getState(), bweb.getState() != bweb.ACTIVE);
View Full Code Here

Examples of org.apache.aries.quiesce.manager.QuiesceManager.quiesce()

    //participant
   
    QuiesceManager quiesceMgr = getOsgiService(QuiesceManager.class);
    List<Bundle> bundleList = new ArrayList<Bundle>();
    bundleList.add(bapi);
    quiesceMgr.quiesce(500,bundleList);
    Thread.sleep(1000);
   
    //blog api bundle should now be stopped, but others should still be running
    assertTrue("Blog api bundle should have been quiesced, but it's state is "+bapi.getState(), bapi.getState() != bapi.ACTIVE);
  assertEquals(bweb.ACTIVE, bweb.getState());
View Full Code Here

Examples of org.apache.aries.quiesce.manager.QuiesceManager.quiesce()

 
  bundleList.add(bweb);
  bundleList.add(bbiz);
  bundleList.add(bper);
 
  quiesceMgr.quiesce(500,bundleList);
    Thread.sleep(1000);
   
    //all blog bundles should now be stopped
    assertTrue("Blog api bundle should have been quiesced, but it's state is "+bapi.getState(), bapi.getState() != bapi.ACTIVE);
    assertTrue("Blog web bundle should have been quiesced, but it's state is "+bweb.getState(), bweb.getState() != bweb.ACTIVE);
View Full Code Here

Examples of org.apache.aries.quiesce.participant.QuiesceParticipant.quiesce()

      Thread t = new Thread(new TestBeanClient((TestBean)obj, 2000));
      t.start();

      System.out.println("Thread Started");
     
      participant.quiesce(callback, bundles);
     
      System.out.println("Called Quiesce");
     
      Thread.sleep(1000);
     
View Full Code Here

Examples of org.apache.aries.quiesce.participant.QuiesceParticipant.quiesce()

          assertNotNull(bundleb);
          bundleb.start();
         
          Helper.getBlueprintContainerForBundle(context(), "org.apache.aries.blueprint.testbundleb");
         
      participant.quiesce(callbackB, Collections.singletonList(getBundle(
        "org.apache.aries.blueprint.testbundleb")));
     
        System.out.println("Called Quiesce");
       
        Thread.sleep(200);
View Full Code Here

Examples of org.apache.aries.quiesce.participant.QuiesceParticipant.quiesce()

        Assert.assertTrue("Quiesce callback B should have occurred; calls should be 1, but it is "+callbackB.getCalls(), callbackB.getCalls()==1);
        Assert.assertTrue("Quiesce callback A should not have occurred yet; calls should be 0, but it is "+callbackA.getCalls(), callbackA.getCalls()==0);
       
        bundleb.stop();
       
        participant.quiesce(callbackA, Collections.singletonList(getBundle(
      "org.apache.aries.blueprint.testbundlea")));
           
        Thread.sleep(1000);
       
        System.out.println("After second sleep");
View Full Code Here

Examples of org.apache.aries.quiesce.participant.QuiesceParticipant.quiesce()

       
        Thread t = new Thread(new TestBeanClient((TestBean)obj, 1500));
        t.start();
        Thread.sleep(200);
         
        participant.quiesce(callback, bundles);
     
        System.out.println("Called Quiesce");
       
        Thread.sleep(500);
       
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.