apache-camel相关内容
我有一个预先存在的 Web 服务“连接"(SOAP),如果可能,我想在不使用 Swing 框架的情况下调用.我遵循了使用 cxf/wsdl2java 工具生成我的 java 文件的联系优先开发. 我希望从 java 对象中提取用户名和密码,并将其放入 SOAP 对象中,然后发送到我的 localhost Web 服务. 当将 Connect 对象作为主体发送到“direct:start
..
如何使用此路由转储 Apache Camel HTTP 组件发送的 HTTP 正文和标头: 来自('direct:abc').setHeader(Exchange.HTTP_URI, 常量("${config.gnutch.solr.coreUrl}/select")).setHeader(Exchange.HTTP_QUERY, 常量("q=${q}&wt=xml")).setHeader(
..
我花了将近两天的时间来理解 Apache Camel 中的 concurrentConsumers 与线程的概念.但我真的不明白这个概念.谁能帮我理解这个概念.我正在使用骆驼 2.12.0. from("jms:queue:start?concurrentConsumers=5").threads(3, 3, "replyThread").bean(new SomeBean());pom.xm
..
我可以从 Chrome REST 客户端成功访问 Sharepoint 2013 AtomPub 界面,以下 URL 为我提供了我想要的文件: http://ourintranet:100/personal/myname/_vti_bin/cmis/rest/5612e38e-a324-4030-9fee-7d05cd9053a4?getContentStream&objectId=4-512
..
我是 Apache Camel 概念的新手.我尝试使用 apache camel API 编写示例代码尝试运行代码时出现以下异常. 谁能帮我解决这个问题? 这里是示例代码和一个异常, 示例代码: CamelContext context = new DefaultCamelContext();context.addRoutes(new RouteBuilder() {公共无效
..
作为this question的后续,我仍然对如何正确使用CXF-RS有点困惑组件. 当我可以使用 标签非常好. 这是我对 Camel 和 CXF 的配置 XML:
..
我在 Camel 的路径中使用日期: fileName=${date:now:dd-MM-yyyy} 但我现在需要的是 - 1 天.这可能吗? 解决方案 好吧,不直接.简单语言中的 date: 对象只能获取当前时间(或您放置在标头中的某个时间值 - 您可以在 java 或类似语言中执行此操作. 但你也可以这样做.创建一个类: 公共类 YesterdayBean{公共字符串 ge
..
无论我将数据格式放在 XML DSL 蓝图中的哪个位置,我都会在不同的位置开始出现此错误.如果我删除它,它可以工作,但我当然不能将 JSON 转换为 POJO.???任何帮助或告诉我我做错了什么,我错过了什么.谢谢! 错误 无法启动捆绑包 passthrumt1.core/1.0.1.SNAPSHOT 的蓝图容器原因:org.xml.sax.SAXParseException:cvc-co
..
我想要一个像 my.company.bindy 这样的包,其中包含多个类,所有类都使用 Bindy 注释进行注释.然后我想要骆驼路线,可以将 CSV 解组为其中一种类型.我已经完成了所有工作,但是如果我在包中有多个绑定注释类,则解组失败.这是因为 Bindy 试图将 CSV 行解组到包中的每个类中.并且一条特定的行不会正确编组到多个类中.我的数据格式在 Spring 中声明如下:
..
我正在尝试使用骆驼 SQL 组件 (http://camel.apache.org/sql-component.html). 我在 Oracle 数据库中有下表: table EMPLOYEE(NAME varchar(32) ,SURNAME varchar(32) , PIC BLOB ); 以下路线:
..
我正在尝试用 LF 替换输入数据的 CRLF,但这会破坏路线.我的代码如下所示 from(fromEndpoint).convertBodyTo(byte[].class, "iso-8859-1").setBody(simple("body.replaceAll(\r\n, \n)")).... 如果我把 setbody 拿出来,它就完美了.我只想要平台相关的换行符 任何想法我做错了什
..
当客户端应用在 5 秒的时间内发送超过 1000 个请求时,我需要通过整形(排队)入站流量来节流. 我遵循的解决方案是:我有一个骆驼:油门将最大请求设置为 1000,将时间跨度设置为 5 秒.当超过阈值时,我正在捕获节流异常,并且在 onException 块内,我会将节流消息发送到 ActiveMQ 请求队列以供以后进一步处理,因为 Camel 基于 1000 req/5 sec 配置过载
..
我正在尝试使用 Apache Camel 2.14 在 Spring XML 中配置 Apache Camel 路由.路由将涉及 或 /;我对 Camel 的经验还不够丰富,无法知道哪个 EIP 最有用.无论哪种方式,我都需要一个aggregationStrategy.我的最终目标是为希望在 XML 中配置路由的客户创建 Camel
..
我没有看到如何使用 camel-avro 组件生成和使用 kafka avro 消息的示例?目前我的骆驼路线是这样的.为了使用模式注册和其他类似的道具,应该改变它使用camel-kafka-avro consumer &制片人. props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://localhost
..
我正在尝试开发基于内容的路由骆驼应用程序.此应用程序将查看文件夹 src/data 以查看是否存在具有节点 的 SOAP 请求文件,然后将该文件复制到目标/消息中,否则该文件将被复制到目标/其他. 你知道如何使用 xpath(或任何其他工具)来检查这种情况(我更喜欢使用 camel-context.xml 文件)吗? 这是我的骆驼背
..
前言:我对 Camel 还很陌生,在尽可能地消化了 Camel 的实际操作之后,我正在将其调整到我正在进行的项目中.在这个项目中,我们有一些相当复杂的错误处理,我想确保我可以在我们对代码进行骆驼化时复制它. 在我们的项目中(与大多数情况一样),有一组我们想要重试的异常和一组我们不想重试的异常 - 但更具体地说,有一组我们比其他项目更想重试(并非所有可恢复的错误可以同样处理).在这种情况下,我
..
Apache Camel 2.12.1 是否可以将 Camel CSV 组件与 pollEnrich 一起使用?我看到的每个例子都是这样的: from("file:somefile.csv").marshal... 而我正在使用 pollEnrich,例如: pollEnrich("file:somefile.csv", new CSVAggregator()) 所以在 CSVAgg
..
伙计们,我正在使用 Apache Camel 从 mysql 表中读取数据.我在控制台上成功打印了它.但是根据我的要求,我需要从一个mysql数据库中读取数据,然后使用一些条件对其进行过滤,然后将过滤后的数据插入另一个mysql数据库表中.我在下面发布我的代码.. 公共类camelJdbc {公共静态 void main(String[] args) 抛出异常 {最终字符串 url = "jdb
..
我有一个 camel-cxf 网络服务.我用来处理 CXF 的 SOAP 故障拦截器机制中的所有 SOAP 故障.效果很好. 我认为最好在同一层处理Camel层抛出的异常,并编写了一个简单的onException场景如下: onException(Exception.class).to("direct:MyWSExceptionHandler"); 每当抛出自定义异常时,我都期待
..
我无法拆分列表中的 Java 对象.如何将 Body 标记/转换为单个 java 对象?
..