Metadata-Version: 2.0
Name: equeue
Version: 0.1.4
Summary: Elastic Queue is a library to bear a PubSub projects. 
Home-page: https://github.com/jesuejunior/equeue
Author: Jesue Junior
Author-email: jesuesousa@gmail.com
License: UNKNOWN
Platform: UNKNOWN
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: BSD License
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 2.7
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.5
Classifier: Programming Language :: Python :: Implementation :: PyPy
Classifier: Topic :: Software Development
Classifier: Topic :: Software Development :: Libraries
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Dist: amqp (==2.1.0)
Requires-Dist: simplejson (>=3.8.2)
Requires-Dist: six (==1.10.0)

# EQueue
Elastic Queue is a library to bear a PubSub projects

### How to use it

Install via PIP

```shell
    $ pip install equeue
```

#### Producing

Using ipython

```python

    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

```python

    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.

```python

    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

```shell
    $ python main.py
``` 

### Developing mode

Run tests

```shell
    $ py.test
```



