Tag: activemq

哪个embedded式消息系统 – > ActiveMQ或者HornetQ: 我将不胜感激关于两个消息系统中的哪一个的一般指针和意见更容易pipe理有一些需要知道和避免的陷阱或魔法的东西具有较less的整体依赖性很简单的工作。

从ActiveMQ切换到RabbitMQ: 我目前正在使用ActiveMQ来满足我的消息需求; 除了几个db失败之外，它运行良好。不过，我至less考虑试用RabbitMQ。但在此之前，我想了解以下内容： RabbitMQ与ActiveMQ有什么不同？ RabbitMQ比ActiveMQ做得更好还是更差？比较而言，RabbitMQconfiguration有多么简单/困难？ RabbitMQ与Spring的整合程度如何？使用ActiveMQ，我只需将一个连接工厂Bean连接到一个JmsTemplate然后使用DefaultMessageListener bean将队列连接到它们各自的处理程序。我可以用RabbitMQ做同样的事吗？

Java消息传递：ActiveMQ，Mule，ServiceMix和Camel之间的区别: 我是Messaging的新手，想知道ActiveMQ ， Mule ， ServiceMix和Camel之间的区别任何人都知道这些产品是如何不同的？提前致谢！编辑：也想知道任何好的地方/资源来学习这些东西。

ActiveMQ：如何在使用临时队列时处理代理故障转移: 在我的JMS应用程序上，我们使用生产者上的临时队列来接收消费者应用程序的回复。我在这个线程中提到了完全相同的问题： http : //activemq.2283324.n4.nabble.com/jira-Created-AMQ-3336-Temporary-Destination-errors-on-HA-failover-in -broker-networking与故障转移-TT-td3551034.html＃a3612738 每当我在我的networking中重新启动一个任意的代理时，我在使用消息应用程序日志中收到许多像这样的错误，同时尝试将答复发送到临时队列： javax.jms.InvalidDestinationException: Cannot publish to a deleted Destination: temp-queue://ID:… 然后，我看到加里在那里build议使用的回应 jms.watchTopicAdvisories=false 作为客户端brokerURL上的url参数。我立即用这个额外的参数改变了我的客户经纪人url。但是，现在我看到像这样的错误，当我重新启动networking中的经纪人进行此故障转移testing： javax.jms.JMSException: The destination temp-queue: //ID:client.host-65070-1308610734958-2:1:1 does not exist. 我正在使用ActiveMQ 5.5版本。而我的客户代理url如下所示： failover:(tcp://amq-host1:61616,tcp://amq-host2.tred.aol.com:61616,tcp://amq-host3:61616,tcp://amq-host4:61616)?jms.useAsyncSend=true&timeout=5000&jms.watchTopicAdvisories=false 另外这里是我的四个经纪人之一的activemqconfigurationXML： amq1.xml 这里有人可以看看这个问题，并build议我在这个设置中犯了什么错误。更新：进一步澄清我在我的代码中如何做请求 – 响应：我已经使用每个生产者的目的地（即临时队列），并将其设置在每封邮件的回复标题中。我已经在JMSCorrelationID标头中发送了每个消息的唯一关联标识符。据我所知即使骆驼和Spring也在使用临时队列来请求响应机制。唯一不同的是，Spring JMS实现为每个消息创build和销毁临时队列，而我为生产者的生命周期创build临时队列。当客户端（生产者）应用程序closures时，此临时队列被销毁，或者当AMQ代理程序意识到没有活动的生产者与此临时队列连接时，此临时队列被销毁。我已经在Producer端的每条消息上设置了一个消息过期，这样消息就不会在队列中被搁置太久（60秒）。

ActiveMQ vs阿波罗vs卡夫卡: 我以前没有任何关于* MQ的经验，我正在寻求build立关于JMS和消息队列的知识。那样的话，我想知道我应该从ActiveMQ开始，还是完全“忽略”它，并开始自学阿波罗。 Apollo与ActiveMQ一样function齐全吗？它是否实现JMS 2.0（我看到ActiveMQ被困在1.1）？我会错过一些非常重要的东西吗？另外，卡夫卡如何比较这两个解决scheme？

什么是ActiveMQ用于？: 我查了一下，然后发送消息给它。但为什么？为什么不使用数据库？必须有ActiveMQ有这个数据库不要？

JMS主题vs队列: 我想知道JMS Queue和JMS Topic之间的区别。从ActiveMQ页面，它说主题在JMS中，Topic实现发布和订阅语义。当您发布消息时，会发送给所有感兴趣的订阅者，因此零到多个订阅者都将收到该消息的副本。只有在经纪人收到消息时具有有效订阅的订阅者才能获得该消息的副本。队列 JMS队列实现负载平衡器语义。一条消息将被一个消费者接收。如果在发送消息时没有消费者可用，则将一直保留到消费者可用于处理消息。如果消费者收到消息，并且在closures之前没有确认消息，消息将被重新发送给另一个消费者。队列可以让许多消费者在可用消费者之间对消息进行负载平衡。我正在寻找一个“东西”，它将以与ActiveMQ代理收到消息的顺序相同的顺序将消息副本发送给每个用户。有什么想法吗？

ActiveMQ或RabbitMQ或ZeroMQ或: 我们有兴趣听听ActiveMQ vs RabbitMQ vs ZeroMQ的优缺点。关于任何其他有趣的消息队列的信息也是受欢迎的。

平台服务与Activemq中间件集成服务: 我有一个用JAX-RS和jersey开发的Restful服务API。我已经在TOMCAT 7中部署了相同的部分。现在我想实现Activemq，以便将所有请求保留在队列中并处理请求资源。如何做到这一点，并与tomcat7集成。如何将ActiveMq与Tomcat7或我的rest服务webapp集成。如何致电该服务。重要说明： – 在Api里面，我使用FilterChaining的概念来保证安全性，在validation了主叫方之后，我只是把请求转发给资源。为此，我已经添加到web.xml中。谢谢这是我的class级 – public class LimitFilter implements Filter { public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { //some authentication if (true) { // let the request through and process as usual chain.doFilter(request, response); } else { // handle limit case, eg […]

如何在Java密钥库中导入现有的x509证书和私钥以在SSL中使用？: 我有这个在activemq配置 <sslContext> <sslContext keyStore="file:/home/alex/work/amq/broker.ks" keyStorePassword="password" trustStore="file:${activemq.base}/conf/broker.ts" trustStorePassword="password"/> </sslContext> 我有一对x509证书和一个密钥文件如何导入这两个用于ssl和ssl + stomp连接器？所有的例子，我可以谷歌总是自己生成密钥，但我已经有一个关键。我努力了 keytool -import -keystore ./broker.ks -file mycert.crt 但是这只导入证书而不是密钥文件和结果 2009-05-25 13:16:24,270 [localhost:61612] ERROR TransportConnector – Could not accept connection : No available certificate or key corresponds to the SSL cipher suites which are enabled. 我已经尝试连接证书和密钥，但得到了相同的结果我如何导入密钥？