Java ReplyFailure类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中io.vertx.core.eventbus.ReplyFailure类的典型用法代码示例。如果您正苦于以下问题：Java ReplyFailure类的具体用法？Java ReplyFailure怎么用？Java ReplyFailure使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ReplyFailure类属于io.vertx.core.eventbus包，在下文中一共展示了ReplyFailure类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: send

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
protected void send(Request request, String target) {
    DeliveryOptions options = new DeliveryOptions().setSendTimeout(request.timeout());

    core.bus().send(target, request.data(), options, send -> {
        if (send.succeeded()) {
            request.write(send.result().body());
        } else {
            Throwable exception = send.cause();

            if (exception instanceof ReplyException) {
                ReplyFailure status = ((ReplyException) exception).failureType();
                exceptionHandlers.get(status).accept(request);
            } else {
                request.error(send.cause());
            }
        }
    });
}

开发者ID:codingchili，项目名称:chili-core，代码行数:19，代码来源:BusRouter.java

示例2: replyJson

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
private static JsonObject replyJson(ReplyException ex) {
  JsonObject jsonObject = new JsonObject();
  DefaultErrorCode errorCode = DefaultErrorCode.getCode(ex.failureCode());
  if (errorCode != null) {
    jsonObject.put("code", errorCode.getNumber())
            .put("message", errorCode.getMessage());
  } else {
    ReplyFailure replyFailure = ex.failureType();
    if (replyFailure == ReplyFailure.NO_HANDLERS) {
      jsonObject.put("code", DefaultErrorCode.SERVICE_UNAVAILABLE.getNumber())
              .put("message", DefaultErrorCode.SERVICE_UNAVAILABLE.getMessage());
    } else if (replyFailure == ReplyFailure.TIMEOUT) {
      jsonObject.put("code", DefaultErrorCode.TIME_OUT.getNumber())
              .put("message", DefaultErrorCode.TIME_OUT.getMessage());
    } else if (replyFailure == ReplyFailure.RECIPIENT_FAILURE) {
      jsonObject.put("code", ex.failureCode())
              .put("message", ex.getMessage());
    } else {
      jsonObject.put("code", DefaultErrorCode.UNKOWN.getNumber())
              .put("message", DefaultErrorCode.UNKOWN.getMessage());
    }
  }
  return jsonObject;
}

开发者ID:edgar615，项目名称:direwolves，代码行数:25，代码来源:FailureHandler.java

示例3: failed

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
private void failed(Future<RpcResponse> completed,
                    Throwable throwable) {
  if (throwable instanceof ReplyException) {
    ReplyException ex = (ReplyException) throwable;
    if (ex.failureType() == ReplyFailure.NO_HANDLERS) {
      SystemException resourceNotFoundEx =
              SystemException.create(DefaultErrorCode.SERVICE_UNAVAILABLE)
                      .set("details", "No handlers");
      completed.fail(resourceNotFoundEx);
    } else {
      ErrorCode errorCode = CustomErrorCode.create(ex.failureCode(), ex.getMessage(), 400);
      SystemException systemException
              = SystemException.create(errorCode);
      completed.fail(systemException);
    }
  } else {
    completed.fail(throwable);
  }
}

开发者ID:edgar615，项目名称:direwolves，代码行数:20，代码来源:EventbusRpcHandler.java

