Stack Overflow
Stack Overflow

Questions tagged [librabbitmq]

An AMQP client library written in C

This is a C-language AMQP client library for use with AMQP servers speaking protocol versions 0-9-1.

See https://launchpad.net/librabbitmq

12 questions
5
votes
1 answer

Librabbitmq 2.0.0 with Python 3 gives TypeError: can't pickle memoryview objects

I am using the latest master branch of the git repo https://github.com/celery/librabbitmq and installing librabbitmq==2.0.0 for Python 3.6 by following the instructions in the readme Using the development version You can clone the repository by…
dowjones123
  • 3,695
  • 5
  • 40
  • 83
4
votes
2 answers

AMQP RabbitMQ consumers blocking eachother?

I have coded up a C (rabbitmq-c) worker app which consumes a queue published by a Python script (pika). I have the following strange behaviour which I can't seem to solve: Starting all the workers before messages are published to the queue works as…
depletionmode
  • 149
  • 1
  • 7
2
votes
1 answer

How to tell if Celery is using librabbitmq?

According to Celery Documentation: librabbitmq If you’re using RabbitMQ (AMQP) as the broker then you can install the librabbitmq module to use an optimized client written in C: $ pip install librabbitmq The ‘amqp’ transport will automatically use…
user212218
1
vote
1 answer

amqp_basic_qos not having any effect

I am trying to code a simple consumer using librabbitmq. It is working, but when I do execute amqp_basic_consume, it consumes the entire queue. What I want is for it to get a single message, process it and repeat. I tried using a basic_qos to have…
Brian Andrus
  • 23
  • 5
1
vote
0 answers

kombu/librabbitmq: ConnectionError: Couldn't revive channel

I am using the producers pool group to publish a message to rabbitmq, but the publish call is failing with the following error: . File "pubsub.py", line 314, in _publish producer.publish(message, exchange=exchange, routing_key=topic) …
vrtx54234
  • 2,196
  • 3
  • 30
  • 53
1
vote
1 answer

How to check if message is delivered to any single queue

I am using rabbitmq-c lib in linux. I want to so basic request and response. I have used amqp_basic_publish with mandatory field as true, I just want to know is that message is delivered any queue. i want basic c example for that.
SayedMomeen
  • 13
  • 4
1
vote
1 answer

Celery + reverse topic exchange (x-rtopic) not working

I am trying to create a celery app using reverse topic exchange rabbitmq plugin from Alvaro Videla. The workers seems to connect with the broker fine using this exchange but when I topic-reverse-route my task, do not pick up the '#' or '*', works…
AndreLobato
  • 170
  • 1
  • 12
0
votes
1 answer

Is there a standard way of doing RPCs with rabbitmq-c

In the RabbitMQ tutorials there's a demonstration of how to do remote process calls in all but C-languages (C, C++). I'm using rabbitmq-c and I'm close to replicating what the Python tutorial is doing, after all correlation_id and reply_to are…
Lorah Attkins
  • 5,331
  • 3
  • 29
  • 63
0
votes
1 answer

How to install librabbitmq in App Engine Google Cloud Platform

I've been trying to install librabbitmq in App Engine GCP without any luck. https://github.com/celery/librabbitmq All other pip packages install properly if they are in the requirements.txt via my yml file, however, this package does not work…
smorhaim
  • 778
  • 1
  • 9
  • 24
0
votes
1 answer

Rabbitmq Acking in multiple consumers

I have a queue on which multiple consumers are working in round robin fashion. Delivery_tag is used to ack messages once consumer is done with its processing. But multiple consumers are setting same delivery_tag, though the message on which they are…
Avinash Jha
  • 1
0
votes
0 answers

RabbitMQ Multi channels

I have developed a PHP application using RabbitMQ and NodeJs. Then i made a copy of that application on the same server. The problem is that sending any message in any application, the other application is listining also, so i want every application…
Gamal Anwar
  • 49
  • 1
  • 6
0
votes
1 answer

How to integrate rabbit mq client library

On lots of searching about Rabbit MQ I found objective C wrapper for librabbitmq-c whose link is directed to librabbitmq-objc. For librabbitmq-c link found https://github.com/alanxz/rabbitmq-c. I tried to integrate both in my application by lots of…
Prince Kumar Sharma
  • 12,591
  • 4
  • 59
  • 90