| Name | aiormq_lib JSON |
| Version |
0.1.3
JSON |
| download |
| home_page | None |
| Summary | Package for working with RabbitMQ |
| upload_time | 2025-03-23 15:03:28 |
| maintainer | None |
| docs_url | None |
| author | MentorSisek |
| requires_python | <4.0,>=3.13 |
| license | MIT |
| keywords |
|
| VCS |
 |
| bugtrack_url |
|
| requirements |
No requirements were recorded.
|
| Travis-CI |
No Travis.
|
| coveralls test coverage |
No coveralls.
|
# rabbitmq
### Install
```bash
pip install aiormq_lib
```
### Example
```python
import asyncio
from aiormq_lib import RabbitMQClient
from aiormq_lib.models import BaseFilter
from aiormq_lib.models import IncomingMessage, Queue
# Create RabbitMQ client
client = RabbitMQClient(
host="localhost",
port=5672,
username="username",
password="password",
port_api=15672,
)
# Filter for listener
class Filter(BaseFilter):
async def __call__(self, message: IncomingMessage):
# Not handling this message
return False
# Add listener for queue "test_queue"
@client.listener("test_queue", Filter())
async def handle_message_1(queue: Queue, message: IncomingMessage):
print(f"Received message: {message.body.decode()}")
async def handle_message_2(queue: Queue, message: IncomingMessage):
print(f"Received message: {message.body.decode()}")
async def main():
# If start_listening is True, start listening
await client.connect(start_listening=True)
# Add listener for queue "test_queue"
await client.add_listener("test_queue", handle_message_2)
await client.send_message("test_queue", {"content": "test"}) # Handler 2
await asyncio.sleep(10)
# Disconnect and stop listening
await client.disconnect()
if __name__ == "__main__":
asyncio.run(main())
```
Raw data
{
"_id": null,
"home_page": null,
"name": "aiormq_lib",
"maintainer": null,
"docs_url": null,
"requires_python": "<4.0,>=3.13",
"maintainer_email": null,
"keywords": null,
"author": "MentorSisek",
"author_email": "n3m0_22@mail.ru",
"download_url": "https://files.pythonhosted.org/packages/93/ed/f158f952c6026910364c27db04d6f9207ece57064507dafc207fb0213472/aiormq_lib-0.1.3.tar.gz",
"platform": null,
"description": "# rabbitmq\n\n### Install\n\n```bash\npip install aiormq_lib\n```\n\n### Example\n\n```python\nimport asyncio\n\nfrom aiormq_lib import RabbitMQClient\nfrom aiormq_lib.models import BaseFilter\nfrom aiormq_lib.models import IncomingMessage, Queue\n\n# Create RabbitMQ client\nclient = RabbitMQClient(\n host=\"localhost\",\n port=5672,\n username=\"username\",\n password=\"password\",\n port_api=15672,\n)\n\n\n# Filter for listener\nclass Filter(BaseFilter):\n async def __call__(self, message: IncomingMessage):\n # Not handling this message\n return False\n\n\n# Add listener for queue \"test_queue\"\n@client.listener(\"test_queue\", Filter())\nasync def handle_message_1(queue: Queue, message: IncomingMessage):\n print(f\"Received message: {message.body.decode()}\")\n\n\nasync def handle_message_2(queue: Queue, message: IncomingMessage):\n print(f\"Received message: {message.body.decode()}\")\n\n\nasync def main():\n\n # If start_listening is True, start listening\n await client.connect(start_listening=True)\n\n # Add listener for queue \"test_queue\"\n await client.add_listener(\"test_queue\", handle_message_2)\n\n await client.send_message(\"test_queue\", {\"content\": \"test\"}) # Handler 2\n await asyncio.sleep(10)\n\n # Disconnect and stop listening\n await client.disconnect()\n\n\nif __name__ == \"__main__\":\n asyncio.run(main())\n```\n",
"bugtrack_url": null,
"license": "MIT",
"summary": "Package for working with RabbitMQ",
"version": "0.1.3",
"project_urls": {
"Homepage": "https://github.com/Tsunami43/aiormq_lib.git"
},
"split_keywords": [],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "d5f5aa103d48c2b344e122e0e60ec61a4c6360795ddaf0091514bd06cd702f73",
"md5": "401a88c00adc2acb7648b4de7f94ebe5",
"sha256": "d198506234b79d9328114188256563f1e11106b1f091f3ace8fdd52f514c4e92"
},
"downloads": -1,
"filename": "aiormq_lib-0.1.3-py3-none-any.whl",
"has_sig": false,
"md5_digest": "401a88c00adc2acb7648b4de7f94ebe5",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": "<4.0,>=3.13",
"size": 11692,
"upload_time": "2025-03-23T15:03:26",
"upload_time_iso_8601": "2025-03-23T15:03:26.998246Z",
"url": "https://files.pythonhosted.org/packages/d5/f5/aa103d48c2b344e122e0e60ec61a4c6360795ddaf0091514bd06cd702f73/aiormq_lib-0.1.3-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "93edf158f952c6026910364c27db04d6f9207ece57064507dafc207fb0213472",
"md5": "4cb02d47e955e7ba6870b92704dd1dda",
"sha256": "346d56d22b8b61ac376f4364b16e325e98e41ba0aee796db34e978cbd3a4e66a"
},
"downloads": -1,
"filename": "aiormq_lib-0.1.3.tar.gz",
"has_sig": false,
"md5_digest": "4cb02d47e955e7ba6870b92704dd1dda",
"packagetype": "sdist",
"python_version": "source",
"requires_python": "<4.0,>=3.13",
"size": 6225,
"upload_time": "2025-03-23T15:03:28",
"upload_time_iso_8601": "2025-03-23T15:03:28.337885Z",
"url": "https://files.pythonhosted.org/packages/93/ed/f158f952c6026910364c27db04d6f9207ece57064507dafc207fb0213472/aiormq_lib-0.1.3.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2025-03-23 15:03:28",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "Tsunami43",
"github_project": "aiormq_lib",
"travis_ci": false,
"coveralls": false,
"github_actions": false,
"lcname": "aiormq_lib"
}
