{ "info": { "author": "Jan Seifert", "author_email": "jan.seifert@fotkyzcest.net", "bugtrack_url": null, "classifiers": [ "Development Status :: 4 - Beta", "Intended Audience :: Developers", "License :: OSI Approved :: BSD License", "Operating System :: POSIX", "Programming Language :: Python :: 2.7", "Programming Language :: Python :: 3.4", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Topic :: Software Development :: Libraries :: Python Modules" ], "description": "IpcQueue\n========\n\nThis package provides SYS V and POSIX message queues to exchange data\namong processes. Both queues have similar functionality with some\ndifferences. Queues are persistent in the kernel unless either queue is\nclosed/unlinked or system is shut down. Unlike `multiprocessing.Queue`,\nthe same queue can be joined by different processes according to its\nunique name/key, it's not necessary to fork main process. Be careful if\nyou use signals in your application, because signal interrupts sending\nor receiving message.\n\nInstallation\n------------\n\nRequires Python CFFI, C compiler and Python header files.\n\n::\n\n cd ipcqueue/\n python setup.py install\n\nUsage\n-----\n\n::\n\n >>> from ipcqueue import posixmq\n >>> q = posixmq.Queue('/foo')\n >>> q.qsize()\n 0\n >>> q.put([1, 'A'], priority=1)\n >>> q.put([2, 'B'], priority=2)\n >>> q.put([3, 'C'], priority=1)\n >>> q.qsize()\n 3\n >>> q.get()\n [2, 'B']\n >>> q.get()\n [1, 'A']\n >>> q.get()\n [3, 'C']\n >>> q.close()\n >>> q.unlink()\n\n >>> from ipcqueue import sysvmq\n >>> q = sysvmq.Queue(1)\n >>> q.qsize()\n >>> q.put([1, 'A'], msg_type=1)\n >>> q.put([2, 'B'], msg_type=2)\n >>> q.put([3, 'C'], msg_type=2)\n >>> q.put([4, 'D'], msg_type=1)\n >>> q.qsize()\n 4\n >>> q.get(msg_type=2)\n [2, 'B']\n >>> q.get()\n [1, 'A']\n >>> q.get()\n [3, 'C']\n >>> q.get()\n [4, 'D']\n >>> q.close()\n\nDocumentation\n-------------\n\nhttp://pythonhosted.org/ipcqueue\n\nLicense\n-------\n\n3-clause BSD", "description_content_type": "", "docs_url": "https://pythonhosted.org/ipcqueue/", "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/seifert/ipcqueue", "keywords": "sysv posix ipc queue", "license": "BSD", "maintainer": "", "maintainer_email": "", "name": "ipcqueue", "package_url": "https://pypi.org/project/ipcqueue/", "platform": "", "project_url": "https://pypi.org/project/ipcqueue/", "project_urls": { "Homepage": "https://github.com/seifert/ipcqueue" }, "release_url": "https://pypi.org/project/ipcqueue/0.9.6/", "requires_dist": null, "requires_python": "", "summary": "Ipcqueue provides POSIX and SYS V message queues functionality to exchange data among processes.", "version": "0.9.6" }, "last_serial": 4438189, "releases": { "0.9.0": [ { "comment_text": "", "digests": { "md5": "44bbf0cf3128c462de47b28a76b8196f", "sha256": "29c08088accf8462fe413265d0d2bd7a9c847dd7435ff1b260c9c61172cfd7a4" }, "downloads": -1, "filename": "ipcqueue-0.9.0.tar.gz", "has_sig": false, "md5_digest": "44bbf0cf3128c462de47b28a76b8196f", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6104, "upload_time": "2017-03-13T13:07:25", "url": "https://files.pythonhosted.org/packages/f8/8f/55c08cc66aa890b9a3cc7117e25ec428a2cc8ac8c23ccf8ccb8ffb1be0a7/ipcqueue-0.9.0.tar.gz" } ], "0.9.1": [ { "comment_text": "", "digests": { "md5": "e221aeda7171ae7e0a4da7545d142f43", "sha256": "253e0e57dab61b39d413b66dd863f9db4b9db844ccd3e6fadf3dd57baed90f93" }, "downloads": -1, "filename": "ipcqueue-0.9.1.tar.gz", "has_sig": false, "md5_digest": "e221aeda7171ae7e0a4da7545d142f43", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7005, "upload_time": "2017-03-13T20:45:09", "url": "https://files.pythonhosted.org/packages/0f/8c/673c92d08c4806a2b05e61b9aa190f4706bfd9a408a132cc419fcc7d4cee/ipcqueue-0.9.1.tar.gz" } ], "0.9.2": [ { "comment_text": "", "digests": { "md5": "3c5ae31d979258fe2ff7a91f00a9133b", "sha256": "059ef22b8808d9f0c93c850356cf626e8e992533fe6b488329982b1614250749" }, "downloads": -1, "filename": "ipcqueue-0.9.2.tar.gz", "has_sig": false, "md5_digest": "3c5ae31d979258fe2ff7a91f00a9133b", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7063, "upload_time": "2017-03-14T07:49:36", "url": "https://files.pythonhosted.org/packages/32/25/bc9b33630cc547b893a59994fb16034a217810ab1a96ee7eec5abf697f2f/ipcqueue-0.9.2.tar.gz" } ], "0.9.3": [ { "comment_text": "", "digests": { "md5": "d169a7c37394306e48db419a9ef3f1f0", "sha256": "55ca1f77b51fb57b6ee48f8b2b9d4e47416bcba81b8523777ea435c92c34cdba" }, "downloads": -1, "filename": "ipcqueue-0.9.3.tar.gz", "has_sig": false, "md5_digest": "d169a7c37394306e48db419a9ef3f1f0", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7081, "upload_time": "2017-03-20T12:22:54", "url": "https://files.pythonhosted.org/packages/37/a1/bc984ee796212678563ed5947c8dbbce8cd5184e2a7ae0772eb9e143afa4/ipcqueue-0.9.3.tar.gz" } ], "0.9.4": [ { "comment_text": "", "digests": { "md5": "848595f72b46d1636c2a8edfb74fa131", "sha256": "52a2f22b9030f988e91c1dcdc3ce884363ad26b79c8075d78497fbc4f17f6b99" }, "downloads": -1, "filename": "ipcqueue-0.9.4.tar.gz", "has_sig": false, "md5_digest": "848595f72b46d1636c2a8edfb74fa131", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15865, "upload_time": "2017-03-20T12:59:03", "url": "https://files.pythonhosted.org/packages/9a/8a/0d8c03b2d7a0d0925cfe70d7ad5591973fe0bfce4a5bce4257f45f6b4652/ipcqueue-0.9.4.tar.gz" } ], "0.9.5": [ { "comment_text": "", "digests": { "md5": "ece788bc950595f0dd30718a073188d5", "sha256": "67c80b5caaa72556c138a19c9a6e13f86ab70f62f22ad13074f0077d5207d4aa" }, "downloads": -1, "filename": "ipcqueue-0.9.5.tar.gz", "has_sig": false, "md5_digest": "ece788bc950595f0dd30718a073188d5", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15104, "upload_time": "2018-08-31T11:19:39", "url": "https://files.pythonhosted.org/packages/b8/f2/ef3c9925107785cede30cd509fb496f0d6a36e4d0871fea1e6467ce05ca0/ipcqueue-0.9.5.tar.gz" } ], "0.9.6": [ { "comment_text": "", "digests": { "md5": "b88b048c9f26d162be7b1af28a84eeec", "sha256": "62c7ed68fd65cc91f964dbe6eb2a7199c02eb72dedea81999526365dd9b4560a" }, "downloads": -1, "filename": "ipcqueue-0.9.6.tar.gz", "has_sig": false, "md5_digest": "b88b048c9f26d162be7b1af28a84eeec", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15241, "upload_time": "2018-10-31T19:55:07", "url": "https://files.pythonhosted.org/packages/37/f3/356c469b08c295e8350a889b9029d87ed08f58b56d334f368c67b3c5ae80/ipcqueue-0.9.6.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "b88b048c9f26d162be7b1af28a84eeec", "sha256": "62c7ed68fd65cc91f964dbe6eb2a7199c02eb72dedea81999526365dd9b4560a" }, "downloads": -1, "filename": "ipcqueue-0.9.6.tar.gz", "has_sig": false, "md5_digest": "b88b048c9f26d162be7b1af28a84eeec", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15241, "upload_time": "2018-10-31T19:55:07", "url": "https://files.pythonhosted.org/packages/37/f3/356c469b08c295e8350a889b9029d87ed08f58b56d334f368c67b3c5ae80/ipcqueue-0.9.6.tar.gz" } ] }