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

Pipeline.append介绍

暂无

代码示例

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

@Override
public Long append(byte[] key, byte[] value) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(value, "Value must not be null!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().append(key, value)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().append(key, value)));
      return null;
    }
    return connection.getJedis().append(key, value);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

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

@Override
Response<Long> execute(Pipeline jedisPipeline) throws DynoException {
  return jedisPipeline.append(key, value);
}

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

@Override
public Response<Long> append(String key, String value) {
 String command = "append";
 return instrumented(command, payloadSize(value), () -> delegated.append(key, value));
}

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

@Override
public Response<Long> append(byte[] key, byte[] value) {
 String command = "append";
 return instrumented(command, payloadSize(value), () -> delegated.append(key, value));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-redis

private void writeUsingAppendCommand(KV<String, String> record, Long expireTime) {
 String key = record.getKey();
 String value = record.getValue();
 pipeline.append(key, value);
 setExpireTimeWhenRequired(key, expireTime);
}

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

@Override
public Long append(byte[] key, byte[] value) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(value, "Value must not be null!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().append(key, value)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().append(key, value)));
      return null;
    }
    return connection.getJedis().append(key, value);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

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

@Override
public Long append(byte[] key, byte[] value) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(value, "Value must not be null!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().append(key, value)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().append(key, value)));
      return null;
    }
    return connection.getJedis().append(key, value);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: gojektech/feast

private Response<?> writeRecord(RedisMutation mutation) {
 switch (mutation.getMethod()) {
  case APPEND:
   return pipeline.append(mutation.getKey(), mutation.getValue());
  case SET:
   return pipeline.set(mutation.getKey(), mutation.getValue());
  case LPUSH:
   return pipeline.lpush(mutation.getKey(), mutation.getValue());
  case RPUSH:
   return pipeline.rpush(mutation.getKey(), mutation.getValue());
  case SADD:
   return pipeline.sadd(mutation.getKey(), mutation.getValue());
  case ZADD:
   return pipeline.zadd(mutation.getKey(), mutation.getScore(), mutation.getValue());
  default:
   throw new UnsupportedOperationException(
     String.format("Not implemented writing records for %s", mutation.getMethod()));
 }
}