activemq相关内容

SpringJMS-如何断开MessageListenerContainer的连接

我想断开队列的DefaultMessageListenerContainer.我正在使用dmlc.stop()，dmlc.shutdown().在连接时，有5个使用者线程已连接到队列.当我尝试断开连接时，有4个使用方断开连接，但仍有1个使用方保持连接状态. (请参阅线程末尾的屏幕截图.) 环境 1.带有AMQP的ActiveMQ 2.带有ApacheQpid的SpringJMS 问题 ..
发布时间：2021-02-12 19:12:58 其他开发

Amazon MQ服务如何在不要求客户端使用TrustStore和KeyStore的情况下工作?

当我们在独立ActiveMQ上配置SSL时，我们可能需要在客户端代码中提供TrustStore，TrustStore密码，KeyStore和KeyStore密码，以通过SSL协议连接到Active MQ，但是对于AmazonMQ，尽管它们已经提供了SSL端点，但是我们可以简单地连接到它，而无需提供与信任和密钥相关的值. 基于SSL的简单ActiveMQ的客户端代码段: ActiveMQ ..
发布时间：2021-02-12 19:12:44 其他开发

在ActiveMQ中配置网络代理后，并非所有使用者都使用该消息

我在同一台计算机上有2个应用程序实例(尽管它也可以在不同的计算机上)，并且具有两个具有不同端口的Tomcat实例，并且该应用程序中嵌入了Apache ActiveMQ. 我已经配置了一个静态的代理网络，以便来自一个实例的消息也可以被所有其他实例使用(每个实例可以是生产者和使用者). servlet: package com.activemq.servlet; import java ..
发布时间：2020-08-19 23:27:38 其他开发

ActiveMQ javax.net.ssl.sslhandshakeexception空证书链

我使用此链接创建了自签名的根CA证书和服务器密钥对 使用了此功能链接以使用先前生成的根证书生成客户端密钥对 尽管这些链接用于为MosquittoMQ设置SSL，而我的用例是针对ActiveMQ，但我相信两种情况下的证书生成过程都相同. 我正在使用的客户端是Java客户端. 代理密钥库包含根证书，并根据密钥库的要求将其捆绑到PKCS12文件中的服务器公钥和私钥，代理信任库包含客户端 ..
发布时间：2020-08-19 23:26:30 Java开发

在Java中的特定时间安排任务

我执行了一些代码，这些代码将在不同的日期时间安排许多作业.因此，总的来说，我将在特定的日期时间执行很多工作.我知道有Spring Scheduler会在某个时间段执行作业，但是它不会动态地调度作业.我可以将ActiveMQ与定时交付一起使用，也可以将Quartz用于我的目的，但是需要一些建议.我应该使用Quartz或ActiveMQ定时/延迟交付还是其他方式. Executor服务中还有定时 ..
发布时间：2020-08-19 23:26:28 其他开发

如何设置NMS侦听器容器的预取限制

除了在连接URL上，我如何在spring config中设置预取限制.我找不到任何属性的文档，并且Connection URL上的参数似乎不起作用.此外，我需要在消费者层面上做到这一点.这是我下面的配置. ..
发布时间：2020-08-19 23:26:24 其他开发

ActiveMQ:批量发布，持久发布消息，但不是异步发布消息?

是否可以批量存储大量消息? 我想让它们同步，持久地发送，但是一次要非常快. 我正在使用NMS(Java框架的.net版本).但是，如果您只知道如何在Java中执行此操作，那么它甚至会有所帮助.也许我可以更轻松地找到.net的解决方案. 我想到了诸如交易之类的事情.但是我只让交易对消费者有用，而对生产者没有作用. 解决方案 传统的建议是，如果您希望在批量发送时获得最大的吞吐量，那 ..
发布时间：2020-08-19 23:26:22 C#/.NET

使用activemq故障转移URI进行重新连接，而第一次连接超时

我目前正在使用activemq故障转移工具来使客户端重新连接到代理，而且我也没有 希望在断开连接时阻止“发送"操作，所以我使用的是URI，如failover:(tcp://192.168.193.177:61616)?timeout=1，而问题是如果我第一次无法连接，连接将超时并且重新连接不起作用，我得到的例外情况: 2011年12月7日下午3:39:28 org.apache.active ..
发布时间：2020-08-19 23:26:14 Java开发

活动的Mq:如何阻止活动的mq创建不存在的队列

