我使用的是ActiveMQ Artemis 2.19.1版本,在一个6节点(3个主服务器)集群中,重新分配对于具有以下警告日志的大型消息失败:
23:35:05,551 WARN [org.apache.activemq.artemis.core.server] AMQ222303: Redistribution by Redistributor[TEST_QUEUE/2244] of messageID = 196,950,715 failed: java.lang.UnsupportedOperationException: Method not supported with Large
我的Quarkus微服务正在使用smallrye反应式消息传递库中的AMQP连接器来生成发送到从运行的ActiveMQ Artemis代理的消息 Docker镜像。The The The 反应式消息库 文档提到了使用动态地址名称的可能性。我在REST资源中使用以下(Kotlin)代码: @Inject
@Channel("task-finished")
lateinit var taskFinishedEmitter: MutinyEmitter
@POST
@Produces(MediaType.TEXT_PLAIN)
fun do
我正试着跟随你的世界的榜样。对于普通的ActiveMQ,它可以工作,但是ActiveMQ Artemis让我头疼。我想有一些配置我做得不对。地址是创建的,但它是否使用多播路由。我想我需要Unicast (队列路由)。
下面的片段不适用于ActiveMQ的artemis版本。我想做的事有可能吗?我想自动创建一个持久队列。
public class SimpleAmqpTest
{
[Fact]
public async Task TestHelloWorld()
{
Address address = new Add
我刚刚在我的新服务器上安装了一个新的artemis,能够正常运行服务,但不能从外部访问。 我也关注了这个问题,似乎与我有类似的问题,但似乎不能工作。 Artemis-2.6.3 console: Service Unavailable 我目前的jolokia-access: <restrict>
<remote>
<host>localhost</host>
<host>10.85.102.148</host><!--This is my computer ip-->
在broker.xml中启用持久性后,当-Xms & -Xmx设置为4 4GB,global-max-size设置为默认值200Mb (大多数设置是由Artemis create命令创建的)时,根据处理的数据速率,我会在一天或三天内得到以下异常。配置类似于。
2020-08-03 02:25:58,969 WARN [org.apache.activemq.artemis.core.server] AMQ222033: Page file 000000005.page had incomplete records at position 9,259,622 at record num