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

Future.rescue介绍

暂无

代码示例

代码示例来源：origin: twitter/distributedlog

bestEffort,
    allowMaxTxID
).rescue(new Function<Throwable, Future<BKLogSegmentWriter>>() {
  @Override
  public Future<BKLogSegmentWriter> apply(Throwable cause) {

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: twitter/distributedlog

}).rescue(new Function<Throwable, Future<byte[]>>() {
 public Future<byte[]> apply(Throwable t) {
  return Future.exception(t);

代码示例来源：origin: pinterest/pinlater

@Override
public Future<Void> deleteQueue(
  RequestContext context, final String name, final String password) {
 return Stats.timeFutureMillis(
   "PinLaterService.deleteQueue",
   backend.deleteQueue(name, password).rescue(new LogAndWrapException<Void>(
     context, "deleteQueue", name)));
}

代码示例来源：origin: pinterest/pinlater

@Override
public Future<Map<String, PinLaterJobInfo>> lookupJobs(RequestContext context,
                            PinLaterLookupJobRequest request) {
 return Stats.timeFutureMillis(
   "PinLaterService.lookupJobs",
   backend.lookupJobs(request).rescue(
     new LogAndWrapException<Map<String, PinLaterJobInfo>>(
       context, "lookupJobs", request.toString())));
}

代码示例来源：origin: pinterest/pinlater

@Override
public Future<Integer> retryFailedJobs(RequestContext context,
                    PinLaterRetryFailedJobsRequest request) {
 return Stats.timeFutureMillis(
   "PinLaterService.retryFailedJobs",
   backend.retryFailedJobs(request).rescue(
     new LogAndWrapException<Integer>(
       context, "retryFailedJobs", request.toString())));
}

代码示例来源：origin: pinterest/pinlater

@Override
public Future<Integer> deleteJobs(RequestContext context, PinLaterDeleteJobsRequest request) {
 return Stats.timeFutureMillis(
   "PinLaterService.deleteJobs",
   backend.deleteJobs(request).rescue(
     new LogAndWrapException<Integer>(
       context, "deleteJobs", request.toString())));
}

代码示例来源：origin: pinterest/pinlater

@Override
public Future<Integer> getJobCount(RequestContext context, PinLaterGetJobCountRequest request) {
 return Stats.timeFutureMillis(
   "PinLaterService.getJobCount",
   backend.getJobCount(request).rescue(
     new LogAndWrapException<Integer>(context, "getJobCount", request.toString())));
}

代码示例来源：origin: pinterest/pinlater

@Override
public Future<PinLaterScanJobsResponse> scanJobs(RequestContext context,
                         PinLaterScanJobsRequest request) {
 return Stats.timeFutureMillis(
   "PinLaterService.scanJobs",
   backend.scanJobs(request).rescue(
     new LogAndWrapException<PinLaterScanJobsResponse>(
       context, "scanJobs", request.toString())));
}

代码示例来源：origin: pinterest/pinlater

@Override
public Future<Void> createQueue(RequestContext context, final String name) {
 if (!validateQueueName(name)) {
  return Future.exception(new PinLaterException(
    ErrorCode.QUEUE_NAME_INVALID, "Invalid queue name: " + name));
 }
 return Stats.timeFutureMillis(
   "PinLaterService.createQueue",
   backend.createQueue(name).rescue(new LogAndWrapException<Void>(
     context, "createQueue", name)));
}