程序员经验分享-hwhale

如何在Mule中创建独占队列消费者？

2024-03-17

在 ActiveMQ 中，您可以为队列配置独占消费者，例如：
Queue_Name_Here？consumer.exclusive=true

如何在 Mule 中配置像上面这样的独占消费者？


您需要对队列名称进行 URL 编码，因为 Mule 可能会尝试将参数解码为 Mule 传输选项，但事实并非如此。

<jms:inbound-endpoint queue="Queue_Name_Here%3Fconsumer.exclusive%3Dtrue" 
                      connector-ref="Active_MQ" 
                      doc:name="JMS"/>
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

Queue

Mule

ActiveMQ

如何在Mule中创建独占队列消费者？ 的相关文章

  • Python 中的线程队列挂起

    我正在尝试通过队列使解析器成为多线程 它似乎有效 但我的队列挂起 如果有人能告诉我如何解决这个问题 我将不胜感激 因为我很少编写多线程代码 此代码从 Q 中读取 from silk import import json import dat

  • Activemq 关闭失败然后终止进程

    我正在实施复制的 leveldb activemq 设置 我有 3 个 activemq 实例在同一个盒子上运行 我正在配置文件中更改它们的 rmiPort amqpport 和 openwire 端口 配置看起来像这样

  • 使用 Tensorflow 对象检测 api 打乱训练数据集

    我正在使用 Faster RCNN 模型和 Tensorflow 对象检测 API 来开发徽标检测算法 我的数据集按字母顺序排列 因此有一百个阿迪达斯徽标 然后是一百个苹果徽标等 我希望在训练时对其进行洗牌 我在配置文件中添加了一些值 tr

  • 如何在Linux中找到处理器队列长度

    尝试确定 Linux 计算机上的处理器队列长度 准备运行但当前未运行的进程数 Windows 中有一个针对此指标的 WMI 调用 但对 Linux 不太了解 我正在尝试挖掘 proc 和 top 以获取信息 有没有办法确定CPU的队列长度

  • 具有动态数量的并行消费者的 Kafka 工作队列

    我想用Kafka来 分工 我想将工作实例发布到某个主题 并运行由相同使用者组成的云来处理它们 当每个消费者完成其工作时 它将从该主题中提取下一个工作 每项工作只能由一个消费者处理一次 处理工作非常昂贵 因此我需要在许多机器上运行许多消费者才

  • 如何在 celery task.apply_async 中使用优先级

    我有一个testcelery 中的队列 我为它定义了一个任务 celery app task queue test ignore result True def priority test priority print priority 它

  • 将 Laravel 事件订阅者排队

    我通过事件订阅者处理多个事件 而不是创建单独的事件 侦听器 我想对其中几个事件进行排队 但我还没有找到实现这一目标的方法 我已经关注官方了文档 https laravel com docs 5 2 events event subscrib

  • Java中的快速队列

    我正在寻找一个快速queueJava 中的实现 我看到LinkedList实施Queue接口 但它只会像LinkedList正确的 有没有一种方法可以让队列更快 特别是对于add 我只需要poll add并检查empty 以后我可能还需要一

  • 从 HTTP 端点发送消息到 JMS

    我正在尝试使用骆驼路由 它将接受 http 端点上的有效负载 然后将该有效负载写入 JMS 队列 到目前为止我所拥有的路线如下 但是一条空消息被传递到 jms 队列 消息到达那里 但没有正文 路线如下

  • 队列上的 IEnumerable 迭代器是否应该使项目出列

    我创建了一个自定义通用队列 它实现了通用 IQueue 接口 该接口使用 System Collections Generic 命名空间中的通用队列作为私有内部队列 示例已清除不相关的代码 public interface IQueue

  • 由于地址已在使用错误，Activemq 无法运行

    如何解决错误 Java Runtime Oracle Corporation 1 7 0 05 E Program Files Java jdk1 7 0 05 jre Heap sizes current 1004928k free 99

  • mule-standalone-3.3.1 无法在 Windows 7 上启动

    在 Windows 7 中启动 mule 服务器时遇到以下问题 我已经设定JAVA HOME and MULE HOME适当地 MULE HOME is set to C BAM Linux fresh mule standalone 3

  • 使用 Celery（RabbitMQ、Django）检索队列长度

    我在 django 项目中使用 Celery 我的代理是 RabbitMQ 我想检索队列的长度 我浏览了 Celery 的代码 但没有找到执行此操作的工具 我在 stackoverflow 上发现了这个问题 从客户端检查 RabbitMQ

  • MSMQ如何管理消息？

    看来MSMQ不使用任何数据库管理系统来管理消息 MSMQ如何管理消息 它将消息存储在平面文件中吗 我正在尝试实现一个消息管理系统 MSMQ 使用位于 windir system32 msmq 中的平面文件 如果你想实现自己的队列 我建议你看

  • 如何使用 NMS 和 C# 识别 ActiveMQ 断开连接

    我有一个 C 发布者和订阅者 它们使用 ActiveMQ 和 NMS 相互通信 一切工作正常 除了我无法知道 ActiveMQ 何时出现故障 这对于消费者来说尤其不利 他们停止获取数据 但除了数据停止显示之外 不会引发任何错误或事件 有没有

  • TensorFlow 队列关闭后可以重新打开吗？

    我想将项目入队 关闭队列以确保其他会话将所有剩余项目出队 然后在下一个纪元稍后重新打开它 这可能吗 q tf FIFOQueue close q q close reopen q with tf Session as sess sess r

  • Laravel 5.1 失败的排队作业在 failed() 方法上失败，阻止调用队列失败事件处理程序

    我正在测试 Laravel 5 1 中的队列功能 我可以让作业在我的数据库表中排队 称为作业 并且可以让它们成功运行 我还创建了一个名为 failed jobs 的队列失败表 为了测试它 在作业表中 我操作有效负载数据以使其失败 然后像这样

  • 通过值获取 std::queue 中元素的索引

    有没有一种简单的方法来获取元素在 a 中的位置std queue通过它在 C 中的值 例如 std queue

  • Azure 有害队列计数警报规则

    在之前的一个项目中 我设法设置了一个警报规则 该规则会查看有害队列消息计数 并在队列中存在某些内容时 每天一次 使用 webhook 向 slack 发出警报 我试图找到它在 Azure 中的位置 因为看起来事情已经发生了变化 如果这不是

  • 数据编织转换

    我有 POST 方法的以下有效负载的输入 order Column X X Column Y Y Column Z Z Column W div 1 some text div 2 true div 3 2 mapper A

