amqp 相关问题

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

AMQP-CPP>处理程序中的错误文件描述符

我正在尝试使用AMQP-CPP库进行消息传递,但是我无法使其工作。我想使用库中已经构建的类来实现通道,连接和处理程序。我从他们的例子开始......

回答 1 投票 1

节点Js / Typescript - AMQP消费者

我是第一次尝试使用node.js / typescript,并且在为一个兔子队列制作消费者时遇到了一些麻烦。代码:let amqp = require('amqp');让connection = amqp ....

回答 1 投票 1

编译WolfSSL的错误

我是新手,我正在尝试为Click Router编译静态库,目前是wolfSSL,我在Ubuntu 17.10上我遵循以下步骤:Clone wolfSSL GIT repo:cd clickDynCOAP git clone https:// .. 。

回答 1 投票 1

MessageListener onMessage方法中的Spring RabbitMQ断点

我在基于Spring RabbitMQ的应用程序的消费者端有这个代码 - 公共类MyReceiver实现了ChannelAwareMessageListener {public MyReceiver(){super(); } @ ...

回答 1 投票 0

暂时停止使用RabbitMQ消息并稍后恢复

我使用Java的rabbitmq-client(https://mvnrepository.com/artifact/com.rabbitmq/amqp-client),我需要实现以下场景:在接收Rabbit消息时,我可能需要暂停...

回答 1 投票 1

是否有AMQP实现具有稳定的C ++客户端库[重复]

是否有AMQP实现具有稳定的C ++客户端库

回答 4 投票 5

为什么二进制内存使用量会在rabbitmq上增长

如何找到二进制内存使用量增长的原因(取决于连接数)我使用了rabbitmqctl eval'[garbage_collect(P)|| P

回答 1 投票 3

Spring AMQP AcknowledgeMode.AUTO运行缓慢

我有一个生产者,每秒向RabbitMQ发送20条消息,而且我有一个消费者,它应该接收与它们产生的速度相同的消息。我有一些条件......

回答 1 投票 2

Mule ESB连接到RabbitMQ

我是Mule ESB 3.6(Anypoint Studio Community Edition 5.2)的新手。我正在研究mule和rabbitmq之间的沟通。 rabbitmq支持AMQP协议,mule有AMQP连接器,但它有效......

回答 2 投票 2

如何配置Spring Amqp @RabbitListener在队列不存在时不抛出异常?

这是我的@RabbitLister代码:@RabbitListener(queues = device。*)我希望这个监听器监听由我的代理上的设备创建的所有队列,其中*是设备的ID,如:device.1当前,...

回答 1 投票 0

使用RabbitMQ插件在Grails中创建队列运行时

我有一个系统,外部系统可以订阅我的系统生成的事件。系统用Grails 2编写,使用RabbitMQ插件进行内部消息传递。外部事件......

回答 3 投票 0

MicroServices - 通过AMQP与多个接收器场景进行异步通信

使用微服务方法,我有服务A有3个实例(A1,A2,A3),可以通过基于AMQP消息的异步通信与服务B通信,服务B有(B1,B2,B3)实例。例子,......

回答 2 投票 0

AMQP.Net Lite与POCO课程

我们正在使用Azure团队的https://github.com/Azure/amqpnetlite。描述说我们必须在消息总线上使用AmqpContract和AmqpMember属性类,如ActiveMQ。我们......

回答 1 投票 0

使用golang连接到Active MQ

Amazon MQ(Active MQ)说它适用于amqp,并且这里有一个go包https://github.com/streadway/amqp但是当我尝试拨打()时我得到这个错误异常(501)原因:“异常( 501)......

回答 2 投票 1

队列最大长度或TTL使用get但不消耗

我看到许多帖子询问限制队列长度。在我对Pika和RabbitMQ的实验中,如果我使用arguments = {'x-message-ttl':1000,'x-max-length':2,'x-overflow':'drop-head'}声明队列。 ..

回答 1 投票 1

从Azure Service Fabric群集模拟10,000个Azure IoT Hub设备连接

我们正在开发一个.Net Core服务,该服务将托管在Azure Service Fabric中。此SF服务需要通过它的AMQP 1.0 SSL TLS与在Azure IoT Hub中注册的10,000个设备进行交互...

回答 3 投票 1

MQLight Node.js客户端在空闲时间后停止接收消息。 MQ 8.0.0.3上的AMQP / MQ Light

我在使用Node.js客户端和IBM MQ 8.0.0.3服务器时遇到问题。我的Node.js应用程序接收消息就好了,但如果我让应用程序空闲几个小时(在这...

回答 1 投票 1

使用Spring RabbitMessagingTemplate发布消息时验证交换,路由密钥

有没有办法在使用RabbitMessagingTemplate发送消息时验证交换和路由密钥/队列?目前,有一个默认的交换和路由键,空白字符串和...

回答 1 投票 1

Celery:当排队太多时阻止添加更多任务

我有一个Flask REST API,它利用Celery来运行异步请求。想法是async = 1查询参数指示应该异步处理请求(返回任务ID ...

回答 1 投票 1

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