Examples of shutdown()

Examples of org.hornetq.integration.bootstrap.HornetQBootstrapServer.shutDown()

42
43
44
45
46
47
48
49
50
51
52
   public void testRun() throws Exception
   {
      HornetQBootstrapServer bootstrap = new HornetQBootstrapServer(HornetQBootstrapServerTest.beans1);
      bootstrap.run();
      Assert.assertTrue(DummyBean.started);
      bootstrap.shutDown();
      Assert.assertFalse(DummyBean.started);
   }

   public void testRunWithConfig() throws Exception
   {
View Full Code Here

Examples of org.hornetq.rest.queue.QueueConsumer.shutdown()

430
431
432
433
434
435
436
437
438
439
440
            consumer = tmp;
            serviceManager.getTimeoutTask().add(this, subscriptionId);
         }
         else
         {
            tmp.shutdown();
         }
      }
      else
      {
         throw new WebApplicationException(Response.status(405)
View Full Code Here

Examples of org.hsqldb.Server.shutdown()

94
95
96
97
98
99
100
101
102
   */
  public static void stopHsqldb(final Object serverObject) throws Exception {
    if ((serverObject != null) && (serverObject instanceof Server))
    {
      final Server server = (Server)serverObject;
      server.shutdown() ;
    }
  }
}
View Full Code Here

Examples of org.hsqldb.server.Server.shutdown()

31
32
33
34
35
36
37
38
39
40
41
            hsqlServer.setSilent(true);
            hsqlServer.start();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            hsqlServer.shutdown();
        }
    }

    public void connect() {
        String url = "jdbc:hsqldb:mem:ap11";
View Full Code Here

Examples of org.infinispan.config.FluentGlobalConfiguration.shutdown()

60
61
62
63
64
65
66
67
68
69
70
     
      legacy.replicationQueueScheduledExecutor()
         .factory(config.replicationQueueScheduledExecutor().factory().getClass())
         .withProperties(config.replicationQueueScheduledExecutor().properties());
     
      legacy.shutdown().hookBehavior(org.infinispan.config.GlobalConfiguration.ShutdownHookBehavior.valueOf(config.shutdown().hookBehavior().name()));
     
      return legacy.build();
   }

}
View Full Code Here

Examples of org.infinispan.configuration.global.GlobalConfiguration.shutdown()

276
277
278
279
280
281
282
283
284
285
286
      assert gc.transport().clusterName().equals("infinispan-cluster");
      // Should be "Jalapeno" but it's overriden by the test cache manager factory
      assert gc.transport().nodeName().contains("Node");
      assert gc.transport().distributedSyncTimeout() == 50000;

      assert gc.shutdown().hookBehavior().equals(ShutdownHookBehavior.REGISTER);

      assert gc.serialization().marshaller() instanceof VersionAwareMarshaller;
      assert gc.serialization().version() == Version.getVersionShort("1.0");
      final Map<Integer, AdvancedExternalizer<?>> externalizers = gc.serialization().advancedExternalizers();
      assert externalizers.size() == 3;
View Full Code Here

Examples of org.infinispan.configuration.global.GlobalConfigurationBuilder.shutdown()

1618
1619
1620
1621
1622
1623
1624
1625
1626
1627
1628
         ParseUtils.requireNoNamespaceAttribute(reader, i);
         String value = replaceProperties(reader.getAttributeValue(i));
         Attribute attribute = Attribute.forName(reader.getAttributeLocalName(i));
         switch (attribute) {
            case HOOK_BEHAVIOR: {
               builder.shutdown().hookBehavior(ShutdownHookBehavior.valueOf(value));
               break;
            }
            default: {
               throw ParseUtils.unexpectedElement(reader);
            }
View Full Code Here

Examples of org.infinispan.util.concurrent.WithinThreadExecutor.shutdown()

78
79
80
81
82
83
84
85
86
87
88
      DistributedExecutorService des = null;
      try {
         Cache<Object, Object> cache = cacheManager.getCache();

         ExecutorService service = new WithinThreadExecutor();
         service.shutdown();

         des = new DefaultExecutorService(cache, service);
      } finally {
         TestingUtil.killCacheManagers(cacheManager);
      }
View Full Code Here

Examples of org.jacoco.agent.rt.internal.output.FileOutput.shutdown()

53
54
55
56
57
58
59
60
61
62
63
    options.setDestfile(destFile.getAbsolutePath());

    FileOutput controller = new FileOutput();
    controller.startup(options, new RuntimeData());
    controller.writeExecutionData(false);
    controller.shutdown();

    assertTrue("Execution data file should be created", destFile.exists());
    assertTrue("Execution data file should have contents",
        destFile.length() > 0);
  }
View Full Code Here

Examples of org.jacoco.core.runtime.IRuntime.shutdown()

77
78
79
80
81
82
83
84
85
86
87
    final byte[] bytes = new Instrumenter(runtime).instrument(reader);
    final TargetLoader loader = new TargetLoader(target, bytes);
    run(loader.getTargetClass());
    final ExecutionDataStore store = new ExecutionDataStore();
    runtime.collect(store, false);
    runtime.shutdown();
    return store;
  }

  protected abstract void run(final Class<?> targetClass) throws Exception;
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.