{ "info": { "author": "Simon Patton", "author_email": "sjpatton@lbl.gov", "bugtrack_url": null, "classifiers": [ "Development Status :: 3 - Alpha", "Intended Audience :: Developers", "License :: OSI Approved :: BSD License", "Programming Language :: Python :: 2.7", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.4", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Programming Language :: Python :: 3.7", "Topic :: Scientific/Engineering" ], "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 [.]\n\nwhere `` is that name of the RabbitMQ queue from which the XML messages should be consumed and `` is a python class in the `` python module that will actually process the messages. If the `. 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 \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\n\n", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "http://nest.lbl.gov/projects/nest-rmq", "keywords": "", "license": "", "maintainer": "", "maintainer_email": "", "name": "rabbitmq-consume", "package_url": "https://pypi.org/project/rabbitmq-consume/", "platform": "", "project_url": "https://pypi.org/project/rabbitmq-consume/", "project_urls": { "Homepage": "http://nest.lbl.gov/projects/nest-rmq" }, "release_url": "https://pypi.org/project/rabbitmq-consume/0.6.1/", "requires_dist": [ "pika (>=1)" ], "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "summary": "Consumes XML messages from a RabbitMQ queue using a user defined class.", "version": "0.6.1" }, "last_serial": 5382984, "releases": { "0.6.0": [ { "comment_text": "", "digests": { "md5": "35c580635783389007215560a70839fc", "sha256": "06e4f906838d3638cb64dc650489ffae0073f62efba224b104cc64ee39541485" }, "downloads": -1, "filename": "rabbitmq_consume-0.6.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "35c580635783389007215560a70839fc", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "size": 13792, "upload_time": "2019-06-03T19:07:26", "url": "https://files.pythonhosted.org/packages/56/93/6168e6c9acbd0be348af49211a2ecaecdb42bbf3cb8a89c7aa2d4d0dce6c/rabbitmq_consume-0.6.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "e77c04a401730c38f5e6097e4fc0bebb", "sha256": "3de23febb584e00a3e642bd6a6357c19e7d41a11db8b79705b7fe793bcbcef08" }, "downloads": -1, "filename": "rabbitmq_consume-0.6.0.tar.gz", "has_sig": false, "md5_digest": "e77c04a401730c38f5e6097e4fc0bebb", "packagetype": "sdist", "python_version": "source", "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "size": 12757, "upload_time": "2019-06-03T19:07:28", "url": "https://files.pythonhosted.org/packages/ee/49/3724766273ae5e1310a7d147cab1f88748c9344d92a646e3d74244664c5d/rabbitmq_consume-0.6.0.tar.gz" } ], "0.6.1": [ { "comment_text": "", "digests": { "md5": "169b6c14143ffc6f6c117ce8219ec85a", "sha256": "5ae12f1ef99e30778db99766daf71ae90658d55fb3dd327c3b1103ad463c4d73" }, "downloads": -1, "filename": "rabbitmq_consume-0.6.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "169b6c14143ffc6f6c117ce8219ec85a", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "size": 13778, "upload_time": "2019-06-10T18:39:41", "url": "https://files.pythonhosted.org/packages/be/79/4ba362cbb93ae47142b69a5e614b7f05b257882bb12f4aae6481df9f5685/rabbitmq_consume-0.6.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "dc3c66e8ab0b5a2a924d4c03a6a58448", "sha256": "f49a8b9b28c5dbd6601e7454a42dca928bf262caa9578883a0c0509846e93c6e" }, "downloads": -1, "filename": "rabbitmq_consume-0.6.1.tar.gz", "has_sig": false, "md5_digest": "dc3c66e8ab0b5a2a924d4c03a6a58448", "packagetype": "sdist", "python_version": "source", "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "size": 11974, "upload_time": "2019-06-10T18:39:42", "url": "https://files.pythonhosted.org/packages/3f/f6/d7aa4efd1f01cddbc5411239acd2f5e9542a2453c48a7c4c3e337b544257/rabbitmq_consume-0.6.1.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "169b6c14143ffc6f6c117ce8219ec85a", "sha256": "5ae12f1ef99e30778db99766daf71ae90658d55fb3dd327c3b1103ad463c4d73" }, "downloads": -1, "filename": "rabbitmq_consume-0.6.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "169b6c14143ffc6f6c117ce8219ec85a", "packagetype": "bdist_wheel", "python_version": "py2.py3", "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "size": 13778, "upload_time": "2019-06-10T18:39:41", "url": "https://files.pythonhosted.org/packages/be/79/4ba362cbb93ae47142b69a5e614b7f05b257882bb12f4aae6481df9f5685/rabbitmq_consume-0.6.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "dc3c66e8ab0b5a2a924d4c03a6a58448", "sha256": "f49a8b9b28c5dbd6601e7454a42dca928bf262caa9578883a0c0509846e93c6e" }, "downloads": -1, "filename": "rabbitmq_consume-0.6.1.tar.gz", "has_sig": false, "md5_digest": "dc3c66e8ab0b5a2a924d4c03a6a58448", "packagetype": "sdist", "python_version": "source", "requires_python": ">=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, <4", "size": 11974, "upload_time": "2019-06-10T18:39:42", "url": "https://files.pythonhosted.org/packages/3f/f6/d7aa4efd1f01cddbc5411239acd2f5e9542a2453c48a7c4c3e337b544257/rabbitmq_consume-0.6.1.tar.gz" } ] }