redis.clients.jedis.Transaction.getPipelinedResponseLength()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(111)

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

Transaction.getPipelinedResponseLength介绍

暂无

代码示例

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

public List<Response<?>> execGetResponse() {
 // Discard QUEUED or ERROR
 client.getMany(getPipelinedResponseLength());
 client.exec();
 inTransaction = false;
 List<Object> unformatted = client.getObjectMultiBulkReply();
 if (unformatted == null) {
  return null;
 }
 List<Response<?>> response = new ArrayList<Response<?>>();
 for (Object o : unformatted) {
  response.add(generateResponse(o));
 }
 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: sohutv/cachecloud

public String discard() {
 client.getMany(getPipelinedResponseLength());
 client.discard();
 inTransaction = false;
 clean();
 return client.getStatusCodeReply();
}

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

public List<Response<?>> execGetResponse() {
 // Discard QUEUED or ERROR
 client.getMany(getPipelinedResponseLength());
 client.exec();
 inTransaction = false;
 List<Object> unformatted = client.getObjectMultiBulkReply();
 if (unformatted == null) {
  return null;
 }
 List<Response<?>> response = new ArrayList<Response<?>>();
 for (Object o : unformatted) {
  response.add(generateResponse(o));
 }
 return response;
}

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

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: apache/servicemix-bundles

public String discard() {
 client.getMany(getPipelinedResponseLength());
 client.discard();
 inTransaction = false;
 clean();
 return client.getStatusCodeReply();
}

相关文章

微信公众号

最新文章

更多

Transaction类方法