amqp 相关问题

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

RabbitMQ Exchange保证

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

rabbitmq amqp rabbitmq-exchange

回答 1 投票 0

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

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

rabbitmq amqp spring-amqp

回答 1 投票 0

在ChunkProcessorChunkHandler上找不到Spring Batch SpelEvaluationException方法

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

spring-boot spring-integration spring-batch amqp

回答 1 投票 0

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

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

python rabbitmq amqp pika

回答 2 投票 5

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

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

python rabbitmq amqp pika python-pika

回答 2 投票 11

套接字连接ActiveMQ与.Net

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

activemq amqp amq

回答 1 投票 0

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

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

java tomcat rabbitmq amqp spring-rabbitmq

回答 1 投票 0

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

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

rabbitmq amqp

回答 1 投票 1

如何从RabbitMQ中删除队列绑定？

我正在使用RabbitMQ按主题将消息路由到感兴趣的订阅者。每个订阅者都有一个队列，我将队列绑定到他们感兴趣的主题。我想允许用户...

rabbitmq amqp py-amqplib

回答 3 投票 8

获取rabbitmq中的路由/绑定密钥

我有两个队列，两个绑定/路由键，我想根据路由/绑定密钥在消费者中写一个条件语句，如何获取它们的值？ var amqp = require（'amqplib / ...

javascript node.js rabbitmq amqp

回答 1 投票 0

芹菜可以在运行时刷新amqp连接参数吗？

我正在尝试用云AMQP建立芹菜经纪人。由于云AMQP服务只提供Java SDK，所以我用Python重写了加密代码，连接工作正常。但是，有......

python rabbitmq celery amqp cloudamqp

回答 1 投票 0

无法打开绑定到应用程序标头x-match表达式的接收器

我正在使用rhea（https://github.com/amqp/rhea），一个node.js库来开发AMQP 1.0客户端。我正在尝试使用x-match调整https://github.com/amqp/rhea/tree/master/examples/selector示例...

amqp qpid rhea

回答 1 投票 1

如何在ActiveMQ中使用AMQP python客户端

我使用amqp客户端连接ActiveMQ代理。 import amqp USER =“guest”PASSWORD =“guest”HOST ='localhost'PORT ='5672'host = HOST +“：”+ PORT conn = amqp.connection.Connection（host = host，...

python activemq amqp

回答 2 投票 1

ASP.NET CORE Web API与RabbitMQ（AMPQ）中的微服务通信

我正在尝试使用asp .net核心Web API实现微服务，并对RabbitMQ进行研发以与每个Web服务进行通信。关于我的项目，它是一个学习管理系统。当老师......

rabbitmq amqp asp.net-core-webapi

回答 1 投票 0

通过URL连接到RabbitMQ

我正在尝试连接到隐藏在nginx代理后面的rabbitmq。它被声明为：location ^〜/ rabbitmq / {proxy_pass http://127.0.0.1:5672/;问题是，我发现......

rabbitmq amqp easynetq

回答 1 投票 0

RabbitMQ消息的大小和类型

RabbitMQ队列中可以存储哪些消息？只有字符串？或者我可以选择我想要存储的类型：int，binary，string等？一条消息的最大大小是多少？有多少队列或交换......

queue rabbitmq message-queue amqp

回答 3 投票 88

使用AMQP可以实现路由方案，但不能使用JMS API

我在面对JMS vs RabbitMQ AMQP时遇到了很大麻烦，需要你的帮助。所以我的问题是 - 是否有一些场景可以使用AMQP 0.9.1协议解决但不能用JMS解决？一世'...

jms amqp

回答 1 投票 1

异步处理消息时的BasicAck

我正在尝试设置RabbitMQ消息队列，以便我可以发送消息以启动长时间运行的进程，并且还能够发送消息以在需要时取消长时间运行的进程。所以我 ...

c# rabbitmq amqp

回答 2 投票 3

我需要在我的单元Test中模拟一个RabbitMQ

我在我的项目中使用RabbitMQ。我在我的消费者中有rabbitMQ的客户端部分的代码，并且连接需要tls1.1来连接真实的MQ。我想在我的JUnit中测试这段代码......

java junit mocking rabbitmq amqp

回答 3 投票 8

从rabbitMQ发送消息到PostgreSQL

我知道可以将消息从PostgreSQL发送到RabbitMQ，但是可以将消息从RabbitMQ发送到PostgreSQL。现在我正在通过amqp插件为RabbitMQ提供一些...

database postgresql rabbitmq mqtt amqp

回答 1 投票 1

amqp 相关问题

最新问题