amqp 相关问题

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

RabbitMQ的NACK消息

我的经验:在发布/订阅的情况下,如果用户的NACK消息,该消息NACKED立即在队列前重新排队,这将是下一个消息的用户...

回答 3 投票 0

Laravel:听AMQP队列

如何实现laravel监听队列?我使用AMQP库在RabbitMQ的文档,这看起来像:$连接=新AMQPStreamConnection(“localhost”的,5672,“客人”,“客人”); $ ...

回答 1 投票 2

@RabittListener忽略routingKey

在制片方我送序列化为JSON字符串多个对象类型。区分的目的,我要送的类名作为路由密钥。在消费方面我尝试使用...

回答 1 投票 0

使用Apache骆驼将消息发送到天青Servicebus队列

我需要将消息发送到Azure中服务总线的队列。我使用HTTP POST将发送邮件,但我需要提高我的流量,然后我决定测试AMQP协议。代码如下:公...

回答 1 投票 0

如何修复AMQP错误窗口操作系统上运行PHP 7.2.2?

我下载php_amqp-1.9.4-7.2-NTS-VC15-x64和php_amqp-1.9.4-7.2-TS-VC15-x64和都尝试,但上运行的php.exe -m我得到以下错误。警告:PHP启动:无法加载动态...

回答 1 投票 1

的RabbitMQ AMQP - 听ACK从消费信息

我在同一台机器上生产商和经纪商。生产者发送消息如下所示:信道= connection.createChannel(); //创建一个持久的队列(如果尚未存在)channel.queueDeclare(...

回答 1 投票 4

如何正确地配置和运行远程芹菜工人?

我是新来的芹菜,可以做一些错误,但我已经花了很多试图找出如何正确配置芹菜。所以,在我的环境我有2个远程服务器;一个是主(...

回答 2 投票 1

如何在JMeter中从AMQP请求中提取数据

我已经使用AMQP Publisher在RabbitMQ中发布消息,然后使用AMQP Consumer作为侦听器。在“查看结果树”中,来自队列的消息显示在AMQP使用者的“请求”选项卡中。 ...

回答 1 投票 -1

使用发布者确认设置默认超时

我想实现配置了超时的AMQP发布者确认的示例。像这样:private final CountDownLatch confirmLatch = new CountDownLatch(1); ...

回答 1 投票 2

如何在Windows上安装amqp

当我在命令行中键入pecl / amqp时,我遇到此错误:pear install pecl / amqp警告:php_bin C:\ xampp \ php。\ php.exe似乎有一个后缀。\ php.exe,但是配置...

回答 3 投票 2

Apache Camel JMS / AMQP组件仅在需要时才创建目标队列

我目前正在开发一个使用Camel和Spring Boot的Integration应用程序。集成应用程序中有一个camel路由,它接收来自Artemis源代理的消息......

回答 2 投票 0

使用amqp扩展将消息从PostgreSQL发布到RabbitMQ时出错 - 在代理1上登录失败

我试图从PostgreSQL发布消息到RabbitMQ(都在Docker上运行)SELECT amqp.publish(1,'amqp.direct','EMAIL','message');但它返回false和警告消息:警告:...

回答 1 投票 0

RabbitMQ Exchange保证

我试图理解RabbitMQ在发布方面的保证 - 到目前为止没有成功 - 我想知道是否有人可以帮我解决这个问题:Bindings Exchange A - > Exchange B ......

回答 1 投票 0

Ramdom com.rabbitmq.client.ShutdownSignalException:连接错误

我们有一个应用程序,我们使用Spring-AMQP通过AMQP连接到远程服务器。最近,随机,我们收到连接错误。这些错误每天发生一次或两次......

回答 1 投票 0

在ChunkProcessorChunkHandler上找不到Spring Batch SpelEvaluationException方法

我有一个通过RabbitMQ执行远程分块的Spring Batch作业基本上,有两个应用程序master和worker,每个都是一个spring-boot应用程序。主配置后:@Bean public ...

回答 1 投票 0

RabbitMQ破坏了管道错误或丢失了消息

使用pika库的BlockingConnection连接到RabbitMQ,我偶尔会在发布消息时出错:致命套接字错误:错误(32,'破管')这是一个非常简单的...

回答 2 投票 5

RabbitMQ在处理长时间运行的任务时关闭连接,超时设置产生错误

我正在使用RabbitMQ生产者向消费者发送长时间运行的任务(30分钟+)。问题是当与服务器的连接关闭并且...时,消费者仍在处理任务。

回答 2 投票 11

套接字连接ActiveMQ与.Net

我有一个任务,我需要在ActiveMQ队列和.Net应用程序之间建立连接。我正在使用AMQP.Net Lite插件。但是我需要.Net的接收器......

回答 1 投票 0

在TomCat上没有配置的Task Executor的DirectMessageListenerContainer?

我正在为我的消息传递应用程序设置DirectMessageListenerContainer。我正在与Tomcat,Spring,AMQP合作。文档有这个警告https://docs.spring.io/spring-amqp/reference/#threading ...

回答 1 投票 0

Rabbit为AMQP 1.0消息节省了额外的字节

我有一个环境,其中一些AMQP 1.0和一些AMQP 0.9.1客户端需要写入/读取RabbitMQ队列。我启用了AMQP 1.0 Rabbit插件,它正在工作,但我在体内得到了额外的字节...

回答 1 投票 1

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