A pure python, thread-safe, minimalistic and pythonic RabbitMQ client library
Definition:
A pure python, thread-safe, minimalistic and pythonic RabbitMQ client library.
Installation Instructions:
pip install rabbitpy
Questions tagged [rabbitpy]
10 questions
3
votes
1 answer
rabbitpy message loop seems to consume massive memory
Using the standard procedure (for loop) as seen in the examples we found that there is a lot of memory used on the machine. I.e. it seems that all the messages in the queue are loaded into memory and also acknowledged. This approach is here. I…
disruptive
- 5,687
- 15
- 71
- 135
2
votes
0 answers
How can I decouple consumers from configuring queues in rabbitpy
I'd like to create exchanges and queues in the RabbitMQ server.
In the consumer, however, I do not want it explicitly declare a queue and receive messages from there. Is there a way to receive queue configuration from the server once a…
Lelouch Lamperouge
- 8,171
- 8
- 49
- 60
1
vote
1 answer
Cannot get example working for RabbitPy
I cannot seem to get the code running - I've been using Pika and keen to try out this thread safe and possibly neater version.
import rabbitpy
with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
with conn.channel() as…
disruptive
- 5,687
- 15
- 71
- 135
0
votes
1 answer
RabbitMQ Inconsistent Results With Jupyter Notebook and Terminal
I'm learning RabbitMQ and following the book RabbitMQ in Depth.
I'm implementing a simple publisher-subscriber pattern. However I get different results from Jupyter Notebook and with simple python command from terminal. I'm using the same…
J.Smith
- 362
- 1
- 10
0
votes
0 answers
RabbitMQ server is already shut down., but python rabbitpy library does not throw error, when I publish a message to the RabbitMQ server
I am using Python 3.5, rabbitpy 2.0.1.
I have created a flask app and I am also using the eventlet library with my app.
I have created an app-level connection and an app-level channel, and I am using that connection & channel between multiple…
0
votes
1 answer
what does the Mandatory argument in rabbitpy mean and how does it really work?
so I'm working on a Project using RabbitMq and Python 3.7. I first used Pika but then I switched to rabbitpy since it's Thread safe and we are using Multithreading in the Project. I looked at the Documentation of rabbitpy and I really like the API,…
basilisk
- 1,156
- 1
- 14
- 34
0
votes
0 answers
rabbitpy - Exception not raised outside context manager
Publishing to a non-existing exchange with rabbitpy does not raise an exception if not using with block:
>>> conn = rabbitpy.Connection('amqp://user:passw@ms7:5672/MyHost')
>>> ch = conn.channel()
>>> msg = rabbitpy.Message(ch,…
R01k
- 735
- 3
- 12
- 26
0
votes
1 answer
Rabbitpy listener reading from wrong queue
I am trying to run a program that uses rabbitpy to send commands from the terminal on one queue and read responses in a separate thread on a different queue. The problem is that when I send a message on queue1, my listener thread (which should be…
Marc
- 3,386
- 8
- 44
- 68
0
votes
2 answers
Publishing a message to queue in RabbitPy
I am looking to RabbitPy for consuming and publishing messages. The consumption part is fine, However I want to send back messages to a specific queue after doing something with the inbound message. However I cannot find anyway to do this in the…
disruptive
- 5,687
- 15
- 71
- 135
0
votes
0 answers
Sleep takes 86% of time in rabbitpy consumer?
I found a rather interesting problem today. I have a queue with 2K messages in it.
The consumer: import rabbitpy
with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
with conn.channel() as channel:
queue =…
Lelouch Lamperouge
- 8,171
- 8
- 49
- 60