-
无法通过jmeter(amqp使用者采样器)使用队列中的消息
我尝试通过jmeter使用包含队列名称,交换和路由键的消息,但观察到以下错误 <blockquote> 2019-11- -
如何使用SOCKS代理或Java中的任何其他代理通过SSL创建与AMQP队列的连接
使用SOCKS代理或任何其他代理,对于无法直接访问Internet或防火墙禁止amqps连接端口的环境,有什么方法 -
调用apply_async时,芹菜不会返回或失败。与celery_beat一起使用
我在使用apply_async调用芹菜任务时遇到问题。 我在settings.py中: <pre><code>CELERY_BROKER_TRANSPORT_OPTIONS = {&# -
Docker服务冻结,没有日志
我有一个用Go编写的使用者,它使用来自Rabbitmq的消息,然后连接两个不同的DB并完成一些工作。 我正在 -
带有群集客户端的AMQP(RabbitMQ)发布/订阅
我们将开发一个订阅AMQP频道的客户端,但是该客户端将被集群化(在Kubernetes中),并且我们只希望一个 -
amqp-connection-manager断开连接不恢复
amqp-connection-manager:3.0.0 amqplib:0.5.5 我正在努力让amqp-connection-manager在断开连接后恢复。初始启 -
在RabbitMQ中可以将不同类型的交换绑定在一起吗?
我当前正在将消息发送到<code>Topic</code>交换机,在该交换机中,消息将根据匹配的路由键复制到队列中 -
AMQP的DistributionMode是否类似于Tibco中的自动确认?
我们正在从Tibco迁移,开始使用ActiveMQ Artemis。 Tibco上有几种可用的ack设置,但在Artemis中我们没有找到与 -
在RabbitMQ集群中进行快速队列绑定的建议设置是什么
当使用<em> com.rabbit.mq:amqp-client:5.4.3 </em>将RabbitMQ集群中的队列绑定时,如果将许多队列绑定到一个交换中 -
一个通道中的多个交换机或一个交换机中的多个通道
我有一个场景,其中有多个源将消息发送到不同的队列,并且每个源都可以将消息发送到多个队列。我 -
Apache Camel将多种资源组合成一条消息
我想问一下,我可以将多个来源(队列)组合成一条消息吗? 例如,我有下面的json <pre><code>{ -
使用AMQP实施Webhook
我正在尝试开发一个Webhook,它将在我们平台中发生的任何事件通知我们的客户。 我们可以利用RabbitMQ来 -
使用不同的交换类型动态创建队列
我正在尝试编写一种使用现有交换名称,新队列名称和路由键作为参数创建新队列的方法。交换的类型 -
rabbitmq / amqp直接回复并返回通知
我使用Rabbitmq从各种输入源(websocket,rest等)向我的工作人员传递消息。每个工作人员在共享交换机上 -
Tsung + AMQP发布带有标题和属性的示例
有没有人试图用Tsung加载测试Rabbitmq?我看到了一个示例<a href="https://github.com/processone/tsung/blob/develop/exampl -
AMP和AMQP之间的区别?
顾名思义,高级消息队列协议(AMQP)和异步消息协议(AMP)是协议。 我真的找不到两者之间的区 -
如何指定使用Spring Cloud Stream向RabbitMQ发送消息的超时时间?
我们在发送消息的过程中遇到了网络问题,这导致所有线程都处于“阻塞”状态。我们正在使用<code>org.s -
为什么Apache Camel路由订阅者突然停止接收来自Quarkus Publisher应用程序的消息?
<strong> <em>问题:</em> </strong> <em>为什么Quarkus发布者继续发布,为什么Apache Camel路由订阅者突然 -
*“ Flowable.interval”是否不支持“ TimeUnit.MILLISECONDS”?
<strong> <em>问题</em> </strong> <em>“ Flowable.interval”不支持“ TimeUnit.MILLISECONDS”吗?</em> <em> -
如何使用Alpakka AMQP创建请求-响应?
我目前正在与Akka一起工作,需要使用异步请求-应答模式通过消息代理(RabbitMQ)进行通信的两种独立服 -
如何获取Java中RabbitMQ的当前IP地址?
我有一个带有地址列表的connectionFactory(org.springframework.amqp.rabbit.connection) <pre><code> @Bean(name = " -
如何使用AMQPNetLite使用.NET Client应用程序设置PRE_ACKNOWLEDGE模式
我们正在使用使用AMQPNetLite库的.NET客户端连接到ActiveMQ Artemis。我需要设置预确认模式,并从文档中了解 -
等效于非HTTP协议(例如AMQP)的Open API规范
我们对HTTP API使用开放API规范(OAS)。我们在微服务/应用程序中使用它们来生成Swagger UI,但它对于文档 -
无法使用amqps连接到RabbitMQ代理
嗨,我想使用amqps连接到Rabbitmq代理,但是似乎无法正常工作。 <pre><code>ConnectionFactory cf = new ConnectionF -
从golang通过
我已经在本地Windows VM上安装了IBM MQ(8.0.0.4),并按照文档中的说明启用了AMQP(<a href="https://www.ibm.com/sup -
如何在Nginx的http使用者中解析RabbitMQ的amqp请求
我有一个设计要求,我必须在nginx中处理RabbitMQ的AMQP请求,并将其代理传递到此处的更下游,nginx充当Rabb -
为什么Apache QPID Broker队列声明参数“ x-qpid-dlq-enabled”无法正常运行?
我正在尝试将Apache QPID Broker(版本7.1.6)作为嵌入式运行在内存代理中,并在代理中声明队列,并将队列 -
使用Apache.NMS.AMQP从.NET连接到AmazonMQ(ActiveMQ)代理
我无法使用Apache.NMS.AMQP客户端(<a href="https://github.com/apache/activemq-nms-amqp" rel="nofollow noreferrer">GitHub repo</a> -
SimpleMessageListenerContainer无法正确调用消息处理程序
我正在尝试在Spring Boot应用程序中侦听RabbitMq队列。在我的<code>RabbitConfig.java</code>文件中,我有以下bean: -
动态队列和侦听器,消息未发送?
兔子配置: <pre><code>package com.rabbitMQ; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframewor