Questions tagged [rabbitmq]
RabbitMQ is an open source robust messaging software for applications based on the AMQP protocol.
20 questions
- Bountied 0
- Unanswered
- Frequent
- Score
- Trending
- Week
- Month
- Unanswered (my tags)
1
vote
0
answers
37
views
Spring Boot RabbitMQ Publisher Configuration for Sending JSON Messages
The publisher class:
...
4
votes
0
answers
177
views
Python – RabbitMQ/Pika basic manager in OOP style
I created some classes for easier management of RabbitMQ and to practice OOP in Python.
I would care about a few issues and any code advice would be appreciated :)
is it a good practice to use the ...
1
vote
1
answer
864
views
RabbitMQ ConnectionFactory wrapper
This is a wrapper around RabbitMQ.Client's ConnectionFactory. Here is the simplest Producer/Consumer RabbitMQ example https://github.com/delaneybrian/jumpstartCS-...
1
vote
1
answer
2k
views
Go Routine: Multiple Consumers to RabbitMQ
Here I'm trying to create the multiple consumers of rabbitmq queue using the goroutines. Also, I'm trying to achieve a graceful shutdown. Is the following approach create any memory leaks? or is it ...
2
votes
0
answers
28
views
npm package as amqp client helper
I would like to build a common helper for my application that will manage all the amqplib calls from all of my nodeJS microservices.
I would like to import my amqplibHelper to every microservice and ...
5
votes
0
answers
731
views
Liveness monitor : python and RabbitMQ together through Pika
I'm a beginner using Python, and I'm trying to implement a functionality of a monitor program already developed by an other programmer.
This program is working on a Windows machine (made by Inno ...
3
votes
0
answers
200
views
A simple functional F# wrapper for EasyNetQ
This is my first attempt at creating a small module to wrap the .NET library EasyNetQ in F# to make it more functional.
I am pretty new to F# and I would like to get feedbacks on everything: types, ...
-1
votes
1
answer
122
views
Anonymous function uses variable declared outside the function [closed]
Please see the code below, which I have taken and adapted from here and here (RPCServer and RPCClient):
...
4
votes
0
answers
495
views
Rabbit MQ long running de-queue by using IEnumerable yield return
The following code attempts to efficiently stream queue messages to processing units using an IEnumerable yield return.
create a blocking collection to handle the stream
create a linked token source ...
7
votes
1
answer
5k
views
golang rabbitmq message consumer
I need to process rabbitmq messages with golang with worker style,
is this correct way to process rabbitmq messages with golang?
...
-1
votes
1
answer
2k
views
Javascript RabbitMQ -> Pull Single Message [closed]
I'm trying to pull a single message off of rabbitmq, process it, and acknowledge that single message. I don't want it to continue after acknowledgement pulling messages off the queue. If I don't do ch....
2
votes
0
answers
375
views
Async MQ ping-pong
I have two sender-receivers. The first is written on Python and the second is on Golang. I used official sources of RabbitMQ documentation here and here.
Python code:
...
4
votes
1
answer
697
views
Convert MQTT messages and publish them to Rabbit MQ
I'm looking for advice on how to find a balance between keeping this code flexible/maintainable, while also keeping it readable.
It reads MQTT messages in JSON format from four different topics, ...
3
votes
0
answers
1k
views
Convert a curl command into Ruby
I had a curl command which I converted using this.
This is the Ruby script:
...
3
votes
0
answers
658
views
Ruby script to to check the status of a rabbitmq queue and send alert
We are using a message broker called rabbitmq. The code checks the status of number of messages in q queue and sent messages. This is achieved by a curl request to a given API.The script has a sleep ...