{ "info": { "author": "Eric Tang", "author_email": "eric.tang@tyo.com.au", "bugtrack_url": null, "classifiers": [ "Development Status :: 5 - Production/Stable", "Intended Audience :: Developers", "License :: OSI Approved :: MIT License", "Programming Language :: Python" ], "description": "# tyo-mq-client-python\nA TYO-MQ python client for TYO-MQ server.\n\n## TYO-MQ server \nplease refer to [TYO-MQ Server]{https://github.com/tyolab/tyo-mq}/server.js\n\nIn short, TYO-MQ is an implementation of pub/sub message distribution service using socket.io(webscoket).\n\n### Creating a messaging server\n\n```javascript\nvar MessageServer = require(\"tyo-mq\").server;\n\nvar mq = new MessageServer();\nmq.start();\n```\n\n### Creating a message producer and consumer\n\n```python\nfrom tyo_mq_client.message_queue import MessageQueue\nfrom tyo_mq_client.socket import Socket\nfrom tyo_mq_client.logger import Logger\nfrom tyo_mq_client.constants import Constants\n\nsubscriber = None\nproducer = None\nready = [False, False]\n\nmq = MessageQueue()\n\nproducer = mq.createPublisher(\"TYO Lab\")\n\n# A producer can be also a consumer\nsubscriber = producer\n\ndef on_message_published(message):\n print (\"received message\" + json.dumps(message))\n os._exit(1)\n\ndef check ():\n if (ready[0] and ready[1]):\n producer.produce({\"message\": \"Hello World\"})\n\ndef subscriber_on_connect () :\n Logger.log(\"Subscriber is connected\")\n ready[0] = True\n subscriber.subscribe(producer.name, Constants.EVENT_DEFAULT, on_message_published, False)\n \ndef on_subscription (data) :\n print (\"received subscription\")\n producer.produce({\"message1\": \"Hello World\"})\n producer.on('test', on_message_published)\n producer.socket.emit('test')\n producer.produce({\"message2\": \"Hello World\"}, producer.eventDefault, Constants.METHOD_BROADCAST)\n\ndef producer_on_connect () :\n subscriber_on_connect() \n\n Logger.log(\"Producer is connected\")\n ready[1] = True\n producer.on_subscription_listener = on_subscription\n producer.on_subscriber_lost(on_subscriber_lost)\n\ndef on_subscriber_lost (data):\n message = json.dumps(data)\n Logger.log('Informed that connection with a subscriber (' + message[\"consumer\"] + ') was lost')\n\nproducer.add_on_connect_listener(producer_on_connect)\nproducer.connect(-1)\n\n\n```\n\n## Maintainer\n\n[Eric Tang](https://twitter.com/_e_tang) @ [TYO LAB](http://tyo.com.au)", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/tyolab/tyo-mq-client-python.git", "keywords": "tyo-mq socket.io node.js pub/sub publisher/subscriber", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "tyo-mq-client", "package_url": "https://pypi.org/project/tyo-mq-client/", "platform": "", "project_url": "https://pypi.org/project/tyo-mq-client/", "project_urls": { "Homepage": "https://github.com/tyolab/tyo-mq-client-python.git" }, "release_url": "https://pypi.org/project/tyo-mq-client/0.0.6/", "requires_dist": null, "requires_python": "", "summary": "A tyo-mq client library", "version": "0.0.6" }, "last_serial": 3979542, "releases": { "0.0.1": [ { "comment_text": "", "digests": { "md5": "a3366d409d4642edab4fab3f9ac10e98", "sha256": "8e2d68692273aa6ea2aad5d6f4608df8190616941b373ba0f3484d7c6d8dcb85" }, "downloads": -1, "filename": "tyo-mq-client-0.0.1.tar.gz", "has_sig": false, "md5_digest": "a3366d409d4642edab4fab3f9ac10e98", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5995, "upload_time": "2018-06-19T03:44:22", "url": "https://files.pythonhosted.org/packages/19/cc/1cb6cbf93bcc05adca9c6d058bd3e5dee2d6e0d75b9cdca7fd4ce63d844d/tyo-mq-client-0.0.1.tar.gz" } ], "0.0.2": [ { "comment_text": "", "digests": { "md5": "8c12b58026c1042e01196dd9758daf2e", "sha256": "f0b62828b7c735f32b44cd5734bb31881cbffc085b94a8010f409c034faa2c88" }, "downloads": -1, "filename": "tyo-mq-client-0.0.2.tar.gz", "has_sig": false, "md5_digest": "8c12b58026c1042e01196dd9758daf2e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5318, "upload_time": "2018-06-19T03:53:39", "url": "https://files.pythonhosted.org/packages/5a/6c/ed0f2c80a01fade656b292f1150efec6e9c1b51f267b5d008293b9cdbd86/tyo-mq-client-0.0.2.tar.gz" } ], "0.0.3": [ { "comment_text": "", "digests": { "md5": "8af30d138d80d5c1943a381ffd7a6a18", "sha256": "f10f01db15317dd2456fe6db09a2c89a22aec2fde4b4df390739257f276be2e5" }, "downloads": -1, "filename": "tyo-mq-client-0.0.3.tar.gz", "has_sig": false, "md5_digest": "8af30d138d80d5c1943a381ffd7a6a18", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5966, "upload_time": "2018-06-19T04:24:46", "url": "https://files.pythonhosted.org/packages/ea/f2/c6a70f4d94de6444a88661025340909b2a6b911e36189f4c597beffeb990/tyo-mq-client-0.0.3.tar.gz" } ], "0.0.4": [ { "comment_text": "", "digests": { "md5": "f67c07f397b6dd3eb48885992fe41ecd", "sha256": "ebe8a5f20f6a3ba1eaafaeaffed7d58e1ea3f0ab49eacabe501e7d512035d8a8" }, "downloads": -1, "filename": "tyo-mq-client-0.0.4.tar.gz", "has_sig": false, "md5_digest": "f67c07f397b6dd3eb48885992fe41ecd", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6225, "upload_time": "2018-06-19T04:28:09", "url": "https://files.pythonhosted.org/packages/37/6e/bf157cb1bf560097b0197e33ae27e9661caa4aa44503c536309f7b2b579d/tyo-mq-client-0.0.4.tar.gz" } ], "0.0.5": [ { "comment_text": "", "digests": { "md5": "43d3def4f279b8adda4285f756cac412", "sha256": "c6155a970324bd63bd8f0dea53c7859bc4f26ec87ef6d73ced533d448d5c2180" }, "downloads": -1, "filename": "tyo-mq-client-0.0.5.tar.gz", "has_sig": false, "md5_digest": "43d3def4f279b8adda4285f756cac412", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7045, "upload_time": "2018-06-19T05:49:01", "url": "https://files.pythonhosted.org/packages/3d/92/279beb53abe0cff0fde9e0d572b3ec37035e9908ecec85d61d19ed6b87c2/tyo-mq-client-0.0.5.tar.gz" } ], "0.0.6": [ { "comment_text": "", "digests": { "md5": "802dccf3f1959beb44e9f34da10d226e", "sha256": "29f47259a41bbfb17b5fea02b7b5614b13308af477b3ea5491f2594866b0c77d" }, "downloads": -1, "filename": "tyo-mq-client-0.0.6.tar.gz", "has_sig": false, "md5_digest": "802dccf3f1959beb44e9f34da10d226e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7133, "upload_time": "2018-06-20T01:12:59", "url": "https://files.pythonhosted.org/packages/49/18/5eea3459c3275680bdbc59b3599c37dda410aad2d3d0cac632bddea5cb87/tyo-mq-client-0.0.6.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "802dccf3f1959beb44e9f34da10d226e", "sha256": "29f47259a41bbfb17b5fea02b7b5614b13308af477b3ea5491f2594866b0c77d" }, "downloads": -1, "filename": "tyo-mq-client-0.0.6.tar.gz", "has_sig": false, "md5_digest": "802dccf3f1959beb44e9f34da10d226e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7133, "upload_time": "2018-06-20T01:12:59", "url": "https://files.pythonhosted.org/packages/49/18/5eea3459c3275680bdbc59b3599c37dda410aad2d3d0cac632bddea5cb87/tyo-mq-client-0.0.6.tar.gz" } ] }