本文整理了Java中redis.clients.jedis.Pipeline.watch()方法的一些代码示例，展示了Pipeline.watch()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Pipeline.watch()方法的具体详情如下：
包路径：redis.clients.jedis.Pipeline
类名称：Pipeline
方法名：watch

Pipeline.watch介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-data-redis

@Override
public void watch(byte[]... keys) {
  if (isQueueing()) {
    throw new UnsupportedOperationException();
  }
  try {
    for (byte[] key : keys) {
      if (isPipelined()) {
        pipeline(newStatusResult(getRequiredPipeline().watch(key)));
      } else {
        jedis.watch(key);
      }
    }
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: com.netflix.spinnaker.kork/kork-jedis

@Override
public Response<String> watch(byte[]... keys) {
 String command = "watch";
 return instrumented(command, () -> delegated.watch(keys));
}

代码示例来源：origin: com.netflix.spinnaker.kork/kork-jedis

@Override
public Response<String> watch(String... keys) {
 String command = "watch";
 return instrumented(command, () -> delegated.watch(keys));
}

代码示例来源：origin: Baqend/Orestes-Bloomfilter

@SuppressWarnings("unchecked")
public <T> List<T> transactionallyDo(Consumer<Pipeline> f, String... watch) {
  return (List<T>) safelyReturn(jedis -> {
    Pipeline p = jedis.pipelined();
    if (watch.length != 0) {
      p.watch(watch);
    }
    p.multi();
    f.accept(p);
    Response<List<Object>> exec = p.exec();
    p.sync();
    return exec.get();
  });
}

代码示例来源：origin: org.springframework.data/spring-data-redis

@Override
public void watch(byte[]... keys) {
  if (isQueueing()) {
    throw new UnsupportedOperationException();
  }
  try {
    for (byte[] key : keys) {
      if (isPipelined()) {
        pipeline(newStatusResult(getRequiredPipeline().watch(key)));
      } else {
        jedis.watch(key);
      }
    }
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void watch(byte[]... keys) {
  if (isQueueing()) {
    throw new UnsupportedOperationException();
  }
  try {
    for (byte[] key : keys) {
      if (isPipelined()) {
        pipeline(newStatusResult(getRequiredPipeline().watch(key)));
      } else {
        jedis.watch(key);
      }
    }
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: Baqend/Orestes-Bloomfilter

pipe.watch("myKey");
pipe.multi();
pipe.set("myKey", "myVal");