带有JMS变压器的ActiveMQ AMQP，利用弹簧集成
我正在尝试建立一个准系统应用程序，并使用ActiveMQ的AMQP和JMS转换器来运行.我的客户端库是Spring Integration，但是，我无法在此配置中启动并运行基本示例. 有关AMQP上ActiveMQ的JMS转换器的详细信息: http://activemq.apache.org/amqp.html 主要测试应用 @IntegrationComponentScan
..
amqp相关内容
AMQP& Openwire-Activemq经纪人和2个不同的消费者
我有一个activeMQ代理，它同时支持amqp和openwire. Openwire的生产者(TCP，端口61616)是否有可能生产到具有使用amqp协议的使用者的队列? 或者我仅限于相同的协议消费者和生产者吗? 解决方案 是的，可以使用ActiveMQ与OpenWire JMS客户端和AMQP客户端进行互操作.保存消息的目的地不是单独的空格，因此，一种类型的客户端将消息放在队列中
..
如何对RabbitMQ服务器进行负载测试(使用JMeter，python或任何其他工具.)?
已被授予访问RabbitMQ服务器的权限，以便对其进行负载测试.我对服务器和AMQ协议是完全陌生的.我一直在网上进行调查，以了解有哪些不同的方法.到目前为止，我正在研究两种方法. JMeter；我找到了这个项目: https://github.com/jlavallee/JMeter- Rabbit-AMQP#build-dependencies .它给了我一个jar文件，可以创建JMete
..
使用Java和AMQP 1.0连接到Windows Server（1.1）上的Service Bus
我要问的问题是这里。 David Ingham在回答此Microsoft文档时给出了答案。 Sentinel已经确认解决方案有效。 然而，我遇到了同样的问题。我遵循Microsoft文档，但仍然有相同的问题。 存在冗余的风险，问题是当使用Qpid-JMS客户端库时（版本0.22或0.26）连接到Windows服务器上的服务总线（1.1）（ NOT Azure ）并遵循Microsoft
..
将消息从RabbitMQ转换为string / json
我目前正在努力解决一个简单的问题。我想从RabbitMQ收到一条消息，并将其转换为字符串（或稍后的json对象）。但我得到的只是字节。 消息对象将其自身显示为字符串 （正文：'{“cityId”：644}'; ID：null;内容：application / json;标题：{}; Exchange :; RoutingKey：pages.type。 index;回复：null; De
..
Spring-AMQP重新排队消息计数基于JVM吗？
我正在寻找rabbitmq文档，似乎rabbitmq没有处理消息重新传递计数。如果我要手动ACK / NACK消息，我需要将重试计数保留在内存中（例如，通过使用correlationId作为映射中的唯一键），或者通过在消息中设置我自己的标头，并重新传送它（因此将它放在队列的末尾） 但是，这是一个spring处理的情况。具体来说，我指的是RetryInterceptorBuilder.stat
..
从Java / Spring中检索RabbitMQ队列中未确认消息的数量
有没有办法返回未确认的消息数？ 我正在使用此代码获取队列中的消息数： DeclareOk declareOk = amqpAdmin.getRabbitTemplate（）。执行（ new ChannelCallback（）{ public DeclareOk doInRabbit（频道频道） 抛出异常{ return channel.queueDecl
..
使用RabbitMQ（Java客户端），有没有办法确定消费期间网络连接是否关闭？
我正在使用Java客户端在RHEL 5.3上使用RabbitMQ。我有2个节点（机器）。 Node1使用Java帮助程序类QueueingConsumer消耗来自Node2上队列的消息。 QueueingConsumer consumer = new QueueingConsumer（channel）; channel.basicConsume（“MyQueueOnNode2”，noA
..
RabbitMQ：消息保持“未确认”状态
我的Java应用程序向RabbitMQ交换发送消息，然后交换重定向消息到绑定队列。 我使用带有RabbitMQ的Springframework AMQP java插件。 问题：消息进入队列，但它仍处于“未确认”状态，它永远不会变为“Ready” ”。 可能是什么原因？ 解决方案 未确认的消息意味着消费者已经读过它，但是消费者从来没有向RabbitMQ经纪人发回ACK说它已经完
..
你如何编码Map< String，Object>使用协议缓冲区？
我正在尝试使用 Protocol Buffers 。 我的消息格式应包含Map entries ...但是如何编写.proto定义？ 据我所知，Protocol Buffers没有内置Map类型。我可以使用重复字段来模拟它。但我遇到的最大问题是，您需要定义所有类型。我希望我的信息灵活，所以我不能指定类型。 任何想法？ 解决方案 我要用一个元
..
RabbitMQ：快速的生产者和缓慢的消费者
我有一个应用程序使用RabbitMQ作为消息队列在两个组件之间发送/接收消息：发送方和接收方。发件人以非常快的方式发送消息。接收器接收消息然后执行一些非常耗时的任务（主要是针对非常大的数据大小的数据库写入）。由于接收器需要很长时间才能完成任务，然后检索队列中的下一条消息，因此发送方将继续快速填满队列。所以我的问题是：这会导致消息队列溢出吗？ 消息使用者如下所示： public voi
..
RabbitMQ使用者是否可以配置为仅使用相同消息的已定义尝试次数
RabbitMQ能否以某种方式运行，我可以定义我的消费者它有限制使用相同的消息。即我的消费者用enqueue = true做一个基本的Reject。并且它会无限地继续听同样的信息。我不是在谈论队列方面的TTL。但是对消费者的控制/配置告诉我只想消耗它5次，然后将其发送到另一个队列。这可以实现吗？ 解决方案 这可以在应用程序级别或通过 TTL 和死信交换。在经纪人方面你不想知道你想要什么（我
..
如何让Spring RabbitMQ创建一个新的Queue？
在使用rabbit-mq的（有限）经验中，如果为尚不存在的队列创建新的侦听器，则会自动创建队列。我正在尝试使用带有rabbit-mq的Spring AMQP项目来设置一个监听器，而我正在收到错误。这是我的xml配置：
..
Spring集成 - Queue / Poller似乎在没有任何动作的情况下耗尽线程池
我有一个Spring集成应用程序，附加到AMQP代理。 我想从amqp队列接收消息，并更新db记录。 为了提高性能，我有一个工作池允许同时进行多个更新。 我有以下内容配置：
..
如何实现Spring AMQP Listener Container中的并发性？
我的容器XML配置：
..
Objective-C RabbitMQ客户端不将消息发布到队列
我正在尝试使用RabbitMQ for iOS创建消息传递应用程序。 我正在使用RabbitMQ-C客户端库的目标c的包装类。 https://github.com/profmaad/librabbitmq-objc Exchange，Queue&队列绑定都没问题但是我的代码没有向RabbitMQ服务器发布消息。请帮帮我，有什么问题？ 这是我的代码： NSError *
..
AMQP Amqp绑定IIS / WAS问题？
当前雇主的设置在Java平台上有一组后台功能，在两个独立的基于.NET的平台上有另一组功能。没有整体架构师。 Java家伙决定使用.NET QPID和AMQP进行消息传递，可能是他们自己的.NET系统和其他外部系统。 .NET体系结构涉及IIS / WAS和Windows Server AppFabric中托管的WCF服务。 如果有任何可能的陷阱，有没有人有AmqpBinding
..
面向服务的体系结构 - AMQP或HTTP
一点背景。 非常大的单片Django应用程序。所有组件都使用相同的数据库。我们需要分离服务，以便我们可以独立升级系统的某些部分而不影响其余部分。 我们使用RabbitMQ作为Celery的经纪人。 现在我们有两个选择： 使用REST接口的HTTP服务。 通过AMQP的JSONRPC到事件循环服务 我的团队倾向于HTTP，因为这是他们所熟悉的，但我认为使用RPC而非A
..
java - spring-amqp中消费者同步回复消息有没有更简单的方法？
问 题 amqp中使用 provider使用sendAndReceive可以等待消费者取得返回值 consumer使用receiveAndReply，并添加监听器，可以取得provider的message处理并回复 当消息是异步时，直接注册监听器实现onMessage(）方法即可。 但是onMessage()方法的返回值是void 那么如果要实现provider同步的功能
..
AMQP延迟传递和防止重复的消息
我有一个系统会偶尔生成消息，我只想每5分钟提交一次或一个消息。如果没有生成消息，队列消费者将不会处理任何内容。如果在5分钟内生成了一百个相同的消息，我只想要其中一个消息从队列中消费。 我正在使用AMQP（RabbitMQ），有没有办法要在rabbitmq或AMQP协议中完成这个？我可以检查一个队列的内容，以确保我不插入重复的？看来，队列检查是一个坏主意，通常不应该对消息系统做些什么。
..