apache-camel相关内容

Hawtio JMX 中根本没有列出骆驼上下文

我已经在 tomcat 中部署了三个示例 apache camel 示例: /camel-example-activemq-tomcat-3.5.0-SNAPSHOT/camel-example-cxf-tomcat-3.5.0-SNAPSHOT/camel-example-servlet-tomcat-3.5.0-SNAPSHOT 它们都已启动并运行正常. 其中一个使用 ActiveM ..
发布时间:2021-11-28 21:34:10 其他开发

Camel、Spring、OSGI:有没有办法指定停止方法?

我正在运行 Camel Spring OSGI 应用程序.Camel 上下文是通过 Spring 初始化的.当 bundle 停止时,我需要做一些清理活动,比如取消注册消息监听器.我怎么做?有没有我可以覆盖的方法?我知道 OSGI 包必须提供激活器启动和停止方法,但我的理解是 Camel/Spring/OSGI 框架覆盖了这些方法. 我的 beanx.xml: ..
发布时间:2021-11-28 21:33:58 其他开发

Apache Camel - 在启动时触发任务只运行一次

我正在使用 Camel & 开发一个 Java 项目.春天.我们想在 Spring 完成它的事情并且 Camel 完成所有路由的构建之后在单例 bean 上触发一个 initialize 方法. 我们不能在类创建时调用该方法,因为它动态链接到它从@Component spring 注释中获取的其他类,我们不知道这些类何时/是否已加载以实际运行 init 方法作为构造函数的一部分. 如何 ..
发布时间:2021-11-28 21:33:48 Java开发

Apache Camel 究竟是什么?

我不明白 Camel 到底是做什么的. 如果你能用 101 个词来介绍骆驼: 究竟是什么? 它如何与用 Java 编写的应用程序交互? 它是否与服务器一起使用? 它是一个独立的程序吗? 请解释什么是骆驼. 解决方案 如果你有 5 到 10 分钟的时间,我一般建议人们阅读这篇与 Apache Camel 的集成 作者:Jonathan Anstey.这是一篇写得很好的 ..
发布时间:2021-11-25 20:59:01 Java Web开发

Camel 处理器与服务端点中的业务逻辑

在 Camel 路由中,我是否应该考虑将我的业务逻辑放在离散托管的 bean 端点中,例如消息驱动 bean 或 Web 服务,而不是仅在 Camel 处理器中实现它? 将 Camel 仅用于调解和使用似乎更清晰地分离关注点编排,使用处理器作为过滤器,而不是作为业务逻辑的容器.但是,我认为此时不需要 EJB 容器,而且我似乎需要一个来托管 MDB. 更简洁的架构与更小的占地面积、更少的 ..
发布时间:2021-11-17 02:32:43 其他开发

ESB 应该如何打包/部署?

我正在尝试围绕 Apache Camel,它似乎是一个轻量级的 ESB.如果我正确理解 Camel/ESB,那么您可以将 Camel Route 视为节点和边的图.每个节点都是路由上的一个端点(可以消费/生产消息).每条边都是两个不同端点(1 个生产者和 1 个消费者)之间的路由. 假设这是正确的,我有一个实际问题:最佳实践对部署应用程序的 ESB/Camel Route 有何规定?我应该将 ..
发布时间:2021-11-17 02:26:38 其他开发

在 Apache Storm bolt 中使用 Apache Camel ProducerTemplate

我正在尝试编写简单的 Storm + Camel 项目.我的 Storm 拓扑分析了推文,一个 bolt 应该将推文文本发送到 apache camel route,而后者又使用 websocket 通知某些 webapp. 由于在尝试使用 build once CamelContext 时从 Bolts 收到 NotSerializableExceptions,我无法使其工作. 我已 ..
发布时间:2021-11-14 23:39:48 其他开发

骆驼找不到“sftp"注册表中的组件并关闭

我正在使用camel-sftp 组件将文件上传到SFTP 服务器.代码很简单: File source = new File(path);final String sftpUri = "sftp://" + userId + "@" + serverAddress + "/" + remoteDirectory+"?password="+pwd;CamelContext context = ne ..
发布时间:2021-11-12 03:49:59 其他开发