示例4: testCallWithMessageParamWrongType

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testCallWithMessageParamWrongType() {
  JsonObject message = new JsonObject();
  message.put("object", new JsonObject().put("foo", "bar"));
  message.put("str", 76523);
  message.put("i", 1234);
  message.put("char", (int)'X'); // chars are mapped to ints
  message.put("enum", SomeEnum.BAR.toString()); // enums are mapped to strings
  vertx.eventBus().send("someaddress", message, new DeliveryOptions().addHeader("action", "invokeWithMessage").setSendTimeout(500), onFailure(t -> {
    assertTrue(t instanceof ReplyException);
    ReplyException re = (ReplyException) t;
    // This will as operation will fail to be invoked
    assertEquals(ReplyFailure.RECIPIENT_FAILURE, re.failureType());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-service-proxy，代码行数:18，代码来源:ServiceProxyTest.java

示例5: replyFailure

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Override
public void replyFailure(String address, ReplyFailure failure) {
    switch (failure) {
        case TIMEOUT:
            counterService.increment("reply.failures.timeout");
            break;
        case NO_HANDLERS:
            counterService.increment("reply.failures.noHandlers");
            break;
        case RECIPIENT_FAILURE:
            counterService.increment("reply.failures.recipientFailure");
            break;
    }
}

开发者ID:unbroken-dome，项目名称:vertx-spring，代码行数:15，代码来源:VertxActuatorMetrics.java

示例6: shutdownHandler

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
/**
 *  Use to terminate the application using a HTTP Post
 *  It requires an AdminKey header to work
 */
private void shutdownHandler(final RoutingContext ctx) {
	// check for AdminKey header
	String adminKey = this.config().getString("AdminKey");
	if (adminKey == null || adminKey.equals(ctx.request().getHeader("AdminKey"))) {
		// TODO: check the body for the right credentials
		this.shutdownExecution(ctx.response());
	} else {
		ctx.fail(new ReplyException(ReplyFailure.RECIPIENT_FAILURE, 401, "Sucker nice try!"));
	}
}

开发者ID:Stwissel，项目名称:vertx-sfdc-platformevents，代码行数:15，代码来源:ApplicationStarter.java

示例7: createServer

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Before
public void createServer(TestContext testContext) {
  vertx = Vertx.vertx();
  Router router = Router.router(vertx);
  router.route().handler(BodyHandler.create());
  router.route().handler(BaseHandler.create());
  router.get("/ex/sys").handler(rc -> {
    throw SystemException.create(DefaultErrorCode.MISSING_ARGS);
  });
  router.get("/ex/validate").handler(rc -> {
    Multimap<String, String> error = ArrayListMultimap.create();
    throw new ValidationException(error);
  });
  router.get("/ex/unkown").handler(rc -> {
    throw new RuntimeException("xxxx");
  });
  router.get("/ex/reply").handler(rc -> {
    throw new ReplyException(ReplyFailure.TIMEOUT, DefaultErrorCode.INVALID_REQ.getNumber(),
                             DefaultErrorCode.INVALID_REQ.getMessage());
  });

  router.get("/ex/reply2").handler(rc -> {
    throw new ReplyException(ReplyFailure.RECIPIENT_FAILURE);
  });
  router.route().failureHandler(FailureHandler.create());
  vertx.createHttpServer().requestHandler(router::accept)
          .listen(port, testContext.asyncAssertSuccess());
}

开发者ID:edgar615，项目名称:direwolves，代码行数:29，代码来源:FailureHandlerTest.java

示例8: consumerSendTimeout

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
public void consumerSendTimeout(@Observes @VertxConsumer(TEST_BUS_TIMEOUT) VertxEvent event) {
    assertEquals(TEST_BUS_TIMEOUT, event.getAddress());
    event.messageTo(TEST_SLOW_HANDLER).setDeliveryOptions(new DeliveryOptions().setSendTimeout(10)).send("foo", (r) -> {
        if (r.failed()) {
            ReplyException exception = (ReplyException) r.cause();
            if (exception.failureType().equals(ReplyFailure.TIMEOUT)) {
                SYNCHRONIZER.add("timeout");
            }
        }
    });
}

开发者ID:weld，项目名称:weld-vertx，代码行数:12，代码来源:VertxObservers.java

示例9: testThrowableToCodeReplyException

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
/**
 * Test code of {@link ReplyException}
 */
@Test
public void testThrowableToCodeReplyException() {
  int expectedCode = 505;
  
  Throwable throwable = new ReplyException(ReplyFailure.NO_HANDLERS, expectedCode, "Message");
  
  int statusCode = ThrowableHelper.throwableToCode(throwable);
  assertEquals(expectedCode, statusCode);
}

开发者ID:georocket，项目名称:georocket，代码行数:13，代码来源:ThrowableHelperTest.java

示例10: replyFailure

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Override
public void replyFailure(String address, ReplyFailure failure) {
  Map<String, String> labels = new HashMap<>();
  labels.putAll(defaultLabels);
  labels.put(SENSISION_CLASS_EB_LABEL_ADDRESS, address);
  incrementMetric(SENSISION_CLASS_EB_MESSAGE_REPLY_ERROR_COUNT, labels);
}

开发者ID:slambour，项目名称:vertx-warp10-metrics，代码行数:8，代码来源:EventBusMetricsImpl.java

示例11: testEventBusMetricsReplyNoHandlers

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testEventBusMetricsReplyNoHandlers() {
  vertx.eventBus().send("foo", "bar", new DeliveryOptions().setSendTimeout(300), ar -> {
    assertTrue(ar.failed());
    testComplete();
  });

  await();

  JsonObject metrics = metricsService.getMetricsSnapshot(vertx.eventBus());
  assertCount(metrics.getJsonObject("messages.reply-failures"), 1L);
  assertCount(metrics.getJsonObject("messages.reply-failures." + ReplyFailure.NO_HANDLERS), 1L);
}

开发者ID:vert-x3，项目名称:vertx-dropwizard-metrics，代码行数:14，代码来源:MetricsTest.java

示例12: testEventBusMetricsReplyTimeout

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testEventBusMetricsReplyTimeout() {
  vertx.eventBus().consumer("foo").handler(msg -> {});

  vertx.eventBus().send("foo", "bar", new DeliveryOptions().setSendTimeout(300), ar -> {
    assertTrue(ar.failed());
    testComplete();
  });

  await();

  JsonObject metrics = metricsService.getMetricsSnapshot(vertx.eventBus());
  assertCount(metrics.getJsonObject("messages.reply-failures"), 1L);
  assertCount(metrics.getJsonObject("messages.reply-failures." + ReplyFailure.TIMEOUT), 1L);
}

开发者ID:vert-x3，项目名称:vertx-dropwizard-metrics，代码行数:16，代码来源:MetricsTest.java

示例13: testEventBusMetricsReplyRecipientFailure

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testEventBusMetricsReplyRecipientFailure() {
  vertx.eventBus().consumer("foo").handler(msg -> msg.fail(1, "blah"));

  vertx.eventBus().send("foo", "bar", new DeliveryOptions(), ar -> {
    assertTrue(ar.failed());
    testComplete();
  });

  await();

  JsonObject metrics = metricsService.getMetricsSnapshot(vertx.eventBus());
  assertCount(metrics.getJsonObject("messages.reply-failures"), 1L);
  assertCount(metrics.getJsonObject("messages.reply-failures." + ReplyFailure.RECIPIENT_FAILURE), 1L);
}

开发者ID:vert-x3，项目名称:vertx-dropwizard-metrics，代码行数:16，代码来源:MetricsTest.java

示例14: testFailingMethod

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testFailingMethod() {
  proxy.failingMethod(onFailure(t -> {
    assertTrue(t instanceof ReplyException);
    ReplyException re = (ReplyException) t;
    assertEquals(ReplyFailure.RECIPIENT_FAILURE, re.failureType());
    assertEquals("wibble", re.getMessage());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-service-proxy，代码行数:12，代码来源:ServiceProxyTest.java

示例15: testCallWithMessageInvalidAction

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testCallWithMessageInvalidAction() {
  JsonObject message = new JsonObject();
  message.put("object", new JsonObject().put("foo", "bar"));
  message.put("str", "blah");
  message.put("i", 1234);
  vertx.eventBus().send("someaddress", message, new DeliveryOptions().addHeader("action", "yourmum").setSendTimeout(500), onFailure(t -> {
    assertTrue(t instanceof ReplyException);
    ReplyException re = (ReplyException) t;
    // This will as operation will fail to be invoked
    assertEquals(ReplyFailure.RECIPIENT_FAILURE, re.failureType());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-service-proxy，代码行数:16，代码来源:ServiceProxyTest.java

示例16: testConnectionTimeout

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testConnectionTimeout() {

  consumer.unregister();
  long timeoutSeconds = 2;
  consumer = ProxyHelper.registerService(TestService.class, vertx, service, SERVICE_ADDRESS, timeoutSeconds);

  proxy.createConnection("foo", onSuccess(conn -> {
    long start = System.nanoTime();

    conn.startTransaction(onSuccess(res -> {
      assertEquals("foo", res);

      vertx.eventBus().consumer("closeCalled").handler(msg -> {
        assertEquals("blah", msg.body());

        long duration = System.nanoTime() - start;
        assertTrue(String.valueOf(duration), duration >= SECONDS.toNanos(timeoutSeconds));

        // Should be closed now
        conn.startTransaction(onFailure(cause -> {
          assertNotNull(cause);
          assertTrue(cause instanceof ReplyException);
          assertFalse(cause instanceof ServiceException);
          ReplyException re = (ReplyException) cause;
          assertEquals(ReplyFailure.NO_HANDLERS, re.failureType());
          testComplete();
        }));


      });

    }));
  }));

  await();
}

开发者ID:vert-x3，项目名称:vertx-service-proxy，代码行数:38，代码来源:ServiceProxyTest.java

示例17: testConnectionWithCloseFutureTimeout

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testConnectionWithCloseFutureTimeout() {

  consumer.unregister();
  long timeoutSeconds = 2;
  consumer = ProxyHelper.registerService(TestService.class, vertx, service, SERVICE_ADDRESS, timeoutSeconds);

  long start = System.currentTimeMillis();
  proxy.createConnectionWithCloseFuture(onSuccess(conn -> {

    vertx.eventBus().consumer("closeCalled").handler(msg -> {
      assertEquals("blah", msg.body());

      long now = System.currentTimeMillis();
      assertTrue(now - start > timeoutSeconds * 1000);

      // Should be closed now
      conn.someMethod(onFailure(cause -> {
        assertNotNull(cause);
        assertTrue(cause instanceof ReplyException);
        assertFalse(cause instanceof ServiceException);
        ReplyException re = (ReplyException) cause;
        assertEquals(ReplyFailure.NO_HANDLERS, re.failureType());
        testComplete();
      }));
    });
  }));

  await();
}

开发者ID:vert-x3，项目名称:vertx-service-proxy，代码行数:31，代码来源:ServiceProxyTest.java

示例18: testLongDelivery2

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Test
public void testLongDelivery2() {
  TestService proxyLong = TestService.createProxyLongDelivery(vertx, SERVICE_ADDRESS);
  proxyLong.longDeliveryFailed(onFailure(t -> {
    assertNotNull(t);
    assertTrue(t instanceof ReplyException);
    assertFalse(t instanceof ServiceException);
    ReplyException re = (ReplyException) t;
    assertEquals(ReplyFailure.TIMEOUT, re.failureType());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-service-proxy，代码行数:14，代码来源:ServiceProxyTest.java

示例19: replyFailure

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Override
public void replyFailure(String address, ReplyFailure failure) {
    dispatch(m -> m.replyFailure(address, failure));
}

开发者ID:unbroken-dome，项目名称:vertx-spring，代码行数:5，代码来源:DispatchingEventBusMetrics.java

示例20: replyFailure

import io.vertx.core.eventbus.ReplyFailure; //导入依赖的package包/类
@Override
public void replyFailure(@NotNull String address, @NotNull ReplyFailure failure) {
  failures.labels(AddressResolver.instance.apply(address), "reply", failure.name()).inc();
}

开发者ID:nolequen，项目名称:vertx-prometheus-metrics，代码行数:5，代码来源:EventBusPrometheusMetrics.java

注：本文中的io.vertx.core.eventbus.ReplyFailure类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java OFBundleAddMsg类代码示例发布时间：2022-05-22

Java PlatformListFakeActivity类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19221|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9996|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8331|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8700|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8644|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9666|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8630|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：8004|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8664|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7539|2022-11-06

客服电话

电子邮件

Java ReplyFailure类代码示例

示例1: send

示例2: replyJson

示例3: failed

示例4: testCallWithMessageParamWrongType

示例5: replyFailure

示例6: shutdownHandler

示例7: createServer

示例8: consumerSendTimeout

示例9: testThrowableToCodeReplyException

示例10: replyFailure

示例11: testEventBusMetricsReplyNoHandlers

示例12: testEventBusMetricsReplyTimeout

示例13: testEventBusMetricsReplyRecipientFailure

示例14: testFailingMethod

示例15: testCallWithMessageInvalidAction

示例16: testConnectionTimeout

示例17: testConnectionWithCloseFutureTimeout

示例18: testLongDelivery2

示例19: replyFailure

示例20: replyFailure

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

微信小程序如何刷新当前界面

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053