apache-camel相关内容
当我在应用程序运行时重新启动数据库时,JPA 组件 无法自动重新连接. 2017-02-09 17:45:08,400 错误 o.h.e.j.spi.SqlExceptionHelper(131) - 连接关闭.- [骆驼 (camel-1) 线程 #99 - jpa://com.toto.Toto ] 但仍然我可以在我的 CXF 路由中使用 spring-data 执行 SQL 请求.
..
我是 Camel 的新手,我尝试处理 SQL 数据.如果 SQL 消费(选择)完成,我会尝试更新消费的行,但我只是得到一个“错误的 SQL 语法"异常. 我使用 Apache Camel SQL 组件,其中起始端点是 sql select 语句.要将它们标记为已使用,我使用 SQL-Component 的 onConsume 参数.在select中,v_table是原表t_table的视图,
..
我想知道是否可以将旧版本的 Camel 组件与较新的 Apache Camel 版本的应用程序集成.在我的情况下,我想集成到 Hbase 服务器版本 1.2,它仅受 HBase 客户端 1.2 支持.因此,即使我想使用 3.1 Camel 版本,我也想使用 Camel-HBase 组件的 3.0.1 版本.这是一件好事吗? 或者有什么地方可以看到 Apache Camel 支持的库版本?
..
我正在做 POJO 到 CSV 之间的数据格式转换,反之亦然.在将 CSV 转换为对象文件(解组)时,我遇到了 int 数据类型的非法参数异常.仅用于字符串其工作正常.下面是我的 POJO @CsvRecord(separator="//|",crlf="UNIX",generateHeaderColumns=false)公共类 EmployeeVO 实现 Serializable{私有静态最终
..
我正在开发一个独立的 Apache camel 应用程序(不在 J2EE 容器上运行).此应用程序需要能够在分布式事务中将消息从 IBM MQ 队列管理器路由到 Oracle 数据库.我的谷歌搜索几乎把我带到了几个地方,但没有一个能给我一些关于如何把所有东西放在一起的好线索.下面的这个链接是最接近我需要的,但不幸的是它不够聪明,无法让我走上正确的道路. IBM MQManager 作为 XA
..
我是 Apache Camel 的新手,我一直盯着编写一个从一个数据库中获取数据并将其插入另一个数据库的应用程序.我正在使用 sql 组件,并试图弄清楚如何使用 spring dsl 从消息头中获取 CamelSqlUpdateCount、CamelSqlRowCount 和 CamelSqlQuery. 我知道我可以使用这个来获取数据中的属性......
..
我对这个话题很陌生,需要一些解释...... 我们有一个正在运行的 ActiveMQ-Server,现在应该使用 Apache Camel 路由和处理来增强它.我们的整个配置都是基于 XML 的. 我的第一种方法是在我们的 activemq.xml 末尾做一个普通的 ,但这似乎是错误的路径. 这些是当前的运输连接器:
..
我有两个具有相同消费者的 AMQ 队列.第一个队列 (Q1) 处理 97% 的消息,而另一个 (Q2) 仅处理 3%.问题是 Q2 中的消息需要在消息排队后立即处理.所以我的问题是,当第二季度有消息可用时,我需要以某种方式暂停第一条路线以获取消费者.apache骆驼路由是这样的:
..
我正在尝试以 Java 配置方式在 Spring 中配置 Apache Camel,详见此 示例.但是我被困在依赖步骤,因为 BundleContextAware 和(传递地) BundleContext 无法解析.似乎没有下载必要的传递依赖项.这是我的 pom.xml: 2.9.0
..
我正在尝试使用 Camel FTP Producer 将文件发送到第三方 ftp 服务器(由 Amazon 托管),并且遇到了一个问题,我收到 Writing File failed with: File operation失败... 主机尝试数据连接 xxxx 与服务器 yyyy 不一样 我以前没见过. 生产者被配置为被动模式,根据TRACE级别的日志,这是启用的.(虽然错误消息听起来更像
..
对于多播 + 聚合,我有以下奇怪的(或至少我不清楚)行为.考虑以下路线: from("direct:multicaster").multicast().to(“直接:A",“直接:B").aggregationStrategy(new AggregationStrategy() {@覆盖公共交换聚合(交换旧交换,交换新交换){if (oldExchange == null) {列出 first
..
Camel-Redis 的序列化程序为消息键添加了额外字符的前缀. 当我检查数据库时,消息键显示类似.. "\xac\xed\x00\x05t\x00\x11test150827171118" 如你所见,字符串 "\xac\xed\x00\x05t\x00\x11" 为键 "test150827171118" 加上前缀. 我尝试了两种模式, 首先,我直接在注册表中设置了
..
我正在为我的应用程序使用 Spring.我想知道“嵌入式"ActiveMQ 和“独立"ActiveMQ 之间有什么区别.如果我运行 ActiveMQ 嵌入式,这是否意味着远程客户端仍然可以连接?我的理解是否正确,嵌入的 ActiveMQ 意味着 ActiveMQ 将在我启动 Spring 应用程序时自动启动,还是有其他含义? 例如,假设我在系统 A 中部署了一个应用程序,并在系统 B 中部署
..
我正在使用 Camel 的 spring DSL 来构建路由,并且我正在使用我的 POJO bean 作为处理器. 最初,我在做: 其中,“myPojoBeanProcessor"在我的 spring 上下文中被定义为一个 bean. 然后,我切换到:
..
在一个干净的 Camel 项目中,我添加了以下依赖项: org.apache.camelcamel-jsonpath2.16.1 当我运行项目时,出现以下错误.如果我删除该依赖项,它将起作用.我在两个不同的项目上试过这个,同样的事情发生了.为了使 jsonpath 工作,还必须将
..
升级到 apache camel-cxf 到 2.15.2 和 cxf 3.0.4 后,我在启动我的骆驼路由时遇到了以下问题. 该路由与支付网关进行肥皂集成. 有没有人找到解决方法? 请参阅下面的堆栈跟踪. 引起:javax.ejb.EJBException:org.apache.camel.FailedToCreateProducerException:创建失败端点生产者
..
我想在 Camel Exchange 上设置一个属性,然后在保存文件时使用该属性.在我的骆驼 dsl 中,我有以下内容: .process(processorToSetExhangeProperty)//设置属性 在交易所.to("file:/tmp?fileName=file-" + property("uid") + ".xml") 文件被保存为: "file-property
..
我想将一个 Json 解组为一个 Map/List of Strings(例如 Map>...) 这是我的输入: {"pointsOfSale":{“销售点":[{"href":"\/pointsOfSale\/UUID.0abc2aca-7930-4c9e-9f38-8af3d0692e04","模型":{"href":"\/models\/modelePointOfSale","mod
..
假设我有一个简单的 json 文件,如下所示 {“日志": {“主持人":“等等",“严重性":“信息",“系统":“1"}} 我正在使用 Apache Camel,它是 Spring XML 来处理和路由 json 文件.我的路由代码如下所示: $.log?(@.seve
..
我们有一个 Apache Camel (2.13.2) 应用程序,它使用 http4 与网络服务器通信,使用 NTLM 进行身份验证. 端点定义为(伪): ....to("http4://thegreat.server.com/uri?authUsername=" + user + "&authPassword=" + pass+ "&authenticationPreemptive=tr
..