diff --git a/README.md b/README.md index 25e9e33..03e8a66 100644 --- a/README.md +++ b/README.md @@ -17,7 +17,6 @@ ```python pip install upy-rabbitmq - ``` ## Config @@ -29,6 +28,7 @@ RABBITMQ_URL=amqp://user:password@remote.server.com:port//vhost ``` ## Callback Class +> callback.py ```python @@ -43,6 +43,7 @@ class MyCallBack(CallbackProcess): ``` ## Start Queue +> worker.py ```python @@ -56,6 +57,7 @@ worker.start_queue( ``` ## New Task +> client.py ```python from upy_rabbitmq.client import UpyMQClient diff --git a/docs/index.md b/docs/index.md index 3d92969..03e8a66 100644 --- a/docs/index.md +++ b/docs/index.md @@ -1,4 +1,4 @@ -# Upy-RabbitMQ +# upy-rabbitmq ![GitHub Org's stars](https://img.shields.io/github/stars/UpyExplorer?label=LinuxProfile&style=flat-square) ![PyPI - Python Version](https://img.shields.io/pypi/pyversions/upy-rabbitmq) @@ -27,7 +27,24 @@ Add an environment variation called **RABBITMQ_URL** in your project's .env file RABBITMQ_URL=amqp://user:password@remote.server.com:port//vhost ``` +## Callback Class +> callback.py + +```python + +import time +from upy_rabbitmq.callback import CallbackProcess + +class MyCallBack(CallbackProcess): + + def process(self): + time.sleep(5) + print(self.body.decode()) +``` + ## Start Queue +> worker.py + ```python from upy_rabbitmq.worker import UpyMQWorker @@ -35,11 +52,12 @@ from upy_rabbitmq.worker import UpyMQWorker worker = UpyMQWorker() worker.start_queue( key="key", - callback=callback + callback=MyCallBack ) ``` ## New Task +> client.py ```python from upy_rabbitmq.client import UpyMQClient