Category "rabbitmq"

Re-queue message on exception

I'm looking for a solid way of re-queuing messages that couldn't be handled properly - at this time. I've been looking at http://dotnetcodr.com/2014/06/16/rabb

Add a header when sending a message with php-enqueue and RabbitMQ

I am trying to send a header using php-enqueue bundle I'm trying this: public function __construct( ProducerInterface $producer ) { parent::__constru

How to do error handling with EasyNetQ / RabbitMQ

I'm using RabbitMQ in C# with the EasyNetQ library. I'm using a pub/sub pattern here. I still have a few issues that I hope anyone can help me with: When there

Routing Dead-Lettered Messages

Is there a way in EasyNetQ to set the routing key [x-dead-letter-routing-key] argument when creating a Queue? (as far as I can see you can only set a DeadLetter

Confusion on AsyncAPI AMQP binding for subscribe operation

I have a server which publishes rabbitmq messages on a exchange, so I tried to create following async api specs for this - asyncapi: 2.3.0 info: title: Hello

Configuring rabbitmq with spring4 stomp and socksjs application

I am having issue with spring 4+Stomp+socks js app. It was working fine with simple message broker but when switch to rabbitmq it is not working and could not s

RabbitMQ set_permissions syntax

I've installed rabbitmq and it's running. I've successfully add_user as well as add_vhost. But in the next step of the documentation it says to set_permissions

RabbitMQ how to change ownership of an ha queue that did not migrate when node left cluster

I have a three-node RabbitMQ cluster (version 3.4.4 on Ubuntu 14.04.3) with approximately 80 queues, 40 of which are ha queues (policy {"ha-mode":"exactly","ha-

django errno 104 Connection reset by peer

I am trying to run my django server on an Ubuntu instance on AWS EC2. I am using gunicorn to run the server like this : gunicorn --workers 4 --bind 127.0.0.1:8

nova services fails intermittently to connect to rabbitmq with timeout error

I am using Openstack Pike with RabbitMQ 3.6.5 on Erlang 18.3.4.4 as the messaging queue. When the nova services are restarted, one of the nova services (mostly

rabbitmq showing wrong disk free limit in management console

as the title says, I have a problem, that the rabbitmq shows (and thinks) that there is more space available, as I told him. I'm running 2 instances of rabbitmq

"PLAIN login refused: User authentication failed" after upgrading RabbitMQ and Erlang

I've just tryed upgrading my RabbitMQ from 3.9.8 to 3.9.14, as well as updating Erlang from 23.3 to 24.3.3 (according to RabbitMQ documentation, RabbitMQ v3.9.1

RabbitMQ and round robin topic exchanges

I'm seeking some advise as to how best configure my rabbitMQ exchanges. I'm trying to use a topic exchange in a round robin methodology. Each consumer has its

RabbitMQ Sample not working in WPF

I'm trying to use rabbitMQ under a WPF application.I've followed the sample that are present on rabbitmq site. The sender is a console application that does

How to send RPC replyTo - NestJs Rabbitmq

I have a simple NestJs Microservice application that is listening for messages from a Rabbitmq service. async function bootstrap() { dotenv.config(); // TO

How to create a queue in RabbitMQ upon startup

I am trying to start RMQ inside docker container, with precreated queue qwer. Prior to this, I was using simple docker-compose.yml file: rabbit: image: ra