| Name | rabbitmq-consume JSON |
| Version |
1.0.0
JSON |
| download |
| home_page | |
| Summary | Consumes XML messages from a RabbitMQ queue using a user defined class. |
| upload_time | 2023-01-25 01:57:28 |
| maintainer | |
| docs_url | None |
| author | |
| requires_python | <4,>=3.10 |
| license | BSD-3-Clause-LBNL |
| keywords |
rabbitmq
rabbitmq_consume
|
| VCS |
|
| bugtrack_url |
|
| requirements |
No requirements were recorded.
|
| Travis-CI |
No Travis.
|
| coveralls test coverage |
No coveralls.
|
# `rabbitmq_consume` project #
The `rabbitmq_consume` project contains both the `rabbitmq_consume` package that provides a simple `Consumer` class for processing messages from a RabbitMQ queue, `rmq-consume` that is an executable that can be used to run that class and `rmq-inject` that cna be used to inject messages into the originating RabbitMQ queue.
## `rmq-consume` executable ##
More details about the `rmq-consume` executable can be found using its help option
rmq-consume -h
The typical usage is the following:
rmq-consume <queue> <module>[.<class>]
where `<queue>` is that name of the RabbitMQ queue from which the XML messages should be consumed and `<class>` is a python class in the `<module>` python module that will actually process the messages. If the `.<class> is omitted from the comand line, the class whose name matches the module name will be used.
The "consumption" class need to derived from the `Consumption.Consumption` as shown in the following trivial example.
from Consumption import Consumption
class TrivialConsumption(Consumption):
def __init__(self,
properties,
body,
redelivered):
def consume(self):
pass
Most real implementations will save the `properties`, `body` and `redelivered` arguments for use in the `consume` method.
## `rmq-inject` executable ##
More details about the `rmq-inject` executable can be found using its help option
rmq-inject -h
The typical usage is the following:
rmq-inject -l <queue>
This injects a "stop listening message" into the queue and when the consumer encounters this it will stop listening for an more messages and shut down.
Raw data
{
"_id": null,
"home_page": "",
"name": "rabbitmq-consume",
"maintainer": "",
"docs_url": null,
"requires_python": "<4,>=3.10",
"maintainer_email": "",
"keywords": "rabbitmq,rabbitmq_consume",
"author": "",
"author_email": "Simon Patton <sjpatton@lbl.gov>",
"download_url": "https://files.pythonhosted.org/packages/37/ce/1176b66598a8ce41d51431b343c492bf991efa3a515934afe0299b1ca80e/rabbitmq_consume-1.0.0.tar.gz",
"platform": null,
"description": "# `rabbitmq_consume` project #\n\nThe `rabbitmq_consume` project contains both the `rabbitmq_consume` package that provides a simple `Consumer` class for processing messages from a RabbitMQ queue, `rmq-consume` that is an executable that can be used to run that class and `rmq-inject` that cna be used to inject messages into the originating RabbitMQ queue.\n\n\n## `rmq-consume` executable ##\n\nMore details about the `rmq-consume` executable can be found using its help option\n\n rmq-consume -h\n\nThe typical usage is the following:\n\n rmq-consume <queue> <module>[.<class>]\n\nwhere `<queue>` is that name of the RabbitMQ queue from which the XML messages should be consumed and `<class>` is a python class in the `<module>` python module that will actually process the messages. If the `.<class> is omitted from the comand line, the class whose name matches the module name will be used.\n\nThe \"consumption\" class need to derived from the `Consumption.Consumption` as shown in the following trivial example.\n\n from Consumption import Consumption\n\n class TrivialConsumption(Consumption):\n\n def __init__(self,\n properties,\n body,\n redelivered):\n\n def consume(self):\n pass\n\nMost real implementations will save the `properties`, `body` and `redelivered` arguments for use in the `consume` method.\n\n\n## `rmq-inject` executable ##\n\nMore details about the `rmq-inject` executable can be found using its help option\n\n rmq-inject -h\n\nThe typical usage is the following:\n\n rmq-inject -l <queue>\n\nThis injects a \"stop listening message\" into the queue and when the consumer encounters this it will stop listening for an more messages and shut down.\n",
"bugtrack_url": null,
"license": "BSD-3-Clause-LBNL",
"summary": "Consumes XML messages from a RabbitMQ queue using a user defined class.",
"version": "1.0.0",
"split_keywords": [
"rabbitmq",
"rabbitmq_consume"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "ddd39fce6cbed0db0e3cb39fa5dcd85e17d1dd6094584e8e4e2b20f8c362f032",
"md5": "00bb528bcbe8d80175e07d2d7ff30c42",
"sha256": "c12641317169e05ec1442441ca6159380c5461f343193ee38697392f4f9eb02d"
},
"downloads": -1,
"filename": "rabbitmq_consume-1.0.0-py3-none-any.whl",
"has_sig": false,
"md5_digest": "00bb528bcbe8d80175e07d2d7ff30c42",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": "<4,>=3.10",
"size": 19800,
"upload_time": "2023-01-25T01:57:27",
"upload_time_iso_8601": "2023-01-25T01:57:27.198362Z",
"url": "https://files.pythonhosted.org/packages/dd/d3/9fce6cbed0db0e3cb39fa5dcd85e17d1dd6094584e8e4e2b20f8c362f032/rabbitmq_consume-1.0.0-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "37ce1176b66598a8ce41d51431b343c492bf991efa3a515934afe0299b1ca80e",
"md5": "72bba92d2642fae3874198d4d2afecee",
"sha256": "ac86964d53dc262a0d1e2494af960cdaa2f185d82c129dbadd7baa66da2410b3"
},
"downloads": -1,
"filename": "rabbitmq_consume-1.0.0.tar.gz",
"has_sig": false,
"md5_digest": "72bba92d2642fae3874198d4d2afecee",
"packagetype": "sdist",
"python_version": "source",
"requires_python": "<4,>=3.10",
"size": 14927,
"upload_time": "2023-01-25T01:57:28",
"upload_time_iso_8601": "2023-01-25T01:57:28.832230Z",
"url": "https://files.pythonhosted.org/packages/37/ce/1176b66598a8ce41d51431b343c492bf991efa3a515934afe0299b1ca80e/rabbitmq_consume-1.0.0.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-01-25 01:57:28",
"github": false,
"gitlab": false,
"bitbucket": false,
"lcname": "rabbitmq-consume"
}
