apache-camel相关内容
我正在尝试通过 Camel Route 将消息放在 Weblogic JMS 中的队列上. 我的目标是最终配置一个 Route 来使用 jms 队列中的消息,我将来自早期 Route 的数据发布到该队列. 这是我的配置:
..
我正在尝试从 ftp 服务器获取具有 .zip 压缩的单个文件,并尝试使用骆驼使用 .gzip 压缩将其存储在 S3 中.以下是我目前的路线. from("sftp://username@host/file_path/?password=&noop=true&streamDownload=true").routeId("route_id").setExchangePatter
..
我目前有一个 SOAP Web 服务,我正在尝试访问它的端点,但我不断收到此错误: soap:服务器没有这样的操作:(HTTP GET PATH_INFO:/camel-exam
..
我正在使用 Camel Proxy 公开一个接口作为起点一条路线.它使用 BeanInvocation 对象作为消息体.如何根据传递给接口的参数设置消息正文和标头? 公共接口测试{公共无效sayHi(字符串名字,字符串姓氏);} 我想制作身体 (firstName + " " + lastName).我还想知道如何将一个参数设置为消息的标头,将另一个参数设置为正文. 解决方案 它使用与
..
..
我浏览了 Apache camel 网站和 camel in action 上的示例,它们都非常关注公开 Web 服务.我在网上找到的唯一示例不起作用. 我正在尝试访问第三方网络服务 wsdl - http://www.webservicex.net/CurrencyConvertor.asmx?WSDL 此服务具有计算货币汇率的操作/方法.操作名称为“ConversionRate".
..
我正在尝试在 osgi 环境 (karaf) 上运行的 apache camel 中发送一个肥皂请求.直到现在我得到了这个代码 public void start(BundleContext context) 抛出异常 {LOGGER.log(Level.INFO, "开始");MyRouteBuilder routeBuilder = new MyRouteBuilder();camelCon
..
我有一个使用 JNDI 和 Spring 的 Camel Context 的良好工作 XML 配置 后来 Solace.JndiObjectFactoryBean 被用作 connectionFactory
..
我正在尝试使用 fuse esb + apache camel + seda/activemq 公开 Web 服务,但在将状态消息返回给 Web 服务调用时遇到了问题. 这是我的简单骆驼路线:
..
我遇到了一个问题,即执行器探测对于 JMS 运行状况失败,即使我的路由可以连接并生成到 JMS 的消息.所以简而言之,Actuator 说它已关闭但它正在工作. 技术栈和技术说明: 春季启动:2.3.1.RELEASE 骆驼:3.4.1 阿尔忒弥斯:2.11.0 Artemis 已设置为使用用户名和密码 (artemis/artemis). 使用 org.apache.acti
..
我有一个骆驼'seda'路线,大致包含代码: JaxbDataFormat jaxb = new JaxbDataFormat(false);jaxb.setContextPath("com.example.data.api");从(“seda:验证").marshal(jaxb).to("spring-ws:" + getDataServiceURL()).unmarshal(jaxb) 我
..
我试图在构成通过 Camel 路由传输的消息的 Java bean 的主体上设置一个属性.我尝试了各种方法,例如 .....${body.label} = ${property.label}..... 在这种特殊情况下,${body} 是一个具有 setLabel(String label) 方法和 ${proper
..
所以下面我有 Camel(通过 Spring DSL)成功地将我的 bean 与 ActiveMQ 队列集成:
..
我有一个实现 Camel 和 ActiveMQ 的系统,用于在一些服务器之间进行通信.我想知道是否有办法在 X 段时间后自动过期并清除发送到队列的消息.由于原始服务器(填充队列)不知道是否有人在接收消息,所以我不希望我的队列增长到太大以至于崩溃.Bonus karma 指向可以提供帮助并提供 java dsl 方式来实现此功能的人. 解决方案 //2 分钟后过期消息长 ttl = Sy
..
我在骆驼路线上遇到了异常 原因:com.fasterxml.jackson.databind.JsonMappingException:没有为类 org.apache.camel.converter.stream.InputStreamCache 找到序列化程序,也没有发现创建 BeanSerializer 的属性(为避免异常,请禁用 SerializationFeature.FAIL_ON_E
..
这可以在 Apache Camel 路由中使用 Spring Boot 属性吗?@Value 工作正常,但这是否可以直接放置在表达式的占位符中. 更新:我知道 PropertiesComponent,但除了 Applicaiton.yml 之外,这将是我不喜欢的另一种配置. application.yml sftp:主机:10.10.128.128用户:ftpuser1密码:ftpu
..
我在 java 中几乎已经准备好使用 jms 和 Camel 的应用程序.弹出我们必须在交换/消息中添加其他信息.可以说这些附加信息实际上是新的 java 对象.将我的新对象添加到交换的最佳方式是什么? 我有很多 Camel 处理器处理如下所示的消息: 公共类 MyProcessor 实现处理器 {@覆盖公共无效进程(交换交换)抛出异常{String s = exchange.getIn(
..
(骆驼 2.9.2) 非常简单的用例,但我似乎找不到答案.我的代码归结为: String user = "user";字符串密码 = "foo&bar";字符串 uri = "smtp://hostname:25?username=" + 用户 +"&password=" + 密码 +“&to=somthing@something.com";//等等.你明白了from("seda:queu
..
我在将 Jackson JSON 库与骆驼一起使用时遇到问题.例外是: FailedToCreateRouteException: 无法创建路由...因为无法创建数据格式“json-jackson".确保数据格式有效并且关联的 Camel 组件存在于类路径中 这是杰克逊库的类路径通知的开头:
..
我正在尝试在 spring.xml 文件中使用 Apache Camel Interceptor 来捕获传入请求和传出响应,如下所示:
..