问题标签 [jboss-amq]

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 回答
735 浏览

jboss - 如何使用命令行控制台界面向 JBoss A-MQ 添加新队列?

我正在尝试将队列添加到正在运行的 JBoss A-MQ 服务。

目前我可以通过Web界面手动完成,如下图: 红帽 JBoss A-MQ Web 控制台

但是,我想使用 A-MQ 命令控制台来做到这一点: 红帽 JBoss A-MQ 命令行界面

与 Web 界面上的“创建”按钮等效的 JBoss A-MQ 控制台命令是什么?

我已经搜索了官方文档,但我似乎找不到它。

0 投票
1 回答
158 浏览

java - Jboss AMQ:从 hawtio 发送持久消息

我们正在开发一个使用 redhat jboss AMQ 的应用程序。我们正在从 6.0 版迁移到 6.1 版,我们拥有新的 webconsole hawtio。为了测试我们应用程序的功能,我需要将PERSISTENT消息发送到队列。在 6.0 版本中,如果我想发送持久消息,我只需要选中复选框,但在 hawtio 中我看不到这样的选项。我相信我需要添加额外的标题,但我不知道到底是哪一个,或者有另一种选择来实现我想要的吗?

0 投票
1 回答
332 浏览

jboss - JBoss-A-MQ 在 JMS 消息传递应用程序中遇到 UnknownHostException

我有一个示例 JMS 消息传递应用程序,如下面的代码片段所示。当我执行程序时(特别是在启动连接时),我得到一个 UnknowHostException。异常的原因是clientid属性获取为空。

