ActiveMQ Artemis中的队列为空之前，寻呼状态不会恢复

文章/答案/技术大牛

发布

1回答

activemq-artemis

我们在ActiveMQ Artemis 2.17.0中遇到了一个问题。其中一个队列在达到最大内存设置- max-size-bytes时进入分页状态。但是直到队列为空，它才恢复寻呼状态。这是一种预期行为吗？

浏览 9提问于2021-06-20得票数 0

回答已采纳

1回答

ActiveMQ Artemis复制不起作用

replication、activemq-artemis、colocation

我有一个ActiveMQ Artemis集群，并将它们配置为通过网络进行排序的复制。Broker1 <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001s

浏览 2提问于2019-12-02得票数 0

1回答

未在ActiveMQ Artemis broker上发布状态为"in delivery“的消息

spring-integration、activemq-artemis

我已经在主从配置上设置了两个ActiveMQ Artemis代理(版本2.17)，并为HA设置了一个共享文件系统。在大流量的测试期间，我会停止主代理，并看到从代理接管并开始向消费者转发消息。过了一段时间后，我可以看到一些消息似乎已经被困在队列中。正如我在查询Artemis UI时看到的那样，“卡住的”消息被认为是“正在传递”。我的问题是，即使当我重新启动主代理时，这些消息也不会传递给使用者，即使更多的消息仍在填充同一

浏览 24提问于2021-03-03得票数 0

回答已采纳

1回答

Artemis回切期间，jBOSS EAP7.3消息驱动Bean无法部署应用程序

java、jms、activemq-artemis、message-driven-bean、jboss-eap-7

