Category "rabbitmq"

How do I deserialize a dead lettered message when dead lettering changes the type?

I'm trying to write a dead letter handler service that reads messages off of a dead letter queue and then does something with the message based on the type, con

What are the differences between gRPC AsyncIO and RabbitMQ and when to use them?

I want to implement event-driven communication in my microservices architecture. For example, if event A happens, services X and Y would carry out certain thing

How to keep forked child process alive in node js

I want to create a rabbitmq cli running like foreverjs with node. It can spawn child_process and keep it running in the background and can communicate with chil

Google Pub Sub/Lite vs RabbitMQ

I would like to confront my understanding of google pubSub/lite vs RabbitMQ (using MQTT over WSS). My use case is that I need something like a topic exchange. T

Docker RabbitMQ in detached mode logging

I am running RabbitMQ in the docker container in detached mode. I am doing this so I can set some values using rabbitmqctl. I added tail -f /dev/null so the c

RabbitMQ nginx config

I have problem that entering RabbitMQ management page in server it asks on each requests basic auth login. I cannot resolve it so that i have not enter on each

How to publish raw json message to another application queue?

In my situation, I only need publish message from laravel application to available rabbitmq queue which created in another symfony application. I installed this

How to remove non-running nodes from RabbitMQ cluster

I need to delete all nodes that are not running in a RabbitMQ cluster via the command line. I have tried rabbitmqctl forget_cluster_node, but I'm not sure how t

How to modify spring-websocket to interface with broker via MQTT instead of STOMP?

I'm building a spring-websocket application that currently uses RabbitMQ as a message broker via the STOMP protocol. The rest of our organization mostly uses IB

Rabbitmq Sending message to only one service

I am building my application on a microservice model. Lets says There is one database on server D1 There is a user service hosted on server U1 There is a notifi

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