Examples of stop()

Examples of org.hornetq.tests.integration.cluster.util.TestableServer.stop()

180
181
182
183
184
185
186
187
188
189
190
         {
            liveServer.stop();
         }
         if (backupServer != null)
         {
            backupServer.stop();
         }
      }

   }
View Full Code Here

Examples of org.hsqldb.Server.stop()

189
190
191
192
193
194
195
196
197
198
199
    for (Future<Integer> result : results) {
      assertEquals(0, (int) result.get());
    }
   
    //stop db
    server.stop();
  }

  public static void main(String[] args) throws Exception {
    // entry point for the multiprocess test
    System.out.println("Starting!");
View Full Code Here

Examples of org.hsqldb.lib.StopWatch.stop()

1831
1832
1833
1834
1835
1836
1837
1838
1839
1840
1841
                dbProps[i] = null;

                continue;
            }

            sw.stop();

            String msg = "Database [index=" + i + ", id=" + id + ", db="
                         + dbType[i] + dbPath[i] + ", alias=" + dbAlias[i]
                         + "] opened sucessfully";
View Full Code Here

Examples of org.hyperic.sigar.CpuTimer.stop()

67
68
69
70
71
72
73
74
75
76
77
            }
        } finally {
            this.shell.setInteractive(isInteractive);
        }

        cpu.stop();
        cpu.list(this.out);
    }

    public static void main(String[] args) throws Exception {
        new Time().processCommand(args);
View Full Code Here

Examples of org.hyperic.sigar.win32.Service.stop()

128
129
130
131
132
133
134
135
136
137
138
            try {
                Service relatedService = new Service(relatedServiceName);
                int relatedServiceStatus = relatedService.getStatus();
                if (!(relatedServiceStatus == Service.SERVICE_STOPPED || relatedServiceStatus == Service.SERVICE_STOP_PENDING)) {
                    log.debug("Stopping Service [" + relatedServiceName + "]");
                    relatedService.stop(this.timeout);
                    log.debug("Service stopped [" + relatedServiceName + "]");
                    relatedService.close();
                }
            } catch (Exception e) {
                log.warn("Unable to stop [" + relatedServiceName + "] from the list [" + services
View Full Code Here

Examples of org.identityconnectors.framework.server.ConnectorServer.stop()

94
95
96
97
98
99
100
101
102
103
    @Override
    public void contextDestroyed(final ServletContextEvent sce) {
        final ConnectorServer _server = (ConnectorServer) sce.getServletContext().getAttribute(SERVER);
        if (_server != null && _server.isStarted()) {
            _server.stop();
        }
        ThreadClassLoaderManager.clearInstance();
    }
}
View Full Code Here

Examples of org.infinispan.Cache.stop()

358
359
360
361
362
363
364
365
366
367
368
         } else {
            entry.getValue().stop();
         }
      }

      if (defaultCache != null) defaultCache.stop();
      globalComponentRegistry.stop();
   }

   public void addListener(Object listener) {
      CacheManagerNotifier notifier = globalComponentRegistry.getComponent(CacheManagerNotifier.class);
View Full Code Here

Examples of org.infinispan.affinity.KeyAffinityService.stop()

127
128
129
130
131
132
133
134
135
136
137
      KeyAffinityService kaf = KeyAffinityServiceFactory.newKeyAffinityService(cache, ex, new ByteKeyGenerator(), 2, true);
      Address address = cache.getAdvancedCache().getRpcManager().getTransport().getAddress();
      byte[] keyBytes = (byte[]) kaf.getKeyForAddress(address);
      String key = ByteKeyGenerator.getStringObject(keyBytes);
      ex.shutdownNow();
      kaf.stop();

      remoteCache.put(key, "v");
      assertOnlyServerHit(getAddress(hotRodServer2));
      TcpTransportFactory tcpTp = (TcpTransportFactory) TestingUtil.extractField(remoteCacheManager, "transportFactory");
View Full Code Here

Examples of org.infinispan.client.hotrod.RemoteCacheManager.stop()

96
97
98
99
100
101
102
103
104
105
106
   @Test(expectedExceptions = UnsupportedOperationException.class)
   public final void getCacheNamesShouldThrowAnUnsupportedOperationException() {
      final RemoteCacheManager nativeCacheManager = new RemoteCacheManager(true);
      final SpringRemoteCacheManager objectUnderTest = new SpringRemoteCacheManager(
               nativeCacheManager);
      nativeCacheManager.stop();

      objectUnderTest.getCacheNames();
   }

   /**
 
View Full Code Here

Examples of org.infinispan.loaders.decorators.AbstractDelegatingStore.stop()

113
114
115
116
117
118
119
120
121
122
123
         }
      } finally {
         for (Iterator<AbstractDelegatingStore> it = stores.values().iterator(); it.hasNext(); ) {
            AbstractDelegatingStore store = it.next();
            try {
               store.stop();
               it.remove();
            } catch (Exception ex) {
               log.error("Failed to stop cache store", ex);
            }
         }
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.