随机推荐

  • 无法摆脱 GDB 中的“值已被优化掉”

    我正在调试CPython可执行的GDB尽管禁用了所有变量 但仍无法获取某些变量的值GCC优化 gdb print co value has been optimized out gdb frame 0 PyEval EvalFrameDef

  • 使用 GD 在图像上写入文本不起作用

    我在用着PHP 7 4当我尝试使用在图像上写文字时imagettftext 功能没有任何反应只有空白图像 当我回滚到PHP 5 6它工作完美 我已经确认 GD 已启用并且我在 Windows 操作系统下 这是我的代码 我已将其复制自php

  • 为什么 O(n) 优于 O( nlog(n) )？

    我刚刚发现了这个奇怪的发现 在普通数学中 n logn 会小于 n 因为 log n 通常小于 1 那么为什么 O nlog n 大于 O n 呢 即为什么nlogn被认为比n花费更多的时间 Big O 是否遵循不同的系统 事实证明 我误认

  • 如何在 Elasticsearch 中或在 Lucene 级别进行联接

    在 Elasticsearch 中执行相当于 SQL 连接的最佳方法是什么 我有一个包含两个大表的 SQL 设置 Persons 和 Items 一个人可以拥有many项目 人员和项目行都可以更改 即更新 我必须运行根据人和物品的各个方面进

  • python中连接变量名

    我有一组表名 1 EOM 2 STMT 3 LOOKUP etc 我想将这些表名称与一些变量名称相关联 例如 1 start time 2 end time 3 total time etc 我想写这些变量名的方式是这样的 1 start

  • 尽管启用了实验性 JS，ECMAScript 6 仍无法工作

    我有最新的 Chrome 版本 45 以及版本 47 的 Chrome Canary 两者都启用了实验性 JavaScript 标志 我想使用 ECMAScript 6 但它不起作用 我不知道为什么 是否还有任何技巧或其他标志也必须启用 E

  • 关闭呈现的视图控制器后推送视图控制器

    我有这个导航堆栈 RootVC gt VC1 gt 呈现 gt ModalVC 我有VC2 不在导航堆栈中 演示时ModalVC 我想单击 ModalVC 中的按钮来关闭 ModalVC 然后推送VC2之后进入导航堆栈VC1一键点击 它应该

  • 如何在 PHP 中将 PDF 文档转换为预览图像？ [关闭]

    Closed 这个问题正在寻求书籍 工具 软件库等的推荐 不满足堆栈溢出指南 help closed questions 目前不接受答案 将 PDF 文档的一部分渲染为图像文件需要哪些库 扩展等 我发现的大多数 PHP PDF 库都以创建

  • 了解右值引用

    我认为我对右值引用不太理解 为什么以下无法编译 VS2012 并出现错误 foo cannot convert parameter 1 from int to int void foo int void bar int x foo x 我会

  • Google Datastore查询NodeJS应用程序如何获取实体的ID

    我有一个使用 Google Datastore 的 NodeJS 应用程序 我设置了一个基本查询 它可以从数据库返回数据 问题 如何检索返回的每个实体的 ID 我需要结果集中的 ID 以便可以在 UI 上向用户显示它 这是到目前为止的 No

  • iOS Appstore应用程序覆盖企业应用程序

    我公司拥有Appstore和企业发行许可证 我们将通过企业许可证使用当前的测试版进行演示 一些用户将下载企业应用程序来测试测试版本 应用商店发布后 我们希望应用商店应用程序覆盖演示期间下载的企业测试版 这样 下载测试版应用程序的人就可以切换

  • Apache Flink 环境中的 AWS SDK 冲突

    我正在尝试将我的作业部署到 Flink 环境 但总是收到错误 java lang NoSuchMethodError com amazonaws AmazonWebServiceRequest putCustomQueryParameter

  • Cocoa Autolayout：内容拥抱与内容压缩阻力优先级

    我在有关 Cocoa Autolayout 的 Apple 文档中找不到有关内容拥抱和压缩阻力之间差异的明确答案 有人可以解释一下它们的用法和区别吗 概念的快速总结 拥抱 gt 内容不想增长 抗压 gt 内容不想收缩 Example 假设你

  • ImportError：没有名为 sklearn.cross_validation 的模块

    我在 Ubuntu 14 04 中使用 python 2 7 我使用以下命令安装了 scikit learn numpy 和 matplotlib sudo apt get install build essential python de

  • 如何使用 FormData 将文件发送到 Nodejs 并让 Node 发回确认消息？

    您好 我正在处理这个简单的表单 尝试使用以下命令将文件发送到我的 Nodejs 服务器FormData 但由于某种原因 节点从未收到它 另外 我怎样才能让节点在页面上发回一条确认消息 说明已收到文件 我做错了什么或错过了什么 请帮忙 先感谢

  • 如何检查当前页面是否是WordPress中的插件管理面板

    我想知道如何检查我当前是否位于插件的管理页面 我创建了一个带有菜单项的插件 该菜单项显示一个包含该插件使用的一些统计信息的页面 为此 我使用自定义 JQuery 插件和一些 CSS 我永远不会在该页面之外使用它们 所以我想知道如何检查这个

  • 使用扩展 DefaultBatchConfiguration 的编程方式时未创建 Spring Batch 5 和 Spring Boot 3 元数据表

    当使用编程方式扩展时DefaultBatchConfiguration 即使属性spring batch jdbc initialize schema被设定为always 有没有办法在扩展时启用自动模式初始化DefaultBatchConf

  • 重新打开时 CSV 中的前导零[重复]

    这个问题在这里已经有答案了 我有 txt 文件 如下所示 我正在使用显示的方法在excel中导入txt文件here http www upenn edu computing da bo webi qna iv csvLeadingZeros

  • 我们可以在基本 Clear Case 项目的配置规范中省略元素 * /main/LATEST 吗？

    在我拥有的一个基本的透明案例项目中 交给我的配置规范如下所示 element CHECKEDOUT element PROJ 1 5 0 LATEST element main LATEST mkbranch PROJ 1 5 0 elem

  • 如何在Mule中创建独占队列消费者？

    在 ActiveMQ 中 您可以为队列配置独占消费者 例如 Queue Name Here consumer exclusive true 如何在 Mule 中配置像上面这样的独占消费者 您需要对队列名称进行 URL 编码 因为 Mule

热门标签