ActiveMQ:在没有代理的情况下启动消费者

2024-02-27

我正在编写一个从队列消费的 JMS 客户端。如果重要的话,我的经纪人是 activemq。

一项要求是,即使代理关闭,客户端也应该启动。在这种情况下,它的行为应该就像队列中没有消息一样,一旦代理启动并且消息开始出现,就会做出相应的行为。

问题是在我的代码中:

connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start()

如果经纪商倒闭,那么它就会陷入困境connection.start()。虽然我想要的是connection.start()以静默方式返回,并在可以时继续尝试在后台连接并消费消息,而在不能时则保持静默。

我怎样才能做到这一点。


使用单独的线程从队列中消费并启动连接。您将需要使用并发队列实现。

主题 1:

  • 实例化队列
  • 启动线程2
  • 尝试连接/阻止
  • 将消息添加到队列

线程 2(或某种池):

  • 启动客户端
  • 从队列/块中读取
  • 处理消息
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

ActiveMQ:在没有代理的情况下启动消费者 的相关文章

随机推荐

  • 我如何比较“Bcrypt”Gem 解密的密码和加密的密码

    我正在尝试对某些帖子的评论使用简单的身份验证 用户使用即时 ID 和密码输入评论 我使用 bcrypt gem 将密码存储在数据库中 就像comments controller rb中这样 comment Comment new comme
  • Django 中子查询的查询

    我正在尝试从另一个查询执行查询 但 Django 说 渲染时捕获数据库错误 子查询返回超过 1 行 我正在使用 PostGis my model class Place models Model coordinate models Poin
  • 通过 .htaccess 文件为所有 PHP 脚本设置 HTTP 标头

    我在我的一个项目中对所有 PHP 程序编写了相同的代码行 是否可以在目录的 htaccess 中执行此操作 如何 PHP 代码 Header Content Type application xhtml xml charset utf 8
  • 混淆矩阵和列联表有什么区别?

    我正在编写一段代码来评估我的聚类算法 我发现每种评估方法都需要来自m n类似矩阵A aij where aij是属于类成员的数据点的数量ci和簇的元素kj 但似乎有两个这种类型的矩阵数据挖掘简介 Pang Ning Tan 等 一个是混淆矩
  • iOS:无法启动 .app 文件

    我不知道为什么它在我的 app 文件中寻找目录 每次我运行应用程序时 它都会在 iPhone 上安装应用程序 但不会运行并给出以下错误 谁能告诉我这个设置存储在哪里 谢谢 error failed to launch Users xxx L
  • 更新/替换 Google 文档上的内嵌图像

    我正在尝试设置一个功能来更新 Google 文档上的图像 就像 Lucidchart Add on 对其 更新插入图表 功能所做的那样 为此 我目前正在执行以下操作 创建命名范围并将其 id 与生成图像的数据一起存储在文档属性中 以供以后检
  • 内部 __lzcnt64 使用不同的编译选项返回不同的值

    我有以下代码 include
  • BindingResult 和 bean 名称“categoryOptions”的普通目标对象都不能作为请求属性

    我知道这个主题有很多线程 我已经尝试了其中的大多数 但仍然无法解决我的问题 我正在使用SpringMVC and MongoDB我想要实现的是 我将在数据库中存储一些数据 然后将其从数据库检索回选择选项 这是我的代码 Jsp页面
  • SQLite:结束事务花费的时间太长

    我正在事务中插入几行 但是 当我执行 END TRANSACTION 时 执行时间约为 250 毫秒 而 BEGIN TRANSACTION 则几乎不需要 1 毫秒左右 我需要加快这里的速度以适应我的应用程序 我怎么能够 编辑 单线程正在访
  • SSL:CERTIFICATE_VERIFY_FAILED 证书验证失败:自签名证书(_ssl.c:1129)

    我正在尝试自动创建受信任的证书和非对称密钥 然后执行自动安装过程 目前 所有这些都是使用 OpenSSL 实用程序手动完成的 我正在使用 Cryptography io 库来实现此自动化 并尝试使用代码生成的证书连接到服务器 当我调用 Po
  • Symfony2 - 从编译器通道访问内核

    有没有办法从编译器通道内部访问内核 我试过这个 public function process ContainerBuilder container kernel container gt get kernel 这会引发错误 还有其他方法吗
  • 是否可以从 Silverlight / C# 调用 matlab 函数?

    是否可以从 Silverlight C 调用 matlab 函数 如果您有一个可以解释 Mathlab 调用的程序集 dll 您应该能够将该程序集包含在您的项目中 并将其与应用程序的其余部分一起编译 显然 您将无法并行运行 Silverli
  • 为什么我的 Android ListAdapter 只显示一项?

    在我的 Android 应用程序中 我正在尝试构建我的第一个自定义列表适配器 我现在设法让它显示一项 但不幸的是 列表中有 8 个项目时 只能显示一项 我的适配器如下所示 public class PossibilitiesAdapter
  • 如何为自定义数组类型重载 Base.show ?

    假设我用它自己的自定义来制作我自己的自定义向量类型show method struct MyVector T lt AbstractVector T v Vector T end function Base show io IO v MyV
  • 如何访问 tf.data.Dataset.list_files() 收集的文件名?

    我在用 file data tf data Dataset list files png 收集图像文件以在 TensorFlow 中进行训练 但希望访问收集的文件名列表 以便执行标签查找 调用 sess run file data 一直不成
  • 将巨大的模型对象保存到文件中

    假设您有一个从 VAR 回归操作返回的 varrest 类模型对象 我想将模型保存到文件中 但不是用于估计系数的所有数据 如何只保存模型规范而不保存训练数据 因为当我保存模型时 它的文件大小超过 1GB 因此加载确实需要时间 可以保存没有某
  • 如何在 Python C-API 中动态创建派生类型

    假设我们有类型Noddy如定义在为 Python 编写 C 扩展模块的教程 http docs python org extending newtypes html adding data and methods to the basic
  • Ruby on Rails 3.2 编译资源无法正常工作

    这是 Rails 资产中的错误吗 我不明白我做错了什么 你能帮忙吗 我不想进行按需编译 The bug Started GET for 127 0 0 1 at 2012 02 02 01 25 44 0200 Processing by
  • SQL SSRS 报告管理器站点每次都要求登录

    SQL Server 2012 SSRS Windows 2008 R2 当尝试通过 URL 访问报告管理器时 http 服务器名称 报告 http servername reports 它提示我们输入用户名和密码 当我输入有效的用户 密码
  • ActiveMQ:在没有代理的情况下启动消费者

    我正在编写一个从队列消费的 JMS 客户端 如果重要的话 我的经纪人是 activemq 一项要求是 即使代理关闭 客户端也应该启动 在这种情况下 它的行为应该就像队列中没有消息一样 一旦代理启动并且消息开始出现 就会做出相应的行为 问题是