activemq

5热度

1回答

我试图发送一个X？-GB大文件作为流到一个ActiveMQ队列进行处理。我知道ActiveMQ supports streams，camel-jms也是如此，但我试图在队列上设置的东西似乎没有任何区别。唯一发生变化的是关闭流缓存结果，而不是“流关闭”异常。我打算使用处理器或自定义类（只要资源得到清理），但这应该是可能的蓝图。如何通过camel-activemq正确处理大文件而不会出现OutOf

2热度

2回答

我们如何分析Activemq的死信队列中的消息

然后，代理将消息发送到死信队列，以便稍后进行分析。这些是来自apache activemq文章的引用。我的策略也是一样的。我想稍后分析死信队列中的消息。我怎样才能做到这一点？

0热度

1回答

一个主题的多个监听器如何在Activemq中工作？

我正在使用ActiveMq嵌入式代理。我正在使用pub/sub模型。我有多个订阅该主题的听众。我正在使用默认消息侦听器容器。所以我开始的话题和用户的统计数据。用于主题的消息的数目的统计始终为零。 DestinationStatistics statistics = destination .getDestinationStatistics(); LOG.info(

0热度

1回答

WSO2如何从ActiveMQ中获取消息，而无需通过客户端应用程序调用任何WSO2 API或代理？

WSO2如何从ActiveMQ中获取消息，而无需通过客户端应用程序调用任何WSO2 API或代理？ [请注意： - 源系统将发送通过ActiveMQ的和WSO2消息将不得不拿起这些消息] 任何人能提供任何解决方案？我无言以对......

0热度

1回答

KahaDB错误“磁盘上没有剩余空间”。如何解决这个问题？

我正在使用activemq。 KahaDB是activemq的默认消息存储。但它不断增加，最终耗尽了磁盘空间。即使所有消息都被确认，它仍然会不断增大，并在其数据存储区中不断创建新的日志文件。我没有设置与KahaDB相关的属性，它使用了默认属性。 broker = new BrokerService(); TransportConnector connector = new Tran

0热度

1回答

限制在ActiveMq主题中发送消息的订户的最大数量

假设有一个ActiveMq实例，并且有100个客户端正在监听主题。当在主题中发布新消息时，是否可以限制接收它的订阅者数量（仅示例10）？如果现在有其他消息传递组件能够做到这一点，或者存在解决方案/合并最佳实践？

-1热度

1回答

在spring启动时在activeMQ中延迟传送消息

我想在'x'秒后在任何时间发送一个't'消息，接收器会收到这个消息。这样做，我已经写了接收器瞬间。没有任何延迟接收的发送者代码 @Autowired private JmsTemplate jmsTemplate; private Queue queue = new ActiveMQQueue("topicName"); public void show(String message)

0热度

1回答

Activemq - 通过不稳定连接发送大文件的最佳协议

使用案例：需要在队列上从一台服务器向另一台发送大型文件（100 MB的倍数）。目前，我正在使用Activemq Artemis服务器发送大文件作为ByteMessage，通过tcp协议输入流的帮助，重新尝试间隔为-1，无限次失败重试。这里的主要问题是消费者终端连接将大部分是不稳定的，即由于移动性原因断开与网络的连接。因此，当在队列中发送文件时，如果连接断开并且重新连接的代理应该从事务中断的地方

-1热度

1回答

Java ActiveMQ：如何发送消息从客户端到服务器

我见过很多关于如何从服务器/生产者发送消息到客户端的代码和示例，但我失去了如何从客户端发送消息到服务器。它是否遵循相同的格式？例如，假设我的服务器有5个主题：A，B，C，D，E。我的客户端只收听主题C. 所以我的服务器创建一个队列并发送消息给订阅者/客户端。我的客户端获取主题C上的消息。它执行一些计算，并且我想要将消息发回给发布者（例如int）。什么是必需的步骤？我是否需要为制作人设定一个目

1热度

1回答

Activemq PooledConnectionFactory中到期超时的含义是什么？

我不明白在Activemq PooledConnectionFactory中应用expiryTimeout字段。 java doc表示“允许连接过期，而不考虑负载或空闲时间，这对于故障转移强制从池中重新连接，重新建立负载平衡或使用主后期恢复很有用”。请给我举一个例子，其中expiryTimeout场效应真实场景。