如何停止活动的mq创建不存在的队列? 我正在使用Active MQ来存储消息，但是如果Itbdoewnt存在，则Active Mq会创建一个队列.如果它不存在，我不希望它创建一个队列 解决方案 您需要通过设置authorizationPlugin来限制目标的创建: 只有具有管理员角色的用户可以发送和阅读消息以及创建目的地 只有具有生产者角色的用户可以发送消息 只有具有消费 ..
发布时间：2020-08-19 23:26:13 其他开发

在ArtemisMQ 2.x上的消息重新分发不起作用

我想在具有静态主机的2节点群集上启用消息重新分发.但这似乎行不通. 1)我有10个生产者，它们写入节点1上的队列"MyTestQueue"(但没有消费者). 2)我在节点2上有1个使用者(但没有生产者)，它使用了来自节点2的消息. 我希望节点1将消息重新分发到使用方存在的节点2，但事实并非如此.节点1上的邮件数仍然等于发送到节点1的邮件数. 我的broker.xml中具有以下配 ..
发布时间：2020-08-19 23:26:10 其他开发

activemq-全部"5.15.3"；不适用于Spring 5

我正在将Spring从4.x.x更新到Spring 5.0.3.该项目使用ActiveMQ版本5.15.3.当我尝试使用最新版本的Spring部署应用程序时，出现此错误: Caused by: java.lang.NoSuchMethodError: org.springframework.web.servlet.handler.AbstractHandlerMapping.obtainAp ..
发布时间：2020-08-19 23:24:03 Java开发

在哪里更改activemq中的预取值

我阅读了有关prefetch buffer的文档.据我的理解，如果我将Prefetch值= 1分配给使用者A.Activemq一次向A发送1条消息.一旦A向activemq发送了确认，则只有activemq将另一条消息推入给A的消息. 我的疑问是，我需要为消费者分配预取值. 我需要在消费者程序中分配预取值.如果正确，可以用简单的代码进行解释. 谢谢. 解决方案 根据 Ac ..
发布时间：2020-08-19 23:23:59 其他开发

在集群环境中将Quartz与Mule一起使用

我有一种情况，我试图从Yelp API中读取数据，并希望在一定间隔后将其放入ActiveMQ队列中，所以我使用了相同的石英调度程序.我的石英调度程序每10分钟运行一次，将数据推送到队列， 到这里一切都很好， 现在，我希望它在集群环境中工作，在那里我将部署2个实例并侦听相同的Yelp端点，现在发生的是，我来自2个实例的石英调度程序正在同一实例上执行，并且它们提取相同的信息来自Yelp，导致相同 ..
发布时间：2020-08-19 23:23:55 其他开发

从activeMQ获取所有队列

我是 activeMQ 的新手.我需要编写代码以获取所有队列并阅读消息. 我没有找到任何获得所有队列的API. 如何从 ActiveMQ 读取队列.如果可能，一些示例会有所帮助. 解决方案 在Java中获取ActiveMQ中的所有队列. 在 pom.xml 中添加Maven以下依赖项 org.springframework ..
发布时间：2020-08-19 23:22:09 Java开发

消费者在ActiveMQ中的致谢

我正在使用ActiveMQ编写Java应用程序.我有一个生产者类(需要用户输入)和一个带有侦听器的消费者类，以便消息到达后，消息侦听器立即执行onMessage(msg)函数. 但是，我的问题是，消费者何时将确认发送回给经纪人，以使味精从经纪人中出队?是在完成onMessage(msg)函数中编写的动作之后还是只是在调用onMessage(msg)函数时? 解决方案 在正常情况下，ack是 ..
发布时间：2020-08-19 23:22:03 Java开发

春季启动SSL TCPClient〜StompBrokerRelayMessageHandler〜ActiveMQ〜Undertow

我正在尝试基于 Spring Websocket演示使用 STOMP代理中继以通过SSL连接进行转发. 如Spring WebSocket文档中所述... 以上配置中的"STOMP代理中继"是Spring MessageHandler，它通过将消息转发到外部消息代理来处理消息.为此，它建立到代理的TCP连接，将所有消息转发给它，然后通过其WebSocket会话将从代理收到的所有消息转发 ..
发布时间：2020-08-19 23:21:54 Java开发

activemq没有合适的Log构造函数

这让我发疯.我只是想在Mac OSX 10.5.7上运行activemq.我有Java版本1.5.0_19和activemq 5.2.0.以下是我在运行bin/activemq时遇到的异常.似乎无法找到log4j，考虑到它与activemq一起提供，并且肯定在lib/optionals目录中，这很奇怪.我唯一能想到的就是我在某处发生冲突，但是我无法想象这是怎么可能的.如果有人听到我有什么提示，Go ..
发布时间：2020-08-15 00:35:32 Java开发