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

Response介绍

暂无

代码示例

代码示例来源：origin: signalapp/Signal-Server

public Optional<ClientContact> get() throws IOException {
 byte[] result = response.get();
 if (result == null) {
  return Optional.empty();
 }
 TokenValue tokenValue = objectMapper.readValue(result, TokenValue.class);
 return Optional.of(new ClientContact(token, tokenValue.relay, tokenValue.voice, tokenValue.video));
}

代码示例来源：origin: sohutv/cachecloud

protected <T> Response<T> getResponse(Builder<T> builder) {
 Response<T> lr = new Response<T>(builder);
 pipelinedResponses.add(lr);
 return lr;
}

代码示例来源：origin: sohutv/cachecloud

@Override
public List<Object> build(Object data) {
 @SuppressWarnings("unchecked")
 List<Object> list = (List<Object>) data;
 List<Object> values = new ArrayList<Object>();
 if (list.size() != responses.size()) {
  throw new JedisDataException("Expected data size " + responses.size() + " but was "
    + list.size());
 }
 for (int i = 0; i < list.size(); i++) {
  Response<?> response = responses.get(i);
  response.set(list.get(i));
  Object builtResponse;
  try {
   builtResponse = response.get();
  } catch (JedisDataException e) {
   builtResponse = e;
  }
  values.add(builtResponse);
 }
 return values;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<Long> del(final String... keys) {
  final Response<Long> response = new Response<Long>(BuilderFactory.LONG);
  long result = 0L;
  for (final String key : keys) {
    result += del(key).get();
  }
  response.set(result);
  return response;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<String> ping() {
  final Response<String> response = new Response<String>(BuilderFactory.STRING);
  response.set(PONG_RESPONSE);
  return response;
}

代码示例来源：origin: sohutv/cachecloud

protected Response<?> generateResponse(Object data) {
 Response<?> response = pipelinedResponses.poll();
 if (response != null) {
  response.set(data);
 }
 return response;
}

代码示例来源：origin: sohutv/cachecloud

public T get() {
 // if response has dependency response and dependency is not built,
 // build it first and no more!!
 if (dependency != null && dependency.set && !dependency.built) {
  dependency.build();
 }
 if (!set) {
  throw new JedisDataException(
    "Please close pipeline or multi block before calling this method.");
 }
 if (!built) {
  build();
 }
 if (exception != null) {
  throw exception;
 }
 return response;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<Long> del(final byte[]... keys) {
  final Response<Long> response = new Response<Long>(BuilderFactory.LONG);
  long result = 0L;
  for (final byte[] key : keys) {
    result += del(key).get();
  }
  response.set(result);
  return response;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<String> flushAll() {
  mockStorage.flushAll();
  final Response<String> response = new Response<String>(BuilderFactory.STRING);
  response.set(OK_RESPONSE);
  return response;
}

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

@Nullable
@Override
@SuppressWarnings("unchecked")
public T get() {
  return (T) getResultHolder().get();
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<String> echo(final String string) {
  final Response<String> response = new Response<String>(BuilderFactory.STRING);
  response.set(echo(string.getBytes(CHARSET)).get());
  return response;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<String> flushDB() {
  mockStorage.flushDB();
  final Response<String> response = new Response<String>(BuilderFactory.STRING);
  response.set(OK_RESPONSE);
  return response;
}

代码示例来源：origin: sohutv/cachecloud

@Override
protected <T> Response<T> getResponse(Builder<T> builder) {
 if (currentMulti != null) {
  super.getResponse(BuilderFactory.STRING); // Expected QUEUED
  Response<T> lr = new Response<T>(builder);
  currentMulti.addResponse(lr);
  return lr;
 } else {
  return super.getResponse(builder);
 }
}

代码示例来源：origin: sohutv/cachecloud

/**
 * Syncronize pipeline by reading all responses. This operation closes the pipeline. Whenever
 * possible try to avoid using this version and use ShardedJedisPipeline.sync() as it won't go
 * through all the responses and generate the right response type (usually it is a waste of time).
 * @return A list of all the responses in the order you executed them.
 */
public List<Object> syncAndReturnAll() {
 List<Object> formatted = new ArrayList<Object>();
 for (Client client : clients) {
  formatted.add(generateResponse(client.getOne()).get());
 }
 return formatted;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<String> select(final int dbIndex) {
  mockStorage.select(dbIndex);
  final Response<String> response = new Response<String>(BuilderFactory.STRING);
  response.set(OK_RESPONSE);
  return response;
}

代码示例来源：origin: sohutv/cachecloud

/**
 * Synchronize pipeline by reading all responses. This operation close the pipeline. Whenever
 * possible try to avoid using this version and use Pipeline.sync() as it won't go through all the
 * responses and generate the right response type (usually it is a waste of time).
 * @return A list of all the responses in the order you executed them.
 */
public List<Object> syncAndReturnAll() {
 if (getPipelinedResponseLength() > 0) {
  List<Object> unformatted = client.getMany(getPipelinedResponseLength());
  List<Object> formatted = new ArrayList<Object>();
  for (Object o : unformatted) {
   try {
    formatted.add(generateResponse(o).get());
   } catch (JedisDataException e) {
    formatted.add(e);
   }
  }
  return formatted;
 } else {
  return java.util.Collections.<Object> emptyList();
 }
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<Boolean> exists(final String key) {
  final Response<Boolean> response = new Response<Boolean>(BuilderFactory.BOOLEAN);
  response.set(mockStorage.exists(DataContainer.from(key)) ? 1L : 0L);
  return response;
}

代码示例来源：origin: sohutv/cachecloud

public List<Object> exec() {
 // Discard QUEUED or ERROR
 client.getMany(getPipelinedResponseLength());
 client.exec();
 inTransaction = false;
 List<Object> unformatted = client.getObjectMultiBulkReply();
 if (unformatted == null) {
  return null;
 }
 List<Object> formatted = new ArrayList<Object>();
 for (Object o : unformatted) {
  try {
   formatted.add(generateResponse(o).get());
  } catch (JedisDataException e) {
   formatted.add(e);
  }
 }
 return formatted;
}

代码示例来源：origin: com.fiftyonred/mock-jedis

@Override
public Response<String> randomKey() {
  final DataContainer result = mockStorage.randomKey();
  final Response<String> response = new Response<String>(BuilderFactory.STRING);
  response.set(result == null ? null : result.getBytes());
  return response;
}

代码示例来源：origin: qiujiayu/AutoLoadCache

private void innerSync(List<Object> formatted) {
  try {
    Response<?> response;
    Object data;
    for (Client client : clients) {
      response = generateResponse(client.getOne());
      if (null != formatted) {
        data = response.get();
        formatted.add(data);
      }
    }
  } catch (JedisRedirectionException jre) {
    throw jre;
  } finally {
    close();
  }
}