List of watch() Examples

Examples of watch()

akka.actor.Inbox.watch()
akka.testkit.JavaTestKit.watch()
Have the testActor watch someone (i.e. getContext().getWatch(...) ).
akka.testkit.TestProbe.watch()
co.paralleluniverse.actors.Actor.watch()
co.paralleluniverse.actors.LocalActor.watch()
com.adito.agent.client.util.ProcessMonitor.watch()
Watch and wait until the process has completed. Any output from the process will be written to the streams provided and the exit code will be returned when the process terminates. @param out an OutputStream to receive data from the stdout stream @param err an OutputStream to receive data from the stderr stream @return exit code @throws java.lang.InterruptedException
com.atlassian.jira.rest.client.IssueRestClient.watch()
Starts watching selected issue @param watchersUri URI of watchers resource for selected issue. Usually obtained by calling Issue.getWatchers().getSelf() @param progressMonitor progress monitor @throws RestClientException in case of problems (connectivity, malformed messages, invalid argument, etc.)
com.atlassian.jira.rest.client.api.IssueRestClient.watch()
Starts watching selected issue @param watchersUri URI of watchers resource for selected issue. Usually obtained by calling Issue.getWatchers().getSelf() @throws RestClientException in case of problems (connectivity, malformed messages, invalid argument, etc.)
com.gitblit.models.TicketModel.Change.watch()
com.hubspot.singularity.logwatcher.tailer.SingularityLogWatcherTailer.watch()
com.sun.enterprise.deployment.backend.ProcessWatcher.watch()
com.surftools.BeanstalkClient.Client.watch()
The "watch" command adds the named tube to the watch list for the current connection. A reserve command will take a job from any of the tubes in the watch list. For each new connection, the watch list initially consists of one tube, named "default". @param tubeName is a name at most 200 bytes. It specifies a tube to add to the watch list. If the tube doesn't exist, it will be created. @return is the integer number of tubes currently in the watch list.
com.surftools.BeanstalkClientImpl.ClientImpl.watch()
com.twitter.common.zookeeper.ServerSet.watch()
com.twitter.common.zookeeper.ServerSetImpl.watch()
com.vmware.vim.cf.CacheInstance.watch()
Add the managed objects and their properties to be watched. @param mos array of managed objects. @param props array of properties to watch
it.hakvoort.neuroclient.agent.DisplayAgent.watch()
org.apache.blur.zookeeper.WatchChildren.watch()
org.apache.blur.zookeeper.WatchNodeData.watch()
org.apache.blur.zookeeper.WatchNodeExistance.watch()
org.apache.tapestry.annotations.Cached.watch()
org.apache.tapestry5.annotations.Cached.watch()
org.broadinstitute.gatk.utils.threading.ThreadPoolMonitor.watch()
Watch the monitor
org.eclipse.sisu.peaberry.ServiceRegistry.watch()
Watch for services in the registry, constrained by the given filter. @param clazz expected service interface @param filter service attribute filter @param watcher the watcher that should receive any matching services @throws UnsupportedOperationException if watching is not supported
redis.clients.jedis.Jedis.watch()
redis.clients.jedis.Pipeline.watch()
zk.ZkCtl.watch()

