equ
equeue
pypi i equeue
equ

equeue

Elastic Queue is a library to bear PubSub projects

by Jesué Junior

0.1.5 (see all)
pypi i equeue
Readme

EQueue

Elastic Queue is a library to bear a PubSub projects

How to use it

Install via PIP

    $ pip install equeue

Producing

Using ipython


    In [1]: from equeue.rabbit.publisher import Publisher

    In [2]: pub = Publisher(host='localhost', username='guest', password='guest', queue_name='t')

    In [3]: pub.put(message_dict={'id': 1})
    Out[3]: <promise@0x10ef18b78>

By poll

Using ipython


    In [1]: from equeue.rabbit.subscriber import Subscriber

    In [2]: sub = Subscriber(host='localhost', username='guest', password='guest', queue_name='t')

    In [3]: msg = sub.get()

    In [4]: if msg:
       ...:     print(msg)
       ...:      

Consuming

Creating a main.py you'd see better.


    from equeue.rabbit.subscriber import Subscriber

    def events_out(callback, message, delivery_tag):
        print(message)
        print(delivery_tag)
        callback.ack(delivery_tag)

    def main():

        sub = Subscriber(host='localhost', username='guest',
                password='guest', queue_name='t')
        
        sub.setup_consumer(callback=events_out)
        while True:
            sub.consume()
    if __name__ == '__main__':
        main()

Then

    $ python main.py

Developing mode

Running tests

To run the project's test you will need to have pytest installed. The instalation is simple as :

$ pip install pytest

And to run the tests you need to ajust yout PYTHONPATH

    $ PYTHONPATH=equeue py.test

GitHub Stars

14

LAST COMMIT

5yrs ago

MAINTAINERS

1

CONTRIBUTORS

2

OPEN ISSUES

4

OPEN PRs

0
VersionTagPublished
0.1.5
5yrs ago
0.1.4
6yrs ago
No alternatives found
No tutorials found
Add a tutorial