Questions tagged [rabbitmq]
RabbitMQ is an open source robust messaging software for applications based on the AMQP protocol.
21
questions
4
votes
0
answers
133
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 ...
- 41
1
vote
1
answer
578
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-...
- 719
1
vote
1
answer
1k
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 ...
- 135
2
votes
0
answers
25
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 ...
- 161
5
votes
0
answers
654
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 ...
- 181
3
votes
0
answers
190
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,121
-1
votes
1
answer
98
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):
...
- 713
2
votes
0
answers
1k
views
Uninstalling Erlang and RabbitMQ, using Write-Verbose to ensure sequencing
I'm new at PowerShell and I like it.
I had the change to write a script that uninstall Erlang and RabbitMQ and I want the same script to then remove the Erlang folder and the RabbitMQ folder.
But ...
4
votes
0
answers
458
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 ...
- 141
7
votes
1
answer
4k
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?
...
- 173
-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....
- 99
1
vote
0
answers
394
views
Twitter clone in NodeJS
I have written a small Twitter clone using NodeJs, MongoDB and RabbitMQ, which you can find here.
I started this project because I wanted to get a better understanding of both NodeJs and Rabbit. I'm ...
- 121
2
votes
0
answers
354
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:
...
- 167
3
votes
1
answer
639
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, ...
- 257
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:
...
- 315
3
votes
0
answers
639
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 ...
- 315
7
votes
1
answer
7k
views
RabbitMQ wrapper to work in a concurrent environment
I'm developing a common library for my organisation that will be used across different services by different teams. The library is a simple wrapper for RabbitMQ.
Some services will only be producers, ...
4
votes
2
answers
605
views
Bulk HTTP request queue consumer
Today I had to write a small tool to help me send HTTP requests in bulk. Rabbit was overloading my server, so I decided to change my consumers to buffer the contents of the request, before sending. ...
- 111
4
votes
1
answer
929
views
RabbitMQ Consumer
I am playing with RabbitMQ and .NET and found myself duplicating the connection initialization logic in all of the consumers.
Created the Consumer in order to ...
- 817
6
votes
3
answers
1k
views
Connecting to RabbitMQ
I would like a review for this connection to RabbitMQ. I just developed it and seems to be working well, but I would like another set of eyes on it before putting this on the sever.
...
11
votes
2
answers
4k
views
NodeJS broker between MongoDB and RabbitMQ
I wrote a small program that aims to take some data from the MongoDB database and put them in the RabbitMQ queue.
I tried to use only promise style but I am a beginner in JavaScript. Could you please ...
- 113