Questions tagged [rabbitmq]

RabbitMQ is an open source robust messaging software for applications based on the AMQP protocol.

Filter by
Sorted by
Tagged with
2
votes
0answers
41 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
1answer
70 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): ...
0
votes
0answers
713 views

Using RabbitMQ in asp.net web api

Use case : I have a Order web Api which creates an orders and publish the order to messaging queue. Notification service (web api 2) consumes this message by subscribing to the messaging queue and ...
1
vote
0answers
28 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 ...
3
votes
0answers
149 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 ...
5
votes
1answer
2k 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
1answer
925 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....
1
vote
0answers
303 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 ...
2
votes
0answers
137 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: ...
1
vote
0answers
149 views

Clojure core.async to handle communication with rabbitmq

I'm learning how to use rabbitmq in the course of writing a webapp in Clojure that will need to call out to Python for occasional machine learning. On the Clojure side, the main library is Langohr, ...
3
votes
1answer
402 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, ...
2
votes
0answers
802 views

Convert a curl command into Ruby

I had a curl command which I converted using this. This is the Ruby script: ...
3
votes
0answers
497 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 ...
6
votes
1answer
4k 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
2answers
390 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. ...
4
votes
1answer
641 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 ...
6
votes
3answers
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. ...
10
votes
2answers
3k 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 ...