-
1 votesanswersviews
创建从RabbitMQ到ActiveMQ的连接
我有一个ActiveMQ服务器的详细信息，我想连接并查看可用的数据 . 我想使用RabbitMQ（CloudAMQP） . 我已阅读文档，但我无法弄清楚如何 Build 此连接？ 我的连接细节如下： host = 'ssl://api.myreports.com:61613' user='myuser' password='mypassword' topicname = '/topic/myTop... -
2 votesanswersviews
密钥库被篡改，或密码与ActiveMQ不正确
我正在使用3个ActiveMQ实例;他们每个人都有自己的 keystore 和 truststore . 我已经相应地为每一个设置了 sslContext . 但是，当我尝试启动该服务时，我得到以下异常： Caused by: java.io.IOException: Keystore was tampered with, or password was incorrect jvm 1 ... -
2 votesanswersviews
Websockets - Tomcat Spring ActiveMQ与ActiveMQ本身
在使用简单代理使用Spring 4.1创建websockets服务器/客户端实现之后，我想使用高级代理向其添加消息队列 . 但在调查ActiveMQ时，我发现它已经内置了websocket支持 . 所以我的问题是，是否有人知道任何数据/信息将允许我评估一种方法而不是另一种方法 . 即当我可以使用ActiveMQ时，通过连接到ActiveMQ的Tomcat / Spring堆栈实现websocket... -
7 votesanswersviews
Spring Websocket与Stomp全功能代理和故障转移
我有spring的配置和一个完整的功能stomp代理（activemq）： @Configuration @EnableWebSocketMessageBroker public class WebsocketConfig extends AbstractWebSocketMessageBrokerConfigurer { private static Logger LOG = org.... -
0 votesanswersviews
带有嵌入式ActiveMQ Broker的Spring Boot WebSocket
我尝试使用Spring boot 1.5.4将Web应用程序从简单代理更改为嵌入式ActiveMq Broker，但在启动时总是出错 Caused by: java.lang.IllegalArgumentException: No handlers at org.springframework.util.Assert.isTrue(Assert.java:92) ~[spring-cor... -
2 votesanswersviews
Spring WebSockets ActiveMQ convertAndSendToUser
我有一个Spring Boot应用程序（Jhipster），它使用STOMP over WebSockets将信息从服务器传递给用户 . 我最近添加了一个ActiveMQ服务器来处理水平扩展应用程序，使用亚马逊自动扩展组/负载均衡器 . 我使用 convertAndSendToUser() 方法，该方法适用于应用程序的单个实例，以找到经过身份验证的用户'"individual queue... -
2 votesanswersviews
什么属于DLQ /无效消息队列？
关于允许应用程序拒绝哪种消息，是否有良好的最佳实践？ 我的理解是，所有无法处理的消息都应该被拒绝到死信队列 - 无论问题是语法错误还是消息中的语义错误，或者应用程序暂时无法处理消息（例如，因为数据库刚刚下降） . 当然 - 如果应用程序已经预先知道它将无法处理消息（DB down），它应该停止接受消息 . 那么共同的理解/最佳实践是什么？ -
190 votesanswersviews
如何在Java密钥库中导入现有的x509证书和私钥以在SSL中使用？
我在activemq配置中有这个 <sslContext> <sslContext keyStore="file:/home/alex/work/amq/broker.ks" keyStorePassword="password" trustStore="file:${activemq.base}/conf/... -
0 votesanswersviews
ActiveMQ使用zookeeper复制了levelDB无法访问？
我有3台zookeeper机器和3台activemq机器 .这是配置 .饲养员：滚动时间= 2000initLimit = 10syncLimit = 2DATADIR =的/ var /动物园管理员/数据CLIENTPORT = 2181server.153 = 192.168.62.153：2888：3888server.156 = 192.168.62.156：2888：3888server... -
3 votesanswersviews
ActiveMQ 5.10 / QPid 0.28 / AMQP 1.0性能问题
我正在尝试使用OpenWire和AMQP与ActiveMQ进行性能基准测试，并获得巨大的吞吐量变化 Using Openwire 持久消息大小：43个字节，无压缩，200个并发连接，吞吐量大约为9006 msgs / sec . 持久消息大小：1580字节，无压缩，200个并发连接，吞吐量约为3678.86 msgs / sec . 有 not much load on CPU 小于5％所以我可以... -
0 votesanswersviews
如何从activemq dlq获取消息？
我正在尝试编写一个脚本，从activeMQ队列中提取消息并在之后清除它们 . 我尝试在线查找，但找不到任何示例来教我如何做到这一点 . 我想知道如何连接到DLQ以及如何清除它？有帮助吗？ 提前致谢 -
4 votesanswersviews
使用ActiveMQ 5，是否可以在内存和网络连接中配置代理？
我们有一组应用程序，我想使用JMS进行消息传递 . 现在，我们的应用程序都与ActiveMQ代理 Build TCP连接 . 是否可以使同一主机上的15个左右的应用程序使用inVM连接或使用共享内存形式，而剩余的20个左右的应用程序仍然使用该主机？ 基本上，我想要将使用inVM配置的代理和使用TCP配置的代理组合在一起 . 我可以这样做，还是必须进行桥接配置？ -
18 votesanswersviews
消息队列系统中的消息优先级本质上是不重要的吗？
似乎我所看到的大多数消息传递系统都具有对优先级消息队列的基本支持（如果有的话） . 例如，AMQP只有specifies至少2个优先级 . RabbitMQ，一个AMQP实现，doesn't support任何优先级 . 在几天内，ActiveMQ将在版本5.4中为10个消息优先级getting support . 10个优先级是JMS spec指定的 . 在非消息传递意义上的单词中的prio... -
2 votesanswersviews
我们如何分析Activemq的Dead Letter队列中的消息
然后，代理接收消息并将其发送到死信队列，以便稍后进行分析 . 这些是来自apache activemq文章的引用 . 我的策略也一样 . 我想稍后分析死信队列中的消息 . 我怎样才能做到这一点？ -
11 votesanswersviews
处理消息队列中的重复
我一直在和我的程序员争论最好的解决方法 . 我们的数据以每秒约10000个对象的速度进入 . 这需要异步处理，但是松散排序就足够了，因此每个对象都循环插入到几个消息队列之一（还有几个 生产环境 者和消费者） . 每个对象约300个字节 . 它需要持久，因此MQ配置为持久存储到磁盘 . 问题是这些对象经常是重复的（因为它们不可避免地复制到 生产环境 者的数据中） . 它们具有10字节的唯一ID . ... -
5 votesanswersviews
预构建的AMQP和STOMP客户端（如GUI客户端）
我正在寻找一个客户端（如在GUI客户端，而不是客户端库）来使用我们的MQ服务器并熟悉它的语义 . 通过按下按钮（或文本命令）发送和接收消息的东西，甚至可以更新我关于服务器队列和消息的状态 . 行政将是一个奖金 . UI不必是图形的（即命令行客户端很好） . 服务器可能会运行RabbitMQ，因此任何RabbitMQ特定的都可以，ActiveMQ也是如此 . 但我宁愿拥有通用的AMQP或STOMP... -
2 votesanswersviews
可以使用ActiveMQ CPP Api与RabbitMQ Broker交谈吗？
我们有需要通过RabbitMQ代理发送消息的C软件，有人试过ActiveMQ CPP lib（CMS）向RabbitMQ代理发送/接收消息吗？ -
1 votesanswersviews
ActiveMQ中消费者的确认
我正在使用ActiveMQ编写Java应用程序 . 我有一个Producer类（它接受用户输入）和一个带有监听器的Consumer类，因此一旦消息到达，Message Listener就会执行onMessage（msg）函数 . 不过，我的问题是，消费者何时将确认信息发回给经纪人，以便msg从经纪人那里退出？是在完成onMessage（msg）函数中写入的操作之后还是仅在调用onMessage（m... -
1 votesanswersviews
消息 生产环境 者是否可以从activemq获得消息接收确认？
在我的情况下，远程客户端正在向wso2esb发送消息，该消息充当代理以将消息转发到ActiveMQ . 一旦远程客户端收到wso2esb对消息接收的确认，它就会从其本地存储中删除该消息 . 因此，仅在ActiveMQ收到来自wso2esb的消息并将其存储在持久存储中之后，才向远程客户端发送确认非常重要 . （存储和转发给消费者模式） . 所有我能找到的读取activemq确认的消息是Active... -
2 votesanswersviews
在ActiveMQ中向多个消费者发送消息
我是ActiveMQ的新手 . 我试图在activemq中实现 生产环境 者 - 消费者（发送者 - 接收者） . 在我的代码中，我可以通过ActiveMQ轻松地从单个 生产环境 者向单个消费者发送和接收消息 . 但是，问题是，我无法将消息发送给同一个制作人的多个消费者 . 这是我的 producer 和 consumer 课程 . MsgProducer.java package jms_ser... -
3 votesanswersviews
ActiveMQ主题与RabbitMQ Direct交换
我们目前正在关注ActiveMQ . 以前我们使用过RabbitMQ，特别是 Direct exchanges ， 生产环境 者可以向代理发送一条消息，然后将其传播到1：N其他队列 . 我们希望在ActiveMQ中进行类似的设置，其中代理保存消息进入其中的配置，而不是将消息直接发送到需要订阅特定主题的特定队列或消费者的服务 . 我已经挖掘了文档并找到了Virtual Topic Composite... -
4 votesanswersviews
如何在确保每个实体的FIFO的同时并行处理消息？
假设您的系统中有一个实体，比如“人物”，并且您希望处理修改各种Person实体的事件 . 重要的是： 同一人员的事件按FIFO顺序处理 多人事件流由不同的线程/进程并行处理 我们有一个实现使用共享数据库和锁来解决这个问题 . 线程竞争获取Person的锁定，然后在获取锁定后按顺序处理事件 . 我们希望转移到消息队列以避免轮询和锁定，我们认为这会减少数据库的负载并简化消费者代码的实现 .... -
1 votesanswersviews
如何抑制ActiveMQ中的排序？
我有一个 生产环境 者和一个消费者的消息队列用于异步请求，保证传递并应用一些超时策略 . 订购这些消息没有意义 . 每条消息都是彼此隔离的，并拥有自己的业务场景 . 所以我不需要在消息队列中进行任何排序 . 但问题是队列被第一条无法传递的消息阻止 . 其他消息是正确的并且准备以正确的方式处理，但是他们必须等待“坏”消息被传递 . Java和JMS与Spring在队列客户端上 . 是否可以在没有任何... -
2 votesanswersviews
如何让本地ActiveMQ代理“镜像”远程ActiveMQ代理上的队列？
我有一个本地ActiveMQ代理，它在一个不可靠的互联网连接上，还有一个可靠数据中心的远程ActiveMQ代理 . 我已经整理出“存储转发”设置，以便在Internet连接可用时将传出消息发送到远程代理 . 仅此一点很有效，但是当消息出站时 . 但是，现在我必须做相反的事情 . 这是场景： 远程ActiveMQ代理中出现新消息 . 消息将放入特定队列 . 几分钟后，本地ActiveMQ代理... -
0 votesanswersviews
ActiveMQ Broker RedeliveryPlugin消息存储
我们正在考虑使用JDBC数据存储区来 Build 一个由3个代理组成的主/从网络 . 根据文档，这将导致一个代理获取JMS表上的独占表锁，从而成为主服务器 . 其他经纪人将无法完全开始并等待他们获得锁定并成为新的主人 . 如何存储等待由ActiveMQ Broker重新传送的消息Redelivery Plugin？它们是否也存在于JDBC数据存储区中，或者它们是代理本地的，并且不会故障转移到下一台... -
2 votesanswersviews
Apache Camel ActiveMQ . 两个经纪人之间的邮件传输速度太慢
我正在尝试通过Apache Camel在2个ActiveMQ代理之间传输消息，而麻烦的是我每秒只能传输大约135个消息 . 我想增加这个数字 . 情况是我在远程服务器上有2个ActiveMQ代理 . 我想从第一个代理队列中获取消息，并通过Camel路由将这些消息传输到第二个代理上的多个队列 . this is how I establish connections: CamelContext co... -
2 votesanswersviews
如何在故障转移方案中通过Active-MQ Broker传递相同的Java应用程序？
有两个名为 GC1 和 GC2 的客户端使用主题“ GC1Alive " & " GC2Alive ”通过ActiveMQ相互通信 . 他们只是通过使用这些主题发送心跳 . Purpose 两个GC之间通信的目的是当 GC1 发生故障时， GC2 应该在故障转移场景中替换 GC1's 位置 . 故障转移方案由ActiveMQ自行处理，其中包含以下URL： URL =... -
0 votesanswersviews
获取从所有主机到我的activemq代理的连接数
ActiveMQ broker setup: 经纪人在机器上运行：hostA 来自不同主机的客户端可以连接到我在hostA上运行的代理实例，任何主机都可以有任意数量的客户端 . Is there a way to find out how many clients are connected to broker and also list which tell me how many connec... -
3 votesanswersviews
Apache Pulsar与Apache RocketMQ
Apache Pulsar（雅虎）似乎是下一代Apache Kafka . Apache RocketMQ（阿里巴巴）似乎是下一代Apache ActiveMQ . 两者都是开源分布式消息传递和流数据平台 . 但他们如何比较？在功能和性能方面我应该何时更喜欢一个？ Pulsar（和Kafka一样）在流媒体方面是否更加优秀，而RocketMQ（如ActiveMQ）在消息传递方面更加优秀？ -
1 votesanswersviews
在ActiveMQ中启动时，“Camel正在关闭”
我目前正在开发一个Java DSL路由，它将从JMS队列中获取消息，对其进行处理，并使用JPA将其放入数据库中 . 真的很简单： public void configure() { from("{{ribMessage.source}}") .split(xpath("/RibMessages/*")) ...