Examples of org.apache.blur.zookeeper.WatchChildren.watch()

    String key = cluster + "|" + table;
    if (map.containsKey(key)) {
      return;
    }
    WatchChildren watchForTableLayoutChanges = new WatchChildren(_zookeeper, path);
    watchForTableLayoutChanges.watch(new OnChange() {
      @Override
      public void action(List<String> children) {
        LOG.info("Layout change for cluster [{0}] table [{1}].", cluster, table);
        updateLayout(cluster);
      }

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchChildren.watch()

    }
  }


  private void watchForOnlineShardNodes(final String cluster) {
    WatchChildren watch = new WatchChildren(_zk, ZookeeperPathConstants.getOnlineShardsPath(cluster));
    watch.watch(new OnChange() {
      @Override
      public void action(List<String> children) {
        _onlineShardsNodes.put(cluster, children);
      }
    });

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchChildren.watch()

      for (String cluster : clusters) {
        if (!_tableWatchers.containsKey(cluster)) {
          String tablesPath = ZookeeperPathConstants.getTablesPath(cluster);
          ZkUtils.waitUntilExists(_zk, tablesPath);
          WatchChildren clusterWatcher = new WatchChildren(_zk, tablesPath);
          clusterWatcher.watch(new Tables(cluster));
          _tableWatchers.put(cluster, clusterWatcher);
        }
      }


      List<String> clustersToCloseAndRemove = new ArrayList<String>(clusters);

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeData.watch()


    @Override
    public void action(Stat stat) {
      if (stat != null) {
        WatchNodeData watchNodeData = new WatchNodeData(_zk, ZookeeperPathConstants.getSafemodePath(cluster));
        watchNodeData.watch(new WatchNodeData.OnChange() {
          @Override
          public void action(byte[] data) {
            if (data == null) {
              LOG.debug("Safe mode value for cluster [" + cluster + "] is not set.");
              _safeModeMap.put(cluster, Long.MIN_VALUE);

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeData.watch()

        _tableDescriptorCache.remove(table);
      }
      for (String table : newTables) {
        final String clusterTableKey = getClusterTableKey(_cluster, table);
        WatchNodeData enabledWatcher = new WatchNodeData(_zk, ZookeeperPathConstants.getTablePath(_cluster, table));
        enabledWatcher.watch(new WatchNodeData.OnChange() {
          @Override
          public void action(byte[] data) {
            runActions();
            _tableDescriptorCache.clear();
          }

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeExistance.watch()

    });
  }


  private void watchForLayoutChanges(final String cluster) throws KeeperException, InterruptedException {
    WatchNodeExistance we1 = new WatchNodeExistance(_zookeeper, ZookeeperPathConstants.getTablesPath(cluster));
    we1.watch(new WatchNodeExistance.OnChange() {
      @Override
      public void action(Stat stat) {
        if (stat != null) {
          watch(cluster, ZookeeperPathConstants.getTablesPath(cluster), _watchForTablesPerCluster);
        }

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeExistance.watch()

    if (_watchForTablesPerClusterExistance.putIfAbsent(cluster, we1) != null) {
      we1.close();
    }


    WatchNodeExistance we2 = new WatchNodeExistance(_zookeeper, ZookeeperPathConstants.getTablesPath(cluster));
    we2.watch(new WatchNodeExistance.OnChange() {
      @Override
      public void action(Stat stat) {
        if (stat != null) {
          watch(cluster, ZookeeperPathConstants.getOnlineShardsPath(cluster), _watchForOnlineShardsPerCluster);
        }

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeExistance.watch()

      for (String table : newTables) {
        final String clusterTableKey = getClusterTableKey(cluster, table);


        WatchNodeExistance readOnlyWatcher = new WatchNodeExistance(_zk, ZookeeperPathConstants.getTableReadOnlyPath(
            cluster, table));
        readOnlyWatcher.watch(new WatchNodeExistance.OnChange() {
          @Override
          public void action(Stat stat) {
            if (stat == null) {
              _readOnly.put(clusterTableKey, Boolean.FALSE);
            } else {

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeExistance.watch()

          readOnlyWatcher.close();
        }


        WatchNodeExistance enabledWatcher = new WatchNodeExistance(_zk, ZookeeperPathConstants.getTableEnabledPath(
            cluster, table));
        enabledWatcher.watch(new WatchNodeExistance.OnChange() {
          @Override
          public void action(Stat stat) {
            if (stat == null) {
              _enabled.put(clusterTableKey, Boolean.FALSE);
            } else {

View Full Code Here

Examples of org.apache.blur.zookeeper.WatchNodeExistance.watch()

    });
  }


  private void watchForLayoutChangeEvents(final String cluster) throws KeeperException, InterruptedException {
    WatchNodeExistance we1 = new WatchNodeExistance(_zookeeper, ZookeeperPathConstants.getTablesPath(cluster));
    we1.watch(new WatchNodeExistance.OnChange() {
      @Override
      public void action(Stat stat) {
        if (stat != null) {
          watchTables(cluster, _watchForTablesPerCluster);
        }

View Full Code Here

0 1 2 3 4 5 6

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.