问题标签 [jms-topic]

我在尝试从看似简单的 java 代码创建主题发布者时遇到问题。我的 WMQ 在公司中单独管理，因此我无法直接控制它。

我尝试通过使用相当标准的 Java 代码创建 a TopicConnection，然后是a ，TopicSession然后是 a 来连接到该主题，尽管是通过 SSL 设置一些额外的系统道具。TopicPublisher但是，无论是否使用 SSL，我都有同样的问题，我相当确定。

在线上

如下引发 WMQ 异常

WMQ 管理员可以通过在SYSTEM.BASE.TOPIC. 但是，公司风险政策不允许这样做。

有人问我为什么需要访问基本主题，但我当然不需要访问权限。我只需要发布到我的主题。

请任何 WMQ 专家有任何其他想法？非常感谢。

我正在尝试测试将消息发布到 JMS 主题的系统的单个组件。在连接自动关闭之前，它似乎可以正常运行几个小时，并且我在日志文件中收到以下消息：

WARN [org.hornetq.core.client] (hornetq-failure-check-thread) HQ212037：检测到连接失败：HQ119014：没有从 invm:0 接收数据。很可能客户端在没有关闭连接的情况下退出或崩溃，或者服务器和客户端之间的网络出现故障。您也可能错误地配置了 connection-ttl 和 client-failure-check-period。请查看用户手册了解更多信息。现在将关闭连接。[代码=CONNECTION_TIMEDOUT]

这是没有客户端的正确行为，还是无论连接了多少客户端，主题都应该继续发布消息？

我正在使用 Java SE。我在应用程序第一次启动时创建一个主题，如下所示：

我对如何Topic在课堂上检索它感到困惑。例如，我有一个类，它连接到 JMS 服务，就像上面一样使用：

我如何才能获得对Topic我创建应用程序启动以发送消息的引用？

我会想象一些类似的东西：

会存在，但我找不到任何东西。

我已经阅读了如何使用 Java EE 使用 JNDI 查找来执行此操作，但是由于我没有在容器中运行，因此我无法使用此服务。

使用 Stomp WebSockets 连接到 ActiveMQ 服务器，我的 extjs5 浏览器 web 应用程序有许多主题订阅范围为面板。

下面是一个带有标题的主题订阅示例：

当用户完成主题订阅后，她会关闭触发 this.mqClient.unsubscribe( sub ) 调用的面板。

重新打开该面板会创建一个具有相同 activemq.subscriptionName 的订阅，这会触发此错误响应：

如何关闭持久主题订阅？

我有一个与 java 消息传递服务相关的问题... 问题：假设我的 JMS 发布者向我发送了 5 条消息...当我收到前两条消息时，我的应用程序会处理它们并确认它们...以便将其从主题中删除。 ..文我收到第三条消息，由于某些问题，我的应用程序无法处理它并且没有确认...但是第 4 条和第 5 条消息得到了处理并确认...但是我检查了管理控制台，我发现第 3 条消息消息也被确认...

我想知道如何单独确认每条消息。有人有想法吗？？？

注意：我使用的是 CLIENT_ACKNOWLEDGE 模式。

我需要将消息推送到 Solace JMS 队列 Webpshere，但在发送消息期间出现错误。我还增加了消息侦听器的大小，但没有解决问题。

我们使用 WebLogic 服务器，使用来自 Topic 的 JMS 消息。我们有几个节点，在主动/主动订阅模式下工作，除了 dB (Oracle) 之外没有共享状态。问题是，我们有一个要求，即只有一个订阅者（第一个接收到消息的）需要在从 Topic 接收到消息时执行实际的业务逻辑。

订阅者之间同步的最佳方法是什么？是否有某种方法可以在 WebLogic 本身上处理此问题，例如从主题收集消息，冒充单个订阅者并将其放入队列中 - 这样 WebLogic 的订阅者将收听队列而不是原始主题？

有人可以帮助我吗？这是我的问题：

我尝试用 jms 发送一个对象（这部分有效）并用 jms 接收它。我的对象很简单。3 个字符串、3 个整数和一个布尔值。

不存在连接问题或类似问题。我收到了物品，但好像我一件一件地收到了所有东西。

这是我的 MessageListener ：

我的发送部分：

最后这是我要发送的内容（在receiver.java 和sender.java 中）：

我的控制台：

如果有人能告诉我有什么问题，那就太好了。我不明白。我的主题/队列/同步/异步的短信工作得很好。它涉及到对象......似乎问题就在这里： yo = (ObectToSend) myMessage.getObject(); 但.....

I'm new to JMS message passing. I want to publish a message to a topic and subscriber should receive it. Here is my spring bean definition.

I publish message in the constructor of JmsPublisher.class

but my listener won't get executed.

在这段代码中，我试图仅为特定主题中的消息设置重新投递警察：

问题是发送到另一个主题（VirtualTopic.secondTopic）的消息也会受到此策略的影响，因为我可以看到第二个主题的侦听器正在处理重新传递的消息。在 RedeliveryPolicyMap 中，我添加了指定目标的策略。但由于某种原因，我无法让它按预期工作。

预期是：

• 一条新消息 A 发布到“VirtualTopic.firstTopic”
• 一条新消息 B 发布到“VirtualTopic.secondTopic”
• “VirtualTopic.firstTopic”上的监听器“Consume.FIRST.VirtualTopic.firstTopic”将处理消息A。
• “VirtualTopic.secondTopic”上的监听器“Consume.SECOND.VirtualTopic.firstTopic”将处理消息B。
• 如果 FIRST 侦听器失败，将在 15 分钟后重试。
• 如果 SECOND 侦听器失败，则不会发生任何事情。该消息将最终进入死信队列。

我从此页面获取了配置：

http://activemq.apache.org/redelivery-policy.html

有没有人完成过这样的事情？谢谢。