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

JedisCommands.rpush介绍

暂无

代码示例

代码示例来源：origin: apache/storm

jedisCommand.rpush(key, value);
break;

代码示例来源：origin: com.netflix.spinnaker.clouddriver/clouddriver-core

public void addResultObjects(List<Object> objects, JedisTask task) {
 String resultId = "taskResult:" + task.getId();
 String[] values = objects.stream()
  .map(o -> {
   try {
    return mapper.writeValueAsString(o);
   } catch (JsonProcessingException e) {
    throw new RuntimeException("Failed to convert object to string", e);
   }
  })
  .collect(Collectors.toList())
  .toArray(new String[objects.size()]);
 log.debug("Adding results to task {} (results: {})", task.getId(), values);
 retry(() -> redisClientDelegate.withCommandsClient(client -> {
  client.rpush(resultId, values);
  client.expire(resultId, TASK_TTL);
 }), format("Adding results to task %s", task.getId()));
}

代码示例来源：origin: vakinge/jeesuite-libs

public boolean rpush(String...strings) {
  try {
    boolean result = getJedisCommands(groupName).rpush(key, strings) == 1;
    //设置超时时间
    if(result)setExpireIfNot(expireTime);
    return result;
  } finally {
    getJedisProvider(groupName).release();
  }
}

代码示例来源：origin: com.netflix.spinnaker.clouddriver/clouddriver-core

public void addToHistory(DefaultTaskStatus status, JedisTask task) {
 String historyId = "taskHistory:" + task.getId();
 Map<String, String> data = new HashMap<>();
 data.put("phase", status.getPhase());
 data.put("status", status.getStatus());
 data.put("state", status.getState().toString());
 String hist;
 try {
  hist = mapper.writeValueAsString(data);
 } catch (JsonProcessingException e) {
  throw new RuntimeException("Failed converting task history to json", e);
 }
 retry(() -> redisClientDelegate.withCommandsClient(client -> {
  client.rpush(historyId, hist);
  client.expire(historyId, TASK_TTL);
  if (status.isCompleted()) {
   client.srem(RUNNING_TASK_KEY, task.getId());
  }
 }), format("Adding status history to task %s: %s", task.getId(), status));
}