jms-topic

0热度

2回答

我们有被连接到一个服务器进程Swing GUI的客户。客户端“呼叫”使用jms:queue“从”骆驼路线定义端点，并使用ActiveMQ的作为底层JMS代理服务器上的服务。但是，客户端还提供了一个骆驼jms:topic端点服务器广播消息返回给客户端。不幸的是，它看起来像主题连接是越来越莫名其妙丢失，虽然客户仍可以“呼叫”服务的服务器上，该服务器无法发送任何消息到客户端的话题端点。骆驼端点的

2热度

1回答

如何集成测试一些Spring JMS配置

我想知道是否有人可以提供帮助。我的第一个10的原因是我对JMS和消息一般知之甚少（几乎没有） - 所以请随时与我联系，并提供任何答案/评论:) 鉴于这对我来说是一种学习方式，我试图组合一个非常基本的Spring JMS配置，然后编写一些集成测试来帮助我理解它是如何工作的。这是我目前的Spring上下文配置与它的JMS组件： <?xml version="1.0" encoding="UTF-8"

0热度

2回答

将消耗的消息从主题移动到队列

假设我有几个订阅者正在消费某个主题。在消息传递给所有订户后，我想要触发一个将在输入中使用此消息的作业。因此，简单的方法是将已成功传递给所有订阅者的消息转移到我的作业将使用消息的队列中。它是JMS的一部分吗？有没有任何消息中间人能够直接做到这一点？如果不是有一个简单的解决方案来解决这个问题？

2热度

1回答

Websphere MQ主题 - 它们是严格命令的吗？

在您订阅strictly ordered的Websphere MQ topic上收到消息吗？换句话说，以类似于queue的方式，假设您的连接得到维护，您可以保证以与发送相同的顺序收到topic消息吗？

0热度

1回答

简单的Java客户端连接到声波主题

我需要编写一个简单的Java类发送消息到声波主题。我可以使用JNDI值进行查找。这是代码。 Hashtable<String, String> properties = new Hashtable<>(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "com.sonicsw.jndi.mfcontext.MFContextFactory")

0热度

2回答

骡与JBOSS 5.1主题

我需要从Mule订阅JBOSS 5.1主题。这是我正在使用的配置。 <jms:connector name="jMSConnector" jndiInitialFactory="org.jnp.interfaces.NamingContextFactory" connectionFactoryJndiName="/ClusteredConnectionFactory" jndiProviderU

1热度

1回答

hornetq“找不到队列<其他服务器uuid>的队列信息”，核心网桥？

我对HornetQ配置的知识非常有限，但我会尽我所能解释我的问题。这里的设置：有一个网络上运行多个独立运行的JBoss（6.1.0Final）实例。这意味着，它们不会聚集在一起，它们已经部署了不同的应用程序，并且通常它们不应该互相干扰。每个JBoss都有一个主题配置的HornetQ。在deploy/hornetq/hornetq-configuration.xml中没有配置核心网桥（或者任何

0热度

2回答

什么时间点的消息从话题中删除？

我有一个话题。我有10位消费者订阅了它。按我的理解，邮件将被从话题，直到所有的消费者都接受了它删除。对？一旦它被删除，任何进一步的用户将不会通知该特定的消息。我无法在任何地方的JMS规范中确认它。

1热度

1回答

带有JMS主题的ActiveMQ - 消费者未出队的一些消息

我们试图将ActiveMQ 5.9.0作为使用JMS主题的消息代理进行设置，但我们在使用消息时遇到了一些问题。出于测试目的，我们有1个主题，1个事件生产者和1个消费者的简单配置。我们一个接一个地发送10条消息，但每次运行应用程序时，都会消耗1-3条消息！其他消息被消耗并且处理得很好。我们可以看到，即使我们重新启动应用程序（我们可以看到“Enqueue”和“Dequeue”中的数字），我们发布到

0热度

1回答

JMS主题为Glassfish上的订阅者提供身份验证

我在GlassFish服务器上配置了JMS主题，并且实现了一个客户端来订阅主题并打印它收到的消息。这工作正常。这是我的客户。您可以看到我选择使用某种“直接连接”而不是使用JNDI查找。 com.sun.messaging.ConnectionFactory connFactory = new com.sun.messaging.ConnectionFactory(); connFactory.