io.vertx.core.Context.exceptionHandler()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(266)

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

Context.exceptionHandler介绍

暂无

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 public void start() throws Exception {
  context.exceptionHandler(err -> {
   fail("Unexpected exception");
  });
  consumer = eb.<String>consumer(ADDRESS1).handler(msg -> {});
 }
}, onSuccess(deploymentID -> {

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testContextExceptionHandlerFailing() {
 RuntimeException failure = new RuntimeException();
 Context context = vertx.getOrCreateContext();
 AtomicInteger count = new AtomicInteger();
 context.exceptionHandler(err -> {
  if (count.getAndIncrement() == 0) {
   throw new RuntimeException();
  } else {
   assertSame(failure, err);
   testComplete();
  }
 });
 context.runOnContext(v -> {
  throw new RuntimeException();
 });
 context.runOnContext(v -> {
  throw failure;
 });
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testExceptionHandlerOnDeploymentAsyncResultHandlerFailure() {
 RuntimeException failure = new RuntimeException();
 Context ctx = vertx.getOrCreateContext();
 ctx.exceptionHandler(err -> {
  assertSame(failure, err);
  testComplete();
 });
 ctx.runOnContext(v -> {
  vertx.deployVerticle(new AbstractVerticle() {
   @Override
   public void start() throws Exception {
   }
  }, ar -> {
   throw failure;
  });
 });
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testExceptionHandlerOnAsyncDeploymentAsyncResultHandlerFailure() {
 RuntimeException failure = new RuntimeException();
 Context ctx = vertx.getOrCreateContext();
 ctx.exceptionHandler(err -> {
  assertSame(failure, err);
  testComplete();
 });
 ctx.runOnContext(v -> {
  vertx.deployVerticle(new AbstractVerticle() {
   @Override
   public void start(Future<Void> startFuture) throws Exception {
    context.runOnContext(startFuture::complete);
   }
  }, ar -> {
   throw failure;
  });
 });
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testContextExceptionHandler() {
 RuntimeException failure = new RuntimeException();
 Context context = vertx.getOrCreateContext();
 context.exceptionHandler(err -> {
  assertSame(context, Vertx.currentContext());
  assertSame(failure, err);
  testComplete();
 });
 context.runOnContext(v -> {
  throw failure;
 });
 await();
}

代码示例来源：origin: io.vertx/vertx-core

@Override
 public void start() throws Exception {
  context.exceptionHandler(err -> {
   fail("Unexpected exception");
  });
  consumer = eb.<String>consumer(ADDRESS1).handler(msg -> {});
 }
}, onSuccess(deploymentID -> {

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testContextExceptionHandlerFailing() {
 RuntimeException failure = new RuntimeException();
 Context context = vertx.getOrCreateContext();
 AtomicInteger count = new AtomicInteger();
 context.exceptionHandler(err -> {
  if (count.getAndIncrement() == 0) {
   throw new RuntimeException();
  } else {
   assertSame(failure, err);
   testComplete();
  }
 });
 context.runOnContext(v -> {
  throw new RuntimeException();
 });
 context.runOnContext(v -> {
  throw failure;
 });
 await();
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Set an exception handler called when the context runs an action throwing an uncaught throwable.<p/>
 *
 * When this handler is called, {@link io.vertx.rxjava.core.Vertx#currentContext} will return this context.
 * @param handler the exception handler
 * @return a reference to this, so the API can be used fluently
 */
public io.vertx.rxjava.core.Context exceptionHandler(Handler<Throwable> handler) { 
 delegate.exceptionHandler(handler);
 return this;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Set an exception handler called when the context runs an action throwing an uncaught throwable.<p/>
 *
 * When this handler is called, {@link io.vertx.rxjava.core.Vertx#currentContext} will return this context.
 * @param handler the exception handler
 * @return a reference to this, so the API can be used fluently
 */
public io.vertx.rxjava.core.Context exceptionHandler(Handler<Throwable> handler) { 
 delegate.exceptionHandler(handler);
 return this;
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testExceptionHandlerOnAsyncDeploymentAsyncResultHandlerFailure() {
 RuntimeException failure = new RuntimeException();
 Context ctx = vertx.getOrCreateContext();
 ctx.exceptionHandler(err -> {
  assertSame(failure, err);
  testComplete();
 });
 ctx.runOnContext(v -> {
  vertx.deployVerticle(new AbstractVerticle() {
   @Override
   public void start(Future<Void> startFuture) throws Exception {
    context.runOnContext(startFuture::complete);
   }
  }, ar -> {
   throw failure;
  });
 });
 await();
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testExceptionHandlerOnDeploymentAsyncResultHandlerFailure() {
 RuntimeException failure = new RuntimeException();
 Context ctx = vertx.getOrCreateContext();
 ctx.exceptionHandler(err -> {
  assertSame(failure, err);
  testComplete();
 });
 ctx.runOnContext(v -> {
  vertx.deployVerticle(new AbstractVerticle() {
   @Override
   public void start() throws Exception {
   }
  }, ar -> {
   throw failure;
  });
 });
 await();
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testContextExceptionHandler() {
 RuntimeException failure = new RuntimeException();
 Context context = vertx.getOrCreateContext();
 context.exceptionHandler(err -> {
  assertSame(context, Vertx.currentContext());
  assertSame(failure, err);
  testComplete();
 });
 context.runOnContext(v -> {
  throw failure;
 });
 await();
}

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

@Override
public void reportFailure(Throwable cause) {
 Handler<Throwable> exceptionHandler = context.exceptionHandler();
 if (exceptionHandler != null) {
  exceptionHandler.handle(cause);
 }
}

代码示例来源：origin: io.vertx/vertx-mysql-postgresql-client-jasync

static <T> void connectCompletableFutureWithHandler(CompletableFuture<T> future, Vertx vertx, Handler<AsyncResult<T>> handler)
{
 future.whenCompleteAsync((result, error) -> {
  if (error != null) {
   handler.handle(Future.failedFuture(error));
  } else {
   handler.handle(Future.succeededFuture(result));
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
}

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

static <T> void connectCompletableFutureWithHandler(CompletableFuture<T> future, Vertx vertx, Handler<AsyncResult<T>> handler)
{
 future.whenCompleteAsync((result, error) -> {
  if (error != null) {
   handler.handle(Future.failedFuture(error));
  } else {
   handler.handle(Future.succeededFuture(result));
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
}

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

static <T> void connectCompletableFutureWithVoidHandler(CompletableFuture<T> future, Vertx vertx, Handler<AsyncResult<Void>> handler)
{
 future.whenCompleteAsync((ignored, error) -> {
  if (error != null) {
   handler.handle(Future.failedFuture(error));
  } else {
   handler.handle(Future.succeededFuture());
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
}

代码示例来源：origin: io.vertx/vertx-mysql-postgresql-client-jasync

static <T> void connectCompletableFutureWithVoidHandler(CompletableFuture<T> future, Vertx vertx, Handler<AsyncResult<Void>> handler)
{
 future.whenCompleteAsync((ignored, error) -> {
  if (error != null) {
   handler.handle(Future.failedFuture(error));
  } else {
   handler.handle(Future.succeededFuture());
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
}

代码示例来源：origin: io.vertx/vertx-mysql-postgresql-client-jasync

static <T> Future<T> completableFutureToVertx(CompletableFuture<T> future, Vertx vertx) {
 Future<T> fut = Future.future();
 future.whenCompleteAsync((result, error) -> {
  if (error != null) {
   fut.fail(error);
  } else {
   fut.complete(result);
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
 return fut;
}

代码示例来源：origin: io.vertx/vertx-mysql-postgresql-client-jasync

static <T> Future<Void> completableFutureToVertxVoid(CompletableFuture<T> future, Vertx vertx) {
 Future<Void> fut = Future.future();
 future.whenCompleteAsync((ignored, error) -> {
  if (error != null) {
   fut.fail(error);
  } else {
   fut.complete();
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
 return fut;
}

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

static <T> Future<Void> completableFutureToVertxVoid(CompletableFuture<T> future, Vertx vertx) {
 Future<Void> fut = Future.future();
 future.whenCompleteAsync((ignored, error) -> {
  if (error != null) {
   fut.fail(error);
  } else {
   fut.complete();
  }
 }, vertxToExecutor(vertx))
  .exceptionally(error -> {
   Handler<Throwable> exceptionHandler = vertx.getOrCreateContext().exceptionHandler();
   if (exceptionHandler != null) {
    exceptionHandler.handle(error);
   }
   return null;
  });
 return fut;
}

内容来源于网络，如有侵权，请联系作者删除！

Context

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com