我正在尝试在一个集群中运行两个JBoss EAP7.3实例。两个实例都在运行2个Artemis activemq服务器，一个是实时的，另一个是备份另一个EAP实例上的实时服务器。我遇到的问题是，如果活动Artemis实例需要在启动时(在回切期间)与备份Artemis实例同步，我的应用程序将无法部署。准备好之前部署我的应用程序。在故障恢复的情况下，备份服务器(变为活

浏览 38提问于2021-04-07得票数 0

1回答

使用Apache轮询来自ActiveMQ Artemis的字节/大型消息

apache-camel、activemq-artemis、camel-jms

在通过JMS连接到ActiveMQ Artemis时，基于Apache的应用程序中，我遇到了一个问题。在Camel路由的末尾，消息存储在Artemis队列中。运行在同一应用程序中的遗留组件定期使用ConsumerTemplate从其中提取它们。的minLargeMessageSize的消息上，即使在一个测试程序中也有3个字节。我的版本是Camel 2.22.1和<

浏览 4提问于2020-01-08得票数 0

1回答

Swift: XCTest会修改状态吗？测试函数返回可选值的约定是什么？

swift、testing、xctest

这里有两个问题： XCTAssertEqual(queue.dequeue()，.) 为可能返回可选值的函数编写测试的推荐方法是什么？例如，我有一个方法

浏览 1提问于2015-01-17得票数 1

回答已采纳

1回答

BlockingCollection，竞争情况？

c#、multithreading、blockingcollection

我已经使用BlockingCollection实现了一个生产者/消费者模式，但是它似乎并没有像我预期的那样阻塞。null)}public void Run() { foreach (Bitmap bmp in queue.GetConsumingEnumerable()) {/&

浏览 0提问于2012-03-24得票数 0

回答已采纳

1回答

React一次挂载一个相同的组件(popover)

reactjs、react-hooks

我需要有登机弹出窗口，显示只在第一次登录，但我想只显示一个弹出窗口的时间，如果我关闭一个弹出窗口，下一个是显示，我怎么做呢？我正在使用window.localStorage检查弹出窗口是否已经显示type Props = { header?

浏览 0提问于2021-04-12得票数 0

1回答

Python:使用matplotlib和用户输入的线程/多处理

python、multithreading、matplotlib

我目前正在编写一段代码，该代码将继续通过串行通信检索到的绘图数据，同时还允许用户以raw_input的形式进行输入，以控制工作，例如启动/停止/清除绘图和设置数据的保存文件名。目前，我正试图通过一个额外的线程来完成这一任务，该线程只需读取用户输入并在程序连续绘制和保存数据时将其中继到程序中。不幸的是，我遇到了一些错误，在绘图循环中输入的命令将程序冻结了大约2分钟，我认为这与matplotlib不安全有关，其中在循环不使用绘图库时输入的</em

浏览 0提问于2015-09-04得票数 0

回答已采纳

2回答

Kafka -根据预定时间将消息移动到队列前面

apache-kafka、message-queue

在Kafka (或其他消息队列)中有没有一个功能，我们可以通过它来添加消息，这些消息只会在指定的时间变得活跃。这意味着该消息不应该在指定时间之前被消费。后续，有没有一种方法可以在消息到达预定时间时将这些消息移动到队列的前面。

浏览 0提问于2018-05-19得票数 0

2回答

无法重新创建已删除的频道

microsoft-teams、microsoft-graph-teams

然后，我试着用相同的名字重新创建，这似乎起作用了。但是，当我使用图形API尝试相同的场景时，我得到了"Channel名称已存在“的错误。

浏览 0提问于2020-01-02得票数 1

1回答

什么传呼机？

git、diff、pager

当我在某个文件上运行git diff时，它使用的是什么寻呼机？我之所以这样问，是因为对于Linux中与寻呼机一起使用的所有其他命令行工具，当我退出时(输入'q')，终端会恢复到以前显示的状态，这是我运行s.t的唯一证据。作为命令行本身。我已经阅读了git diff的文档，但是没有看到它说明如何将终端恢复到我运行diff之前的方式。我可以expo

浏览 5提问于2020-03-12得票数 0

回答已采纳

1回答

在MassTransit传奇中，从初始块调度事件时是否有短时间限制？

masstransit、saga

我正在开发一个POC，用于使用MassTransit sagas来处理用于授予申请的系统中的状态更改。我使用的是MassTransit 8.0.0-develop.394、.Net 6、EFCore6.0.2和ActiveMQ Artemis1.19.0。在填充验证数据之前输入的应用程序数据应该安排在以后的验证中，但是之后输入的数据应该立即进行验证。我认为带有预定事件的</

浏览 5提问于2022-03-10得票数 0

1回答

用什么快速的方式从C打给Lua？

c、lua

我有一个HTTP服务器，需要处理来自Lua代码的HTTP请求。在C代码中，我以这种方式调用一些Lua (idea来自)：luaL_openlibs(L);当我注释掉所有这些Lua调用时，我可以做一个200000 API。但是当打开这个API调用时，100

浏览 6提问于2013-06-22得票数 3

回答已采纳

1回答

如何将队列上的新消息通知给连续的Azure WebJob？

c#、azure、azure-webjobs、azure-sdk-.net、azure-queues

一个连续的webjob正在处理队列中的消息(正常优先级)。但是，如果另一个队列(高优先级)有任何消息，它希望得到通知，然后切换到处理该队列的消息，直到该队列为空，然后恢复到原始队列。我不想在处理每条消息之前手动检查高优先级队列，因为这将耗费IO操作(收费)。据我所知，webjob不能直接相互通信-所以使用另一个带有队列触发器的webjob我认为不会起作用(如果不正确请告诉我)。

浏览 1提问于2018-03-21得票数 1

1回答

具有数组元素的奇怪行为arrayBlockingQueue

java、arrays、multithreading、blockingqueue

我在使用ArrayBlockingQueue时有一些奇怪的行为，我使用它来在java应用程序中的某些tread之间进行通信。我尝试修复它的事情:我尝试了睡眠，如果我添加了150毫秒的睡眠，那么响应是正确的。在这个while循环之后，我尝试打印temp[1]，这时它是正确的值(它打印出44，但是消费者收到34)。最有可能的情况是同步问题，然而我认为基于BlockingQueue的对象的重点应该是解决这个问题。如果您对

浏览 0提问于2015-11-24得票数 0

2回答

等待Thread::Queue完成的正确方式是什么？

perl、loops

我正在尝试构建一个简单的爬虫，但似乎所有的线程都不会完成，甚至队列都是空的：$_->join for @threads; 那么，等待这些线程完成的正确方式是什么呢它永远不会跳出while循环。

浏览 0提问于2012-11-10得票数 1

回答已采纳

1回答

在Boost ASIO服务器中处理生存期

c++、boost-asio

在handle_accept类的rubymud_server方法中，我称之为new_connection->handshake()。一旦函数体退出，我相信我的new_connection就会丢失它的所有引用数并死亡。如果是这样的话，这件事只是运气好才能得到回应吗？ws_.async_accept和ws_.async_write是否在ws_connection的ws_成员被销毁之前完成？

浏览 6提问于2017-03-27得票数 2

回答已采纳

1回答

事务在故障转移时被回滚，但是提交可能已经成功。

jms、activemq-artemis

我有一个使用jms向ActiveMQ Artemis队列发送数据的应用程序。我收到了一条例外消息：我不能跳过一个口信。

浏览 0提问于2019-03-26得票数 0

回答已采纳

1回答

Datomic在连接到恢复的数据库时抛出ActiveMQInternalErrorException

datomic

我在源计算机上安装Datomic Pro v1.0.6202后重复了备份/恢复过程，以便源版本和目标版本匹配，但在连接到恢复的数据库时会出现相同的症状。/sendBlocking (ChannelImpl.java:404).嗯，我开始认为我发现了一个数据中的bug，或者是我本地的JDK (OpenJDK 15)有问题。会不会有什么奇怪的冲突？:artemis-core-client:

浏览 23提问于2020-10-24得票数 1

点击加载更多