Welcome To Ask or Share your Answers For Others

Recent questions tagged RabbitMQ

0 votes

1.3k views

1 answer

rabbitmq - Message loss issues reported in production

We have received multiple message loss issues in PROD recently. Upon investigating such issues we have so far ... .com/questions/65841974/message-loss-issues-reported-in-production...

asked Oct 7, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.2k views

1 answer

rabbitmq - Is it possible for workers to consume based on topic?

I understand that you can send messages directly to a queue using channel.sendToQueue, and this creates a tasks-and- ... /is-it-possible-for-workers-to-consume-based-on-topic...

asked Oct 7, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.3k views

1 answer

rabbitmq - Sending last known good state to new consumers

I'm using rabbitmq to propagate a singular varying state to multiple consumers (one-to-many relationship). ... questions/65897619/sending-last-known-good-state-to-new-consumers...

asked Oct 7, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.2k views

1 answer

rabbitmq - How does the broker make sure that message is consumed only by one consumer?

I have a queue and have two consumers c1 and c2. My two consumers are up and running. When a message is ... the-broker-make-sure-that-message-is-consumed-only-by-one-consumer...

asked Oct 7, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.7k views

1 answer

rabbitmq - EasyNetQ Request-Response queue is not consumed by anyone

I'm working on a microservices system in which two microservices communicate with the Request-Response EasyNetQ lib ... /easynetq-request-response-queue-is-not-consumed-by-anyone...

asked Oct 7, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.7k views

1 answer

rabbitmq - C# Convert ReadOnlyMemory<byte> to byte[]

Given ReadOnlyMemory Struct I want to convert the stream into a string I have the following code: var ... .com/questions/61374796/c-sharp-convert-readonlymemorybyte-to-byte...

asked Oct 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.6k views

1 answer

rabbitmq - C# Convert ReadOnlyMemory<byte> to byte[]

Given ReadOnlyMemory Struct I want to convert the stream into a string I have the following code: var ... .com/questions/61374796/c-sharp-convert-readonlymemorybyte-to-byte...

asked Oct 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

2.0k views

1 answer

rabbitmq - Consume multiple queues in python / pika

I am trying to create a consumer that would subscribe to multiple queues, and then process messages as ... .com/questions/24510310/consume-multiple-queues-in-python-pika...

asked Oct 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

2.2k views

1 answer

rabbitmq - Consume multiple queues in python / pika

I am trying to create a consumer that would subscribe to multiple queues, and then process messages as ... .com/questions/24510310/consume-multiple-queues-in-python-pika...

asked Oct 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.4k views

1 answer

rabbitmq - Reverse scaling pods with KEDA - Kubernetes

Have been looking around for a way to reverse scale pods with KEDA, so reduce number of pods the ... stackoverflow.com/questions/66052169/reverse-scaling-pods-with-keda-kubernetes...

asked Oct 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.3k views

1 answer

rabbitmq - Reverse scaling pods with KEDA - Kubernetes

Have been looking around for a way to reverse scale pods with KEDA, so reduce number of pods the ... stackoverflow.com/questions/66052169/reverse-scaling-pods-with-keda-kubernetes...

asked Oct 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.4k views

1 answer

rabbitmq - Route message to queue based on one of the message's properties as routing key

I have a microservice A that publishes messages to an exchange E. Each one of those messages contain in one of its ... hear suggestions on how to do so based on existing tools....

asked Feb 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.6k views

1 answer

rabbitmq - What is the use of add_callback_threadsafe() method in pika?

From the description in the pika documentation, I can't quite get what add_callback_threadsafe() method does. It says, " ... ack_message() method after the time.sleep() is over?...

asked Feb 6, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

2.2k views

1 answer

rabbitmq - rabbitmqadmin is not recognized on windows

'rabbitmqadmin' is not recognized as an internal or external command, operable program or batch file. I tried ... t find the folder that contains rabbitmqadmin file on windows...

asked Jan 29, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.5k views

1 answer

rabbitmq 消息发布与订阅

客户端(安卓跟IOS)用mqtt协议订阅消息，然后管理后台用amqp来发送消息，但是发现用ampq协议来发送西消息，mqtt端接收不到，如果用mqtt来发送是没有问题的，代码就是用官方的测试代码如下： // ... ) { fmt.Printf("* [%s] >> %s ", msg.Topic(), string(msg.Payload())) })...

asked Jan 27, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.5k views

1 answer

rabbitmq php basic_consume 怎么在没有消息接收的时候退出脚本

require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLibConnectionAMQPStreamConnection; $connection = new AMQPStreamConnection('localhost', 5672, ' ... ，怎么会php脚本一直卡住，不会停止退出呢...

asked Jan 27, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.4k views

1 answer

rabbitmq - Could not load module C:Program Fileserl-23.1erts-11.1inerlexec.dll

Post Rabbit MQ Upgrade, Rabbit MQ service is not coming up on startup. The error message that shows up is : ... .dll. Failed to set Global Policy message-TTL on rabbit@HOSTNAME...

asked Jan 27, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

1.4k views

1 answer

rabbitmq - Could not load module C:Program Fileserl-23.1erts-11.1inerlexec.dll

Post Rabbit MQ Upgrade, Rabbit MQ service is not coming up on startup. The error message that shows up is : ... .dll. Failed to set Global Policy message-TTL on rabbit@HOSTNAME...

asked Jan 27, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

2.8k views

1 answer

rabbitmq - Amazon Availability Zone Latency

We have a system setup on Amazon EC2's, divided between 2 availability zones. In our setup, we have a single RabbitMQ messaging ... , so I am limited in what I can see/adjust/etc....

asked Jan 27, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

3.9k views

1 answer

rabbitmq 怎么获取unack状态的消息内容

rabbitmq 怎么获取unack状态的消息内容...

asked Jan 25, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

4.2k views

1 answer

rabbitmq 社交类网站如何设计

例如A关注B，B发动态，推送给A， rabbitmq中是应该每个用户一个队列吗？然后其他的用户订阅这个队列吗？队列应该何时创建？在用户注册完成时还是登录时？网上找到的教程大部分都是简单的生产者，消费者，可以调通。但是类似实例比较少，如果有相似、相关的书籍或实例教程，请大侠推荐给我，非常感谢。### 问题描述...

asked Jan 25, 2021 in Technique[技术] by 深蓝 (71.8m points)

0 votes

4.0k views

1 answer

rabbitmq 延时消息计时不准确是什么原因？

这是go 写的一个延时处理的考试收卷延时消息 rabbitmq已安装了延时消息插件 examRecord.MyExamination.AnswerTime = 120 分钟 `delayInt := function.GenerateRangeNum(10, 100) //这是一个 ... ？还是什么原因，感觉时间越长，误差就越大，几分钟的时候没有这个情况 ...

asked Jan 25, 2021 in Technique[技术] by 深蓝 (71.8m points)

To see more, click for the full list of questions or popular tags.

...