《apache》专题

我用camel定义了一个处理器，它允许我使用计时器生成一个jaxb-javabean，并将pojo写入xml文件。但当我启动应用程序时，我遇到了以下错误： 08:09:00 WARN[or.ap.ca.co.ti.时间消费者]（骆驼（骆驼-1）线程#2-定时器：//生成发票）错误处理交换。交换[20E715FDB7EFE19-0000000000000000]。由：[java.io.IOEx 我的

我已经使用选项在Apache ActiveMQ Artemis中创建了地址和队列。但是，当我检查我的时，我没有找到我使用创建的任何地址和队列，尽管当我启动broker时，我可以在Artemis控制台上看到所有这些地址和队列。现在，我想将相同的配置复制到另一个服务器上，因为有大量的队列，所以很难在另一个服务器上创建所有的队列。是否有任何选项可以转储到并且我可以在另一台服务器上使用它，或者任何其他选项

我使用Camel spring-ws组件通过在路由的“from”部分指定SOAP web服务来公开它。 碰巧的是，在路由逻辑的末尾，Exchange的“out”消息没有填充，但是“in”消息包含所需的响应数据。 如果在生成最终响应时不存在“out”，则生产者组件的默认约定是使用“in”交换消息。 然而，SpringWebservice消费者仅支持最终交换有“out”消息的场景。以下是https:/

我现在已经在camel中做了一些小项目，但有一件事我很难理解，那就是当在camel路线上消费时，如何处理大数据(这不适合内存)。 我有一个包含几GB数据的数据库，我想使用骆驼进行路由。显然，将所有数据读入内存不是一种选择。 如果我是作为一个独立的应用程序这样做的，我会有代码来分页数据并将块发送到我的JMS enpoint。我想使用骆驼，因为它提供了一个很好的模式。如果我从文件中消费，我可以使用流（

这是我的豆子 这是我的路线 您可能会在上面的路由中找到一些语法问题，但它工作正常（此处复制的代码不准确） 想知道，我们可以看到bean正在路由中使用，这是类的一个实例，但是它是如何在路由中调用方法的呢？路由是如何知道调用和打印哪个方法的？

我首先有一个多部分文件，我想把它发送到camel管道，并用原始名称保存这个文件。 我的代码： 另一方面，我有： from（“seda:rest_upload”）.convertBodyTo（File.class）.to（“file://rest_files"); 我也尝试注册转换器： 当我执行我的代码时，我看到下面的stacktrace: 如何解决这个问题？

我有一个ActiveMQ服务器的实例，它运行着几个数据源，如果消息消费失败，它会将数据推送到两个队列中，一个是DLQ。我使用Apache Camel来消费和处理来自这些队列的消息，并想将其写入InfxDB。 然而，到目前为止，我未能让堆栈运行，以使Apache Camel并行消耗所有队列。我总是遇到这种错误: 一个Apache Camel实例如何使用多个队列？ 我尝试了两种方法: 每个路由活动MQ

我有以下Apache Camel FTP文件下载路径： 我将此路由添加到上下文，然后使用ConsumerTemplate请求数据： 当出现连接错误时(例如，未知的主机、无法到达的主机)，我想关闭路由，并在“receiveBody”行后抛出一个异常，在那里我试图读取下载的文件。 我该怎么做呢？ 我为路由尝试了一个onException-handler，在其中添加了一个流程块，并调用了exchange

在本例中，我试图在调用businessLogic之前设置对象依赖关系。我收到一个空指针，因为未设置“使用者”对象。 这里是例子的基础，主要是尝试使用Spring DSL。 http://camel.apache.org/polling-consumer 第节:基于计时器的轮询消费者 这是我的camel/spring配置: 爪哇代码 消费对象的用法有一个空指针。我在想，Spring不仅仅是正确地自动

我正在尝试在AWS EMR 5.11的Spark上安装Apache Hive。ApacheSpark版本-2.2。1 Apache配置单元版本-2.3。2条纱线记录显示以下错误： 18/01/28 21:55:28错误ApplicationMaster:用户类引发异常：java。lang.NoSuchFieldError:SPARK\u RPC\u服务器\u地址java。lang.NoSuchFi

我试图用精度值2来舍入十进制数，但它不起作用。让我知道以下代码中的问题：

我们目前正在使用Apache Camel作为集成框架设置一个Springboot项目。 在路由的最后，我们需要使用WSS websocket协议发送消息，其中我们的应用程序充当客户机，需要将消息发送到公开websocketendpoint的远程服务器。 但是远程服务器首先需要在WSS握手期间进行身份验证。事实上，它需要一些特定的HTTP头，包括头。只有在握手过程中才需要该令牌。打开websocke

嗨，我在FUSE ESB中使用Apache CXFendpoint公开了一个Webservice。客户端需要将用户名作为密码传递，如下所示。请告诉我如何从Camel Exchange对象读取服务器中的内容。

我试图使用开源的apache kafka运行Kafka连接器(不是使用confluent) 这很好，但这种方式只启动Kafka连接工作程序，我如何加载社区连接器？ 我尝试了上面的两个命令，都没有给出错误，但无法加载连接器模块。另一个问题，我键入什么命令来检查连接器的状态？