jms-topic

1热度

2回答

如果我有一个主题树像 - 体育/ NBA/ - 体育/ NHL/ ，如果我想获得通知，每一支NBA球队我会订阅一个主题字符串像：Sports/NBA/* 但是如果我对整个列表中的2个团队不感兴趣呢？如果在订阅诸如体育/ NBA/*/- 湖人之类的主题时有过滤某些主题对象的方法吗？感谢您的任何意见问候

1热度

1回答

ActiveMQ中的setBackOffMultiplier（double backOffMultiplier）如何工作

我正在使用activemq编写应用程序，我正在使用redelivery策略重新传递邮件。我正在使用ActiveMQ的ExponentialBackOff概念。我的问题是这个ExponentialBackOff/setBackOffMultiplier是如何工作的。例如在我的情况下，我想重新传递邮件直到邮件过期时间，即15分钟。我想在15分钟内尝试重新传递10次。但ExponentialBack

1热度

1回答

JMS主题字符串中是否可以包含空格？

JMS主题字符串是否可以包含空格？ EG：“/ TOPIC STRING /” 当我尝试发布到这个主题时，它说它是一个无效的目的地。

0热度

1回答

如何将选择器应用于来自SolAdmin的主题队列

现在，我有一个单独的主题，它有许多不同类型的消息。假设Topic1具有类型A，B和C的消息。我有三个订阅该主题的队列（QueueA，QueueB，QueueC）。我希望每个队列只使用它所对应的消息类型，但无法找到这样做的方法。到目前为止，我只能订阅该主题（将采用关于该主题的每条消息）。我似乎无法在SolAdmin上找到设置消息选择器的位置。我使用SolAdmin版本8.0.1.3和安慰VMR版本

2热度

1回答

Spring Integration与IBM MQ集成jmsmessage-driven-channel-adapter

我已经编写了使用Spring Integration JMS消息驱动的通道适配器从IBM MQ读取消息的代码，但无法读取队列中的消息，任何人都可以帮助我以下是我的配置。 <beans:bean id="ibmJmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <beans:property name

0热度

1回答

消息选择器vs Tibco EMS上的消息过滤主题

我正在使用Tibco EMS主题进行客户/服务器通信的客户端服务器应用程序。在我们的一个用例，我们需要发送消息每劈了过来> 200K“科目”分钟的几百万。每个客户都对他需要订阅的一小部分主题感兴趣。的问题是，这些实现是比较合理的：送过来一个主题的所有消息，并使用消息选择通过相关科目进行过滤。为每个主题创建一个非静态主题，并让客户端订阅相关主题的主题。

0热度

1回答

ActiveMQ内的路由逻辑到特定的工作池

我有一个场景，我有相同的队列配置为SMS和EMAILS。我希望ActiveMQ将消息路由到特定的使用者池，即如果它是SMS，则必须将其路由到工作线程池以用于SMS。所以，如果我需要扩大SMS的数量，那么我只需要增加SMS Worker Pool的池大小而不是EMAIL工作池。我可以使用Apache Camel来实现我的需求的路由逻辑吗？

0热度

2回答

访问ActiveMQ的死信队列中的消息，并在消费后重新传递给webservice或套接字

Iam使用ActiveMQ在Java中编写应用程序，其中iam使用生产者和异步使用者机制，其中生产者发送的消息未因网络消耗因此这些消息被发送到ActiveMQ的死信队列。我的问题是如何访问死信队列中的消息，并通过在消费者中使用它并发送到web服务或套接字等来执行重试。任何代码示例都会很好。

4热度

3回答

计数存储在kafka主题中的邮件数

我使用的是kafka的0.9.0.0版本，我想在不使用管理脚本kafka-console-consumer.sh的情况下计算kafka主题中的邮件数。我已经尝试了答案中的所有命令Java, How to get number of messages in a topic in apache kafka 但是没有人会得出结果。任何人都可以帮我在这里。

0热度

1回答

如何获取生产者发送的所有数据，当订阅者在Mqtt主题中处于非活动状态时Java（未保留或最后一条消息）

我一直在寻找互联网。我曾尝试将cleansession设置为“false”，qos 1和2，但订阅者在上线时没有获取所有内容。请帮助...我的代码是 Example.java（监制） public class Example extends PersonBean { public void hey(){ String clientId = MqttClient.generateClientI