想使用 CAMEL、CXF 和 Karaf 访问静态资源

我是 CAMEL、CXF 和 Karaf 的新手.我想使用带有 CXF 和 KARAF 的 CAMEL 访问静态文件.想知道这样做的最佳方法.我在网上搜索过,发现基于 CXF 的休息 Web 服务可以写成相同的.有没有其他更简单的方法.我们正在使用 jboss FUSE 服务器. 解决方案 有更好的方法来做同样的事情. 第 1 步在您的 maven 插件中添加 src/m ..
发布时间:2021-11-12 03:49:17 其他开发

Apache camel soap 请求类型转换错误

我正在尝试在 osgi 环境 (karaf) 上运行的 apache 骆驼中发送一个肥皂请求.直到现在我得到了这个代码 public void start(BundleContext context) 抛出异常 {LOGGER.log(Level.INFO, "开始");MyRouteBuilder routeBuilder = new MyRouteBuilder();camelContext ..
发布时间:2021-11-12 03:48:15 其他开发

camel-hdfs2 方案没有文件系统:hdfs

在我的 OSGI 项目中使用camel-hdfs2 时出现了一些错误(基于karaf) 我的环境: Apache Karaf v4.0.4 Apache Camel v2.15.2 Apache Camel hdfs2 v2.15.2 错误是: 方案没有文件系统:hdfs 错误详情: 2016-07-07 15:59:52,141 |错误 |pool-14-th ..
发布时间:2021-11-12 03:48:03 其他开发

记录骆驼异常并发送到死信通道

我有一条在 Karaf 内运行的 Camel 路线,为此我添加了一个死信频道.这是为了处理路由失败的情况,我想保留问题消息并记录原因.我无法将异常抛回调用应用程序,因为我正在异步处理一些处理. 通过阅读文档并尝试了许多案例,我不清楚如何将异常记录到 Karaf 的日志中并将原始消息存入死信队列. 这是我所拥有的摘录:- ..
发布时间:2021-11-12 03:46:53 其他开发

如何使用 apache camel 验证 xsd?

我正在使用 apacheservicemix 并尝试使用 apache camel 验证 xml 文档.我有一条名为 Students_route.xml 的路线: 我创建了 3 个目录,分别称为:valid、invalid 和 finally.在 karaf 中运行“start Students_route.xml"后什么也没有发生.当我查看日志时,我没有得到任何错误,只是一些这样的消息: ..
发布时间:2021-11-12 03:46:09 其他开发

为什么骆驼 kafka 生产者很慢?

我使用 apache camel kafka 作为客户端来生成消息,我观察到 kafka 生成器需要 1 毫秒来推送消息,如果我使用骆驼聚合将消息合并到批处理中,那么推送一条消息需要 100 毫秒. 安装简述3 卡夫卡集群 16 核 32GB 内存 示例代码 String endpoint="kafka:test?topic=test&brokers=nodekfa:9092,no ..
发布时间:2021-11-12 02:57:45 其他开发

如何使用camel-kafka提交偏移线程安全?

如问题所问如何手动控制使用camel-kafka 提交偏移量? 我想使用camel-kafka 手动提交偏移量.我的路线: .from(kafka:topic1).aggregate(new GroupByExchangeStrategy()).to(kafka:topic2).process(new ManualCommitProcessor()) ,其中 ManualCommitProce ..
发布时间:2021-11-12 02:42:07 其他开发

Apache Camel Kafka 支持 Confluent 模式注册表

我正在尝试使用 kafka 组件创建骆驼路由,尝试使用 io.confluent.kafka.serializers.KafkaAvroDeserializer 和 schemaRegistry url 以及其他组件参数来使用事件.我不确定 Camel-Kafka 目前是否完全支持这一点.有人可以对此发表评论吗? from("kafka:{{kafka.notification.topic}}? ..
发布时间:2021-11-12 02:41:03 其他开发