问题标签 [activemq-artemis]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
8569 浏览

jms - 如何修复新的 ActiveMQ Artemis 安装阻塞问题?

我的任务是为 JMS 客户端评估 ActiveMQ Artemis。我有 RabbitMQ 经验,但没有使用 ActiveMQ Artemis。

我在本地机器上安装了 Artemis,按照说明创建了一个新代理,并将其设置为 Windows 服务。Windows 服务可以正常启动和停止。我没有对broker.xml文件进行任何更改。

对于我的第一个测试,我试图从一个独立的 Java 程序执行 JMS 队列生产/消费。我正在使用“使用 JMS”部分的 Artemis 用户手册中的代码(不使用 JNDI):

当我运行此代码时,我收到以下错误:

我的研究还没有确定这是服务器端设置,还是让生产者无阻塞地发送。我一直无法找到具有阻塞布尔值的生产者发送方法,只有持久性。关于重点放在哪里的任何想法?

编辑:添加到专用于此队列的新address-setting元素:broker.xml

0 投票
1 回答
95 浏览

messaging - 多个 Apache Artemis 目的地与单个目的地

我不确定什么是最好的方法,我有 10K 用户,每个用户订阅 5 个主题,总共 50K 主题,或者我可以更改它,以便每个用户订阅一个主题,总共 10K 主题并使用 payloadType 属性区分消息的类型。基本上,有大量消息流的 10K 主题与带有小消息流的 50K 主题。哪个更畅销并且总体上是更好的方法?谢谢

0 投票
1 回答
1848 浏览

java - 如何使用 Artemis JMS 管理 API 创建持久队列

说来话长,但我需要使用 Artemis JMS 管理 API创建一个持久队列。目前,代码默认创建一个临时队列:

我认为原作者认为这会创建一个持久队列,但显然不是。我找不到很好的文档,想知道是否有人可以确认/否认这一点。

提前致谢。

0 投票
1 回答
161 浏览

java - 从 JMS 侦听器 onMessage() 提交时,批处理作业卡在 STARTING

我正在尝试根据 JSR 352 规范使用JobOperator从 BatchRuntime 获得onMessage(...)的 JMS MessageListener 中的方法启动批处理作业。

结果是作业执行卡在STARTING。当我尝试从同一个线程停止任务时,它同样卡在 STOPPING。

从平原开始相同的工作,HttpServlet它会立即运行到完成。为什么会这样?

0 投票
1 回答
1272 浏览

java - javax.jms.InvalidDestinationException: AMQ219002: 目标地址不存在 [条件 = amqp:not-found]

我正在使用 Qpid 协议向 ActiveMQ Artemis 的队列发送一条消息,如果我使用以下可以成功的代码

但是当我使用这种方式时会失败:

下面的代码是 jndi.properties:

谁能帮我解决它?谢谢!

0 投票
2 回答
225 浏览

module - Artemis Wildfly 中添加 mqtt 协议

我想将 mqtt 与 Artemis activemq 一起使用。我尝试为 mqtt 添加一个模块,就像这里的这篇文章一样。我的问题是一样的,我看不到添加协议支持: MQTT

有人可以帮我吗?

0 投票
1 回答
632 浏览

security - 用户:null 没有权限='CREATE_DURABLE_QUEUE'

我正在尝试将一个简单的 paho 客户端连接到 artemis wildfly 代理。当我尝试连接我的客户端时出现此问题:
WARN [org.apache.activemq.artemis.core.protocol.mqtt] (Thread-2 (activemq-netty-threads-164875171)) 处理控制包时出错,正在断开 ClientAMQ119032:用户:null 在地址 $sys.mqtt.queue.qos2.JavaSample 上没有权限 ='CREATE_DURABLE_QUEUE'。

我向wildfly添加了一个应用程序用户,我给了他'guest'作为角色,在我的standalone-full.xml中,我发现了这个:

所以我尝试用用户名和密码(在wildfly中创建为应用程序用户)连接我的客户端,但它不起作用并且无法连接到代理。

你能帮我解决这个问题吗?

0 投票
2 回答
393 浏览

jms - 使用 Apache Artemis 的 JMS 队列,如何仅检索队列中的最后一条消息

我目前正在使用 Artemis ActiveMQ 2.2.0 和队列,我能够毫无问题地发送和接收消息。但是,我想知道如果队列中有多条消息,接收方如何只能检索最后一条消息?我应该使用任何特殊的队列吗?谢谢,

0 投票
1 回答
341 浏览

wildfly - Wildfly 10.1 集群中的 Spring websockets

将 Wildfly 10.1 Standalone-full-ha.xml 与包含的 ActiveMQ Artemis 1.1.0 一起使用。通过将其添加到 activemq 配置来启用 STOMP:

基于https://spring.io/guides/gs/messaging-stomp-websocket/部署了一个示例 spring websockets 战争

我在 2 个能够形成集群的独立服务器上运行它。我能够连接到两台服务器并发送消息,但是当我断开其中一个 websocket 时,另一台服务器上会引发以下异常:

我还使用 Wildfly 11 Alpha 和随附的 ActiveMQ Artemis 1.5.3 对此进行了测试,但每次断开 websocket 时都会出现相同的错误。

当我关闭服务器时,我也会收到以下错误,但我不太关心这些,因为它们只在关闭期间发生:

弹簧 websocket 示例有问题吗?

我是否需要更改默认的standalone-full-ha.xml 中的某些内容以使其在集群中正常工作,而不会在客户端断开连接时引发异常?

0 投票
1 回答
96 浏览

interceptor - Artemis mqtt 客户端拦截器:java.lang.ClassNotFoundException

我想拦截 mqtt 客户端发送给 artemis 代理的消息。我正在关注示例“interceptor-client-mqtt”。我的问题是我总是收到错误“java.lang.ClassNotFoundException:SimpleMQTTInterceptor”。我的问题是我应该把拦截器类放在哪里以便经纪人可以找到它?我应该只放拦截器的类,还是应该放一个jar文件?