当前位置: 首页 > 知识库问答 >
问题:

使用ActiveMQ的Spring Cloud合约消息验证器

岳玉书
2023-03-14

我整个星期都在玩Spring Cloud合同。我能够使用Spring Cloud Stream创建一个生产者和消费者应用程序来传递消息。

我正在尝试重新设计生产者端,以使用ActiveMQ(带有虚拟主题)。我想我快到了。我已经编写了自己的MessageVerifier,并将其注入到测试的基类中。现在我得到:

测试运行:1,失败:0,错误:1,跳过:0,运行时间:2.535秒

我可以从日志文件中看出测试消息正在发送,我的自定义MessageVeriator正在接收消息。我错过了什么步骤?

如果我这样定义MessageVerifier:

公共类ConsumerMessageVerifier实现MessageVerifier

然后,这就解决了ClassCastException,但会导致其他问题“应用程序无法启动”错误:

描述:html" target="_blank">参数0的方法合同VerifierMessageExchange在org.springframework.cloud.contract.verifier.messaging.integration.合同VerifierIntegrationConfigation需要一个Bean类型的'org.springframework.cloud.contract.verifier.messaging.MessageVerimer'找不到。-Bean方法'合同VerifierMessageExchange'没有加载,因为@条件OnClass没有找到所需的类'org.springframework.amqp.rabbit.core.RabbitTemboard'-Bean方法'合同VerifierMessageExchange'没有加载,因为@条件OnClass没有找到所需的类'org.apache.camel.Message'-Bean方法'合同VerifierMessageExchange'在'合同VerifierIntegrationConfigation'没有加载,因为@条件OnMisSingBean(类型:org.springframework.cloud.contract.verifier.messaging.MessageVerimer; SearchStrategy: all)找到bean'消费者MessageVerimer'-Bean方法'合同VerifierMessageExchange'在'NoOp合同VerifierAutoConfigsion'没有加载,因为@条件OnMisSingBean(类型:org.springframework.cloud.contract.verifier.messaging.MessageVerimer; SearchStrategy: all)找到bean'消费者MessageVerimer'

所以,我不确定这条路是否正确。所以我的问题是:

>

如果是,解决“应用程序无法启动”错误需要哪些步骤?

谢谢!

共有1个答案

益阳平
2023-03-14

需要键入MessageVerifier。您还需要合同验证消息。你可以查看Spring云合同包:org。springframework。云合同验证者。信息。amqp组织。springframework。云合同验证者。信息。流动‌​ org。springframework。云合同验证者。信息。骆驼组织。springframework。云合同验证者。信息。整数‌​对样品进行分类

 类似资料:
  • 线程名称:线程组1-1示例开始时间:2019-09-11 18:52:42英国夏令时加载时间:0连接时间:0延迟时间:0大小以字节为单位:0发送字节:0头大小以字节为单位:0主体大小以字节为单位:0示例计数:1错误计数:1数据类型(“text”“bin”“”):文本响应代码:000响应消息:javax.naming.nameNotFoundException:DynamicQueue/MyQueu

  • SCS English Version 子链是MOAC区块链中非常重要的一个模块。其主要目的在于分流母链中的业务逻辑,把一些比较繁琐的业务操作放在子链中执行。 子链由合约节点(Smart Contract Server - SCS)节点组成,必须部署在母链Vnode上。 子链支持分片,每个分片都能独立完成业务逻辑。 子链中的节点随机组合,支持动态增减。 同时,在主链上,我们增加了代理的Vnode节

  • 本文向大家介绍SpringCloud Bus 消息总线的具体使用,包括了SpringCloud Bus 消息总线的具体使用的使用技巧和注意事项,需要的朋友参考一下 什么是消息总线 1. 概念 在微服务架构中,通常会使用轻量级的消息代理来构建一个共用的消息主题来连接各个微服务实例, 它广播的消息会被所有在注册中心的微服务实例监听和消费,也称消息总线 2. SpringCloud Bus Spring

  • ActiveMQ:5.10.2在ServiceMix的Karaf OSGi中 卡哈布坚持。 默认代理设置。连接中的默认设置(TCP://x.x.x.x.x:61616) 一切正常,但是:如果我将消费者的数量减少到1(或者2或3个,我不知道阈值在哪里),那么来自1个队列的消息将被消耗,来自另一个队列的消息将被存储。过了一段时间,我看到了这张照片: 1用户停止接收消息。他认为没有更多消息了。 从act

  • 问题内容: 大家好 这是我的要求信息: 我尝试验证与body标签相关的。有像和这样的标签,这对我来说真的很混乱。我的问题是如何验证身体部位?首先,我应该获得什么标签来开始验证 要不就 ??? 我必须执行哪些操作(规范化/转换/加密)??? 任何帮助表示赞赏。提前致谢。 问题答案: 解决方案是: 哪里 并向X509KeySelector提供验证签名所需的公钥。

  • 我有一个有必填字段的表单,当我尝试提交有空白必填字段的表单时,屏幕截图中会显示如下所示的错误消息。对于Java中的Selenium,它不可能识别是否显示了错误消息,因为这些错误是HTML5,并且它们不存在于DOM中。于是我谷歌了一下,发现我们可以使用JavaScript。但当我使用它时,我每次都得到假,即使消息显示。您的帮助将不胜感激。 WebElement字段=driver.findElemen