amqp 相关问题

AMQP是一种开放式消息传递标准。它为高性能企业消息传递定义了线级协议和语义框架。如果您正在使用特定代理(例如:[rabbitmq]),则AMQP标记可能是多余的。 AMQP不应与Apache [ActiveMQ]混淆

Apache QPID Broker队列为什么声明参数“ x-qpid-dlq-enabled”无法正常工作?

我正在尝试将Apache QPID Broker(版本7.1.6)作为嵌入式运行在内存代理中,并在该队列中将队列声明选项x-qpid-dlq-enabled设置为“ true”来声明一个队列。公共...

回答 1 投票 0

Amqpcpp未定义符号

我正在尝试从amqpcpp(代码片段)运行示例之一:int onCancel(AMQPMessage * message){AMQPQueue * q = message-> getQueue(); q->取消(message-> getConsumerTag()); ...

回答 2 投票 1

如何获得Java中RabbitMQ的当前IP地址?

我有一个ConnectionFactory(org.springframework.amqp.rabbit.connection),其地址列表为@Bean(name =“ mainConnectionFactory”)@Primary public ConnectionFactory ...

回答 1 投票 0

如何指定使用Spring Cloud Stream向RabbitMQ发送消息的超时时间?

我们在发送消息的过程中遇到了网络问题,这导致所有线程处于“阻塞”状态。我们正在使用org.springframework.cloud:spring-cloud-stream:2.0.1.RELEASE和org ....

回答 1 投票 0

rabbitmq / amqp直接回复并返回通知

我使用Rabbitmq从各种输入源(websocket,rest等)向我的工作人员传递消息。每个工作人员在共享交换机上侦听一堆不同的路由键。现在是...

回答 1 投票 -1

使用不同的交换类型动态创建队列

我正在尝试编写一种使用现有交换名称,新队列名称和路由键作为参数创建新队列的方法。交换的类型可能不同(直接,扇出,主题)。是...

回答 1 投票 0

能否在RabbitMQ中将不同类型的交换绑定在一起?

我当前正在将消息发送到主题交换机,在该交换机中,消息将根据匹配的路由密钥复制到队列中。我希望能够将其中一些消息复制到其他基于...的消费者...

回答 2 投票 0

带有Camel的Azure Service Bus(ASB),MessageProducer已关闭(amqp:link:detach-forced)

我正在使用Apache Camel和camel-amqp组件,以便与ASB队列进行通信。 [ ]

回答 1 投票 0

无法与rabbitmq建立ssl连接

我正在尝试与Rabbitmq代理建立ssl连接。我遵循此页面为我提供帮助,并且找到了我的错误,但是我不知道该由谁来解决。我被困在与经纪人的测试连接中:...

回答 1 投票 3

如何使用Java RabbitMQ和设置URI服务器?

我正在使用RabbitMQ Java API连接到RabbitMQ服务器。我想使用ConnectionFactory.setUri(...)配置要使用的服务器。它似乎在破坏虚拟主机。有一个默认的...

回答 3 投票 2

消息队列和应用程序结构

我已经阅读了文档,并且非常确定我了解基于AMQP的消息队列中存在的不同组件的概念。 但是,我很难将其映射到实际的面向服务的实现。 有人可以给出两种通过途径进行...

回答 1 投票 1

用芹菜花监测

由于Celery文档建议使用flower进行监控,我试图让它与托管的RabbitMQ提供程序 CloudAMQP 一起使用 我可以在CloudAMQP管理控制...

回答 1 投票 4

是否可以将自定义方法类型添加到protobuf服务?

当您使用protobuf描述服务时,可以添加rpc方法。是否可以编写一些扩展以使用自定义方法类型,例如:service SomeService {rpc SomeRPCMethod(Request)返回(...

回答 1 投票 1

RabbitMQ-从发布者那一侧找出一条消息已被消费者确认

我正在使用RabbitMQ作为MQ代理。是否可以收到所有队列都已确认某条消息的通知?也就是说,如果将其发送到5个队列,则会在...

回答 1 投票 5

RabbitMQ是否可以在没有任何队列的情况下保留直接交换消息?

[我想知道是否可能出现以下情况:创建直接类型的交换,然后使用路由键rk1将消息发布到该交换。之后:创建一个接收带有...的消息的队列,并带有...

回答 2 投票 0

RIF或基于时间的优先级队列的RabbitMQ支持

是否有任何方法可以使RabbitMQ队列表现为堆栈,即客户端获得队列中发布的最后一条消息(LIFO),而不是第一条消息?或者也可以将其设置为...

回答 1 投票 0

如何在Celery中创建具有不同并发性的任务?

以下任务有不同的要求。缓慢的任务应该只能一个接一个地执行。快速任务可以执行相同(或更多)操作,但应独立于慢速任务。 ...

回答 1 投票 0

它是好使用一个RabbitMQ的通道全部够程? [关闭]

我在做一个消息发布者和一个接收器/从RabbitMQ的队列。我打算使用一个RabbitMQ的渠道发布消息,一个用于读取,但我也希望我的代码是异步的,...

回答 2 投票 2

安装PHP扩展AMQP和librabbitMQ问题

我有一些问题,运行Linux的亚马逊AMI的机器上安装PHP扩展AMQP。我已经成功通过下载最新焦油安装librabbitmq-C(https://github.com/alanxz/rabbitmq-c)...

回答 1 投票 1

RabbitMQ AMQP消息和TIBCO 5.10

我们正在使用TIBCO 5,需要使用消息并将其发布到RabbitMQ AMQP消息。据我研究和测试,TIBCO 5中不支持AMQP消息,但是......>

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.