程序员经验分享-hwhale

Apache Camel 中的忽略消息

2024-01-08

希望这听起来并不荒谬，但我怎样才能丢弃消息在骆驼故意?

到目前为止，我将它们发送到日志组件，但同时我什至不想记录提款。

有没有/dev/空骆驼的端点？


您可以使用消息过滤器 eip 来过滤掉不需要的消息。http://camel.apache.org/message-filter http://camel.apache.org/message-filter

没有 dev/null 组件。

另外，您可以在路由中使用 ，当一条消息击中它时，它将停止继续路由。

我们在 dev/null 上得到的最接近的是路由到日志，您可以在其中设置 logLeve=OFF 作为选项。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

apachecamel

Apache Camel 中的忽略消息 的相关文章

  • 如何在同一场战争的多个 jar 中使用相同的 CamelContext

    我使用的是camel 2 16 2 我需要在多个jar 中使用一个 CamelContext 因为我需要将所有 Camel 路由器放入一个 CamelContext 中 所以我的战争将把所有这些罐子作为 Maven 工件 请告诉我如何处理上

  • Akka 会淘汰 Camel 吗？

    My 理解Akka 的特点是它提供了一个模型 多个独立的线程可以通过该模型以高度并发的方式相互通信 它使用 参与者模型 其中每个线程都是一个 参与者 负责执行特定的工作 您可以编排在什么条件下将哪些消息传递给哪些参与者 我以前使用过 Cam

  • 为什么camel kafka Producer很慢？

    我使用 apache camel kafka 作为生成消息的客户端 我观察到 kafka 生产者需要 1 毫秒才能推送一条消息 如果我使用骆驼聚合将消息合并到批处理中 那么推送一条消息需要 100 毫秒 安装简述 3 kafka 集群 16

  • Web 服务具有“无此类操作：HTTP GET PATH_INFO”

    我目前有一个 SOAP Web 服务 我正在尝试访问它的端点 但我不断收到此错误

  • 批量消费骆驼kafka

    尽管遵循此处发布的示例 但我无法与卡夫卡骆驼消费者一起批量阅读 我是否需要对生产者进行更改 或者问题最有可能出在我的消费者配置上 有问题的应用程序利用卡夫卡骆驼组件 https camel apache org components 3 1

  • Apache Camel Java DSL 在正文中添加换行符

    因此 我在 Java DSL 中设置了一个 netty4 套接字路由 如下所示 Override public void configure throws Exception String dailyDataUri SOCKET daily

  • Apache Camel：带有聚合的多播 - AggregationStrategy 调用过于频繁

    对于多播 聚合 我有以下奇怪的 或者至少对我来说不清楚 行为 考虑以下路线 from direct multicaster multicast to direct A direct B aggregationStrategy new Agg

  • java.lang.IllegalArgumentException：缺少某些字段（可选或强制）

    我正在尝试使用 Apache Camel Bindy 创建固定文件阅读器 但出现异常 请帮助我找到解决方案 没有页眉和页脚 效果很好 Update 文件很小 现在无法理解 并且添加了 public 文件内容 101 08 2009 30A9

  • Camel - 将特定参数从路由传递到通用 bean 方法

    假设我有一条骆驼路线 如下所示 from direct myRoute setHeader someHeader simple some header value beanRef myBean beanMethod 我有一颗豆子cannot

  • 骆驼工作单元

    我试图理解骆驼中的工作单元概念 我有一个简单的问题希望这里有人可以提供帮助 例如 如果路由交换涉及多个路由 from aws sqs Q1 to direct processMe route1 from direct processMe t

  • 使用 Camel 的表达式语言获取并格式化昨天的日期

    我在 Camel 的路径中使用日期 fileName date now dd MM yyyy 但我现在需要的是 1天 那可能吗 嗯 不直接 简单语言中的 date 对象只能获取当前时间 或者您放置在标头中的某个时间值 您可以在 java 或

  • Camel Apache：从接收到的 XML 中提取一些值的 xpath

    在我的 Camel 路由期间 我查询服务器 HTTP GET 结果 我收到一个 200 OK 其 XML 正文看起来类似如下

  • 使用Java DSL的Camel CXF POJO模式

    我有一个预先存在的 Web 服务 连接 SOAP 如果可能的话 我想在不使用 Swing 框架的情况下进行调用 我遵循接触优先开发 使用 cxf wsdl2java 工具生成我的 java 文件 我希望从 java 对象中提取用户名和密码并

  • 替换 Camel v2.16.0 中已弃用的 beanRef()

    我们正在从 Camel v2 13 升级到 v2 16 并发现 beanRef 已被标记为已弃用 Apache Camel 推荐的替代 替代方案是什么 我在 Camel v2 16 0 文档网站上找不到任何有用的东西 甚至更新的示例尚不可用

  • Apache Camel/ActiveMQ 优先级路由

    我有两个具有相同消费者的 AMQ 队列 第一个队列 Q1 处理 97 的消息 另一个队列 Q2 仅处理 3 问题是 Q2 中的消息需要在排队后立即处理 所以我的问题是 当第二季度有消息可用时 我需要以某种方式暂停第一条路线以吸引其消费者 a

  • Akka、SQS 和 Camel 的消费者投票率

    我正在做的一个项目需要从SQS读取消息 我决定使用Akka来分布式处理这些消息 由于 Camel 支持 SQS 并且在 Consumer 类中内置了 Akka 中使用的功能 因此我认为最好以这种方式实现端点并读取消息 尽管我还没有看到很多人

  • 用于检查 Apache Camel XML 中字符串的 JSONPath 表达式

    假设我有一个简单的 json 文件 如下所示 log host blah severity INFO system 1 我正在使用 Apache Camel 它是 Spring XML 来处理和路由 json 文件 我的路由代码看起来像这样

  • WebSphere Camel JMS、spring、taskExecutor、haninging 线程

    我正在尝试将 Camel 与 WebSphere 集成 除了一件事之外 它工作得很好 场景如下 JMS WMQ gt 路由 转换 gt BEAN 执行 JPA OpenJPA1 2 DB2 提交 为了能够插入WAS事务管理器和mangaed

  • Apache Camel 的 JsonMappingException

    我在骆驼路线上遇到以下异常 Caused by com fasterxml jackson databind JsonMappingException No serializer found for class org apache cam

  • 如何使用 Apache Camel 路由从授权服务器获取访问令牌？

    我有一个授权服务器 带有注释的简单类 SpringBootApplication RestController Configuration EnableAuthorizationServer oauth2 security 在端口上运行80

随机推荐

  • Java 类路径找不到 MySQL 驱动程序

    每当我运行以下代码时 import com mysql jdbc Driver public void insertIntoMysql Print out classloader information ClassLoader cl Cla

  • 如何应用KineticJS过滤器？

    我发现 KineticJS 滤镜文档非常令人沮丧 并且无法在网上找到示例 尤其是考虑到亮度 Kinetic filters 文档link http kineticjs com docs symbols Kinetic Filters php

  • 单击球体

    我有一个以正交投影为中心绘制的单位球体 半径为 1 球体可以自由旋转 如何确定用户单击球体上的点 Given 显示器的高度和宽度 投影圆的半径 以像素为单位 用户点击点的坐标 假设左上角为 0 0 则 x 值随着向右移动而增加 y 值随着向

  • 为什么 Grpc.Core NuGet 包这么大？

    最新的 Grpc Core NuGet 包有 150 MB 之大 它似乎在其一生中稳步增长 这里有一些例子 v1 17 1 2018 年 12 月 48 34 MB v2 23 1 2019 年 8 月 68 11 MB v2 30 0 2

  • 如何制作自定义 Java/JavaFX 控制台？

    有必要制作一个自定义控制台 我有以下代码 public class Console extends OutputStream private Console ResourceBundle resourceBundle throws IOEx

  • 抑制来自套接字的“不允许操作”错误

    我有一个小型实用程序 可以处理 TCP 和 UDP 套接字 有时 我会在 stderr 中打印错误 不允许操作 我的问题是 我根据套接字函数的返回码 偶尔是 errno 处理错误 并且不打印任何内容 因此 该消息必定来自套接字调用之一 我不

  • 如何在 SQL Server 中检查 select 查询结果是否为 NULL

    在 SQL Server 中 如何验证查询是否返回 NULL 并根据它运行块 例如在查询 1 中 我想检查if count is not null然后检查它是否 gt 0 我应该使用if exists here if select coun

  • CSS 样式表在顶部还是底部？或者如何解决空白页问题？

    我一直将样式表放在顶部 之间 的html 据我了解 这是最佳实践 例如 http stevesouders com hpws css bottom php http stevesouders com hpws css bottom php

  • Python：将 IP 地址打包为 ctype.c_ulong() 以与 DLL 一起使用

    给出以下代码 import ctypes ip 192 168 1 1 thisdll ctypes cdll aDLL thisdll functionThatExpectsAnIP ip 我怎样才能正确地将它打包为一个期望它作为 c u

  • 最大数量数组中总和小于或等于 k ​​的元素的数量

    我想找到最大的数 给定正整数数组中的元素的总和小于或等于给定的编号 k 例如 我有一个数组 3 4 7 2 6 5 1 and k 6 答案是 3 因为 1 2 3 是得出总和 6 的最大元素 对数组进行排序 计算元素的数量 然后开始按顺序

  • 单击按钮后如何关闭弹出模式

    选中复选框然后单击按钮后如何关闭弹出模式 如果未选中复选框 则不关闭模式 复选框和按钮放置在模态内 当我检查复选框并单击按钮时 模式不会关闭 document ready function one checked on click clos

  • 8086 汇编语言中的换行符：我的文本打印为阶梯式

    I m getting stair step output like this 我的程序工作正常 除了当我打印一个新行 然后打印当前行中的某些内容时 它会显示在下一行上 但前面有一些空格 程序是这样的 打印0到9的多个数字的表格 data

  • localhost 和 0.0.0.0 的 IPV6 是什么？

    众所周知 IPv4 地址localhost is 127 0 0 1 环回地址 IPv6 地址有什么用途localhost并为0 0 0 0因为我需要阻止一些广告主机 众所周知 IPv4 地址localhost is 127 0 0 1 环

  • 列表中的每个孩子都应该有唯一的“key”道具

    我不断收到此警告 列表中的每个孩子都应该具有唯一的 key 道具 即使我有具有不同键的独特项目 每当我创建一个新的 植物 对象时 我都会给它一个新的 uuid setPlants prevItems gt return name newPl

  • hadoop 集群应该在相同的硬件上运行吗？

    我记得在某处读到过 如果运行 Hadoop 的机器彼此之间差异很大 那么 Hadoop 的性能会显着下降 但我似乎找不到该评论了 我正在考虑在不由我的团队直接管理的虚拟机阵列上运行 Hadoop 集群 我需要知道这是否是我应该在请求中提出的

  • 如何在 Xcode 10 中打开 Xcode 11 Beta 4 项目？

    我在 Xcode 11 Beta 4 中开发了一个项目 然后降级到 Xcode 10 并且无法打开该项目 我想将我的应用程序提交到应用程序商店 但我在 Xcode 11 beta 4 中不断收到错误消息 我是初学者 我知道我篡改了构建设置

  • 在 Unity3D 中，“设置”网格的边界会做什么或实现什么？

    在 Unity 代码库中 我看到了这个 the game object currently has no mesh attached MeshFilter mFilter gameObject AddComponent

  • 我们可以使用 for-each 循环遍历传递给函数的数组吗？

    我知道我们可以通过这种方式迭代作为参数传递的数组 NO ERROR void fun int a int n for int i 0 i

  • 如何在 NetBeans 中显示/显示隐藏或不可见的字符？

    如何在 NetBeans 中显示 显示隐藏字符 在其他编辑器中 如果打开此功能 空格可能会显示为小中心点 制表符可能会显示为右箭头 此功能对于查看文件是否使用制表符或空格进行缩进等很有用 这个功能已经缺失很长一段时间了 功能要求 https

  • Apache Camel 中的忽略消息

    希望这听起来并不荒谬 但我怎样才能丢弃消息在骆驼故意 到目前为止 我将它们发送到日志组件 但同时我什至不想记录提款 有没有 dev 空骆驼的端点 您可以使用消息过滤器 eip 来过滤掉不需要的消息 http camel apache org

热门标签