应用程序:公共类 MessagingTestApp {

JNDI 属性文件:

堆栈跟踪:

我是 JBoss-AMQ 和 JMS 的新手。如果有人能指出我哪里出错了,我将不胜感激。

0 投票
2 回答
149 浏览

persistence - 特定队列的 Activemq 持久性

我在 activemq.xml 中找到了用于将队列持久保存在数据库中的全局配置(persistenceadapter)。

我的应用程序中有 5 个队列正在运行,我只想保留两个队列,在 activemq.xml 中有没有办法做到这一点?

问候, BRK

0 投票
1 回答
732 浏览

jms - 在 ActiveMQ 代理不可用时重试建立 JMS 连接

这是我的场景。我几乎没有安装为服务的 ActiveMQ (JBoss-AMQ) 生产者和消费者。在服务器重新启动中,处理生产者或消费者服务在 ActiveMQ 代理服务之前启动的这种情况的最佳实践是什么。在这种情况下,生产者/客户端无法建立连接并开始挂起,即使在代理服务启动后也是如此。

这是我的连接创建代码片段:

我是 JMS 的新手,非常感谢您的支持。

0 投票
1 回答
5402 浏览

java - javax.jms.JMSSecurityException:用户名 [null] 或密码无效

我有一个简单的 JMS 发送器和接收器。
我使用 jboss-amq 作为代理。
他们使用 jndi 来查找值。

jndi.properties

使用这些值我得到了以下异常:

我注意到如果我将以下内容添加到 jndi 文件中

这两个程序运行没有错误

那么,第一种方法有什么问题?

0 投票
1 回答
559 浏览

jboss - 无法从 Hawtio 浏览非文本消息

目前我正在我的应用程序中实现 ActiveMQ 消息代理。我们正在使用 RedHat JBoss Hawtio 管理控制台来浏览消息。我们无法在管理控制台中读取 ObjectMessage。正常的短信显示正常。我看到类似的问题已经报告为 Jboss 问题跟踪器中的错误,但我没有看到任何解决方案。想咨询我们的社区专家,看看是否有人对此问题有一些解决方案/解决方法。这是我在管理控制台中看到的错误消息。

https://issues.jboss.org/browse/ENTESB-4074

0 投票
1 回答
181 浏览

jboss-amq - Redhat Jboss AMQ 7.0.1 证书库身份验证失败

我正在尝试为 Jboss AMQ 7.0.1 实施基于证书的身份验证我已经根据 AMQ 示例“ssl-enabled-dual-authentication”设置客户端和代理端但我收到以下错误

[org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager] 无法验证用户:javax.security.auth.login.FailedLoginException:用户为空

我正在尝试使用 Apache Qpid AMQP1.0 客户端。虽然我已经配置了证书基础登录配置,但似乎 jaas

属性登录模块

正在被调用。

以下是服务器堆栈跟踪。

14:24:03,324 调试 [org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager] 无法验证用户:javax.security.auth.login.FailedLoginException:用户在 org.apache.activemq.artemis 为空.spi.core.security.jaas.PropertiesLoginModule.login(PropertiesLoginModule.java:89) [artemis-server-2.0.0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2]在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_131] 上 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_131]。 DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_131] 在 java.lang.reflect.Method.invoke(Method.java:498) [rt.jar:1.8.0_131] 在 javax.security。 auth.login.LoginContext。在 javax.security.auth.login.LoginContext.access$000(LoginContext.java:195) [rt.jar:1.8.0_131] 在 javax.security 调用(LoginContext.java:755)[rt.jar:1.8.0_131] .auth.login.LoginContext$4.run(LoginContext.java:682) [rt.jar:1.8.0_131] 在 javax.security.auth.login.LoginContext$4.run(LoginContext.java:680) [rt.jar: 1.8.0_131] 在 java.security.AccessController.doPrivileged(Native Method) [rt.jar:1.8.0_131] 在 javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:680) [rt.jar:1.8 .0_131] 在 javax.security.auth.login.LoginContext.login(LoginContext.java:587) [rt.jar:1.8.0_131] 在 org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager.getAuthenticatedSubject( ActiveMQJAASSecurityManager.java:185) [artemis-server-2.0.0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2] 在 org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager.validateUser(ActiveMQJAASSecurityManager.java:94) [artemis-server-2.0.0.amq-700008- redhat-2.jar:2.0.0.amq-700008-redhat-2] 在 org.apache.activemq.artemis.core.security.impl.SecurityStoreImpl.authenticate(SecurityStoreImpl.java:128) [artemis-server-2.0. 0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2] 在 org.apache.activemq.artemis.protocol.amqp.broker.AMQPConnectionCallback.isSupportsAnonymous(AMQPConnectionCallback.java:104) [ artemis-amqp-protocol-2.0.0.amq-700008-redhat-2.jar:] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPConnectionCallback.getSASLMechnisms(AMQPConnectionCallback.java:92) [artemis-amqp -protocol-2.0.0.amq-700008-redhat-2.jar:] 在 org.apache.activemq.artemis。protocol.amqp.proton.AMQPConnectionContext.onAuthInit(AMQPConnectionContext.java:315) [artemis-amqp-protocol-2.0.0.amq-700008-redhat-2.jar:] at org.apache.activemq.artemis.protocol.amqp .proton.handler.ProtonHandler.dispatchAuth(ProtonHandler.java:309) [artemis-amqp-protocol-2.0.0.amq-700008-redhat-2.jar:] 在 org.apache.activemq.artemis.protocol.amqp。 proton.handler.ProtonHandler.inputBuffer(ProtonHandler.java:204) [artemis-amqp-protocol-2.0.0.amq-700008-redhat-2.jar:] at org.apache.activemq.artemis.protocol.amqp.proton .AMQPConnectionContext.inputBuffer(AMQPConnectionContext.java:120) [artemis-amqp-protocol-2.0.0.amq-700008-redhat-2.jar:] 在 org.apache.activemq.artemis.protocol.amqp.broker.ActiveMQProtonRemotingConnection。 bufferReceived(ActiveMQProtonRemotingConnection.java:138) [artemis-amqp-protocol-2.0.0.amq-700008-redhat-2.jar:] 在 org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java :628) [artemis-server-2.0.0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2] 在 org.apache.activemq.artemis.core.remoting.impl.netty .ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:69) [artemis-core-client-2.0.0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2] 在 io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext .java:358) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1]在 io.netty.handler.codec.ByteToMessageDecoder.handlerRemoved(ByteToMessageDecoder.java:219) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty .channel.DefaultChannelPipeline.callHandlerRemoved0(DefaultChannelPipeline.java:631) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.DefaultChannelPipeline.remove (DefaultChannelPipeline.java:468) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.DefaultChannelPipeline.remove(DefaultChannelPipeline.java:428 ) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 org.apache.activemq。artemis.core.protocol.ProtocolHandler$ProtocolDecoder.decode(ProtocolHandler.java:185) [artemis-server-2.0.0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2] 在io.netty 上的 io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:411) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1]。 handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 org.apache.activemq.artemis。 core.protocol.ProtocolHandler$ProtocolDecoder.channelRead(ProtocolHandler.java:128) [artemis-server-2.0.0.amq-700008-redhat-2.jar:2.0.0.amq-700008-redhat-2] 在 io。 netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5。Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1]在 io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.handler .ssl.SslHandler.unwrap(SslHandler.java:1066) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.handler.ssl.SslHandler .decode(SslHandler.java:900) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder .java:411) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.handler.codec.ByteToMessageDecoder。channelRead(ByteToMessageDecoder.java:248) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java: 372) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358) [netty-all -4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350) [netty-all-4.1.5.Final -redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) [netty-all-4.1.5.Final-redhat-1 .jar:4.1.5.Final-redhat-1] 在 io.netty.channel。AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext. java:358) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) [netty -all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:972) [netty-all -4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:386) [netty-all-4.1.5 .Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 io.netty.channel。epoll.EpollEventLoop.run(EpollEventLoop.java:302) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] at io.netty.util.concurrent.SingleThreadEventExecutor$5 .run(SingleThreadEventExecutor.java:873) [netty-all-4.1.5.Final-redhat-1.jar:4.1.5.Final-redhat-1] 在 java.lang.Thread.run(Thread.java:748 ) [rt.jar:1.8.0_131]

0 投票
1 回答
75 浏览

jboss-amq - 使用 JMS 的 Jboss AMQ 连接应该使用哪个库

根据 Jboss AMQ 指南,应该使用 AMQ JMS Client 1.1.0 来连接代理。但它仅适用于 amqp:// 或 amqps:// 不适用于 tcp:// 或 ssl:// 。我们应该将哪个库用于非 amqp 但标准 JMS 连接?

官方示例程序使用 maven 和 redhat repo 作为所需的库,它没有使用 AMQ JMS Client 1.1.0。

0 投票
1 回答
51 浏览

jboss-amq - JBoss AMQ 7.0.1 管理控制台 wiki 页面抛出异常 javax.management.InstanceNotFoundException : io.fabric8:type=Fabric

我已经安装了 Jboss AMQ 7.0.1。一切正常。但是如果我尝试在 Web 管理控制台中浏览 Wiki,则会出现以下异常。

javax.management.InstanceNotFoundException : io.fabric8:type=Fabric

堆栈跟踪:

经过一番搜索,我发现这可能是面料升级的原因,但不确定到底是什么,我必须这样做。