我正在尝试设置一个小POC，它可以演示使用RabbitMQ的Apache Camel可以处理异步处理。这样做的动机是找到一种方法来支持最适合异步处理的长时间运行的任务。routingKey=A") .to("r
浏览 75提问于2020-01-21得票数 2
现在，我们计划使用https连接rabbitmq。我执行了一些步骤，以便通过以下步骤将rabbitmq启用为https现在在我的代码中我们正在使用。但是，如果我想启用对等验证，那么我需要通过KeyManager和信任库。不知道如何传递这些细节。我可以看到文档中说要使用connectionFactory作为
使用自定义RabbitMQ连接工厂。org.apache.camel.NoSuchBeanExceptio
浏览 3提问于2020-01-10得票数 0
回答已采纳
2回答
我试图从一个文件中读取数据，并使用apache camel将其写入一个rabbitmq队列，但最终导致了错误。queue=hello at org.apache.camel.component.rabbitmq</e
浏览 5提问于2016-08-02得票数 2
回答已采纳
我正在使用rabbitmq，可以执行所有必需的功能，如根据绑定进行消息路由。
我从未使用过apache camel，但使用过rabbitmq。我的问题是，camel-rabbitmq提供了哪些单独由rabbitmq提供的附加功能。
浏览 0提问于2015-08-11得票数 2
(RabbitMQEndpoint.java:216) ~[camel-rabbitmq-2.21.1.jar:2.21.1]at org.apache.camel.component.rab
浏览 0提问于2018-05-23得票数 0
回答已采纳
1回答
弹簧关闭信号的处理
、、、、
我有一个spring应用程序，它使用camel来设置从队列中使用的路由。我用rabbitmq做消息代理。现在的问题是，如果rabbitmq代理掉了，连接就不会自动恢复。(Z)V at org.apache</
浏览 4提问于2017-10-04得票数 0
回答已采纳
在org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.declareAndBindQueue(RabbitMQDeclareSupport.java(RabbitMQEndpoint.java:222) ~骆驼-兔-2.17.0.jar:2.17.0在org.apache.camel.component.rabbitmq.RabbitConsumer.openChannel(RabbitConsumer.java:288)
浏览 2提问于2016-04-04得票数 1
1回答
我正在尝试将消息的一部分解析为pojo，这样我就可以在java中处理它。消息包含json，但我只需要它的一部分，所以我尝试使用jsonpath来挑选我需要的那部分json，但是我无法解组，我还找到了一个直接从jsonpath创建pojo的方法，但它返回null。at org.apache.camel.component.rabbitmq.RabbitConsumer.doHandleDelivery(RabbitConsumer.java:107)
atorg.apache.<e
浏览 30提问于2020-07-09得票数 0
2回答
我对RabbitMQ和Apache相当陌生.消息被bing从接口(IMAP等)中取出并发送到队列中进行进一步处理。我很难找到一个解决方案，以避免在RabbitMQ关闭的情况下丢失消息。我使用Spring和camel版本2.25.1。
非常感谢。
浏览 4提问于2020-07-07得票数 0
回答已采纳
1回答
我希望以JSON格式向RabbitMQ发布一条消息，并成功地使用该消息。我试图用骆驼来整合生产者和消费者。然而，我很难理解如何创建一条实现这一目标的途径。我使用JSON来定义生产者和消费者之间的接口。我的应用程序创建JSON，将其转换为byte[]，并使用Camel ProducerTemplate将消息发送到RabbitMQ。在使用者端，需要将byte[]消息转换为字符串，然后转换为JSON，然后封送到对象，以便我可以处理<
浏览 3提问于2015-11-01得票数 0
回答已采纳
3回答
我正在使用Java在Camel中为兔子MQ编写一个简单的示例。: Failed to resolve endpoint: rabbitmq://localhost?java.lang.String.substring(String.java:1937) at org.apache.camel.component.rabbitmq.RabbitMQCompon
浏览 4提问于2014-07-10得票数 1
回答已采纳
我试图理解卡夫卡和骆驼之间的区别。据我理解，Camel将为开发人员提供更多的抽象，而不必担心在某种程度上更改协议/系统。卡夫卡怎么能应付骆驼现在所能做的大部分事情呢？我想我的问题真的可以归结为卡夫卡和骆驼在未来的打样系统上是如何比较的，卡夫卡在哪里比骆驼差呢？我的印象是，卡夫卡并没有像一个系统发展得那么好。编辑:这是严格基于围绕Camel的messages.The文档的，它清楚地表明它是基于企业集成模式的，但是我越深入研究卡夫卡文档，就可以实现相同的模式。我是不是遗漏了什么？
浏览 11提问于2018-01-15得票数 14
回答已采纳
我正在使用camel rabbitmq，出于测试目的，我尝试向队列发送一条消息，我试图在rabbitmq界面中显示该消息，然后再将其读回。
然而，我不能让它工作。我认为有效的是，我在rabbitmq管理界面的exchange选项卡中创建了一个新的exchange。在我的java代码中，我将消息发送到该交换。当我尝试阅读时，我无法阅读并得到以下错误：< in route: Route(route2)[[From[rabbitmq://192.168.59.103:
浏览 2提问于2014-10-20得票数 8
回答已采纳
我的目标是在rabbitmq交换队列和kafka主题之间建立一个连接器。我按照这个指南来设置连接器：https://camel.apache.org/camel-kafka-connector/latest/try-it-out-locally.html。我从源代码https://github.com/apache/camel-kafka-connector下载并安装了连接器，为<
浏览 11提问于2020-09-25得票数 1
回答已采纳
我使用Spring + Apache + Apache开发了一个简单的生产者-消费者应用程序。我已经使用了旧的URI格式(现在不再推荐)，它运行得很好。(RabbitMQEndpoint.java:221) ~[camel-rabbitmq-3.0.0.jar:3.0.0]
at org.apache.camel.component.rabbitmq.RabbitMQConsumer.openConnection(Rabbit
浏览 16提问于2019-12-24得票数 0
回答已采纳
我试图在Spring中使用rabbitMQ中的Camel，方法如下：<?xml version="1.0" encoding="UTF-8"?/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd">
浏览 2提问于2020-10-30得票数 2
回答已采纳
2回答
我正在尝试使用Apache来使用文件，这些文件被推到FTP文件夹中。Camel上下文中到FTP服务器的路由和连接是可以的，但是当文件被推送到FTP文件夹时，我无法获得文件创建事件来处理。下面是我的代码和日志:首先是我的camel pom.xml的一部分(我使用的是camel 3.0.1版本)： <!-- https:/&
浏览 9提问于2020-12-22得票数 0
回答已采纳
我发现对于使用来自多个rabbitmq队列的异步事件并将工作负载分散到内部api而言，Celery将是理想的候选者。
我对Python不是很感兴趣，我的目标是只需要维护配置。
浏览 3提问于2019-06-05得票数 1
云服务器
ICP备案
对象存储
腾讯会议
云直播
腾讯云开发者
