stomper
Advanced tools
| Metadata-Version: 1.1 | ||
| Name: stomper | ||
| Version: 0.2.9 | ||
| Version: 0.4.0 | ||
| Summary: This is a transport neutral client implementation of the STOMP protocol. | ||
@@ -86,9 +86,4 @@ Home-page: https://github.com/oisinmulvihill/stomper | ||
| Ralph Bean has worked to add support for this version of STOMP. This will | ||
| become the default protocol used in stomper 0.3.x releases. | ||
| This is the default version of the of STOMP used in stomper versions 0.3.x. | ||
| For now it can be used as follows:: | ||
| import stomper.stomp_11 as stomper | ||
| * https://stomp.github.io/stomp-specification-1.1.html | ||
@@ -99,5 +94,9 @@ | ||
| This is the default version of the of STOMP used in stomper versions 0.2.x. | ||
| The default will change in stomper versions 0.3.x. | ||
| This is no longer the default protocol version. To use it you can import it as | ||
| follows:: | ||
| import stomper.stomp_10 as stomper | ||
| This is the default version used in stomper version 0.2.x. | ||
| * https://stomp.github.io/stomp-specification-1.0.html | ||
@@ -109,2 +108,18 @@ | ||
| 0.4.0 | ||
| ~~~~~ | ||
| Thanks to Lumír 'Frenzy' Balhar (https://github.com/frenzymadness) contributing | ||
| python3 support. | ||
| 0.3.0 | ||
| ~~~~~ | ||
| This release makes STOMP v1.1 the default protocol. To stick with STOMP v1.0 | ||
| you can continue to use stomper v0.2.9 or change the import in your code to:: | ||
| import stomper.stomp_10 as stomper | ||
| **Note** Any fixes to STOMP v1.0 will only be applied to version >= 0.3. | ||
| 0.2.9 | ||
@@ -114,2 +129,3 @@ ~~~~~ | ||
| Thanks to Ralph Bean for contributing the new protocol 1.1 support: | ||
| * https://github.com/oisinmulvihill/stomper/issues/6 | ||
@@ -116,0 +132,0 @@ * https://github.com/oisinmulvihill/stomper/pull/7 |
@@ -13,2 +13,3 @@ MANIFEST.in | ||
| lib/stomper.egg-info/dependency_links.txt | ||
| lib/stomper.egg-info/requires.txt | ||
| lib/stomper.egg-info/top_level.txt | ||
@@ -15,0 +16,0 @@ lib/stomper/examples/__init__.py |
@@ -1,4 +0,3 @@ | ||
| # TODO, someday switch this to stomp_11 when we trust that it works and is | ||
| # backwards compatible. | ||
| from stomp_10 import ( | ||
| from __future__ import absolute_import | ||
| from .stomp_11 import ( | ||
| Engine, | ||
@@ -10,2 +9,3 @@ Frame, | ||
| ack, | ||
| nack, | ||
| begin, | ||
@@ -12,0 +12,0 @@ commit, |
@@ -8,2 +8,4 @@ """ | ||
| """ | ||
| from __future__ import print_function | ||
| from builtins import str | ||
| import uuid | ||
@@ -108,3 +110,3 @@ import logging | ||
| """ | ||
| print 'Lost connection. Reason:', reason | ||
| print('Lost connection. Reason:', reason) | ||
@@ -115,3 +117,3 @@ | ||
| """ | ||
| print 'Connection failed. Reason:', reason | ||
| print('Connection failed. Reason:', reason) | ||
| ReconnectingClientFactory.clientConnectionFailed(self, connector, reason) | ||
@@ -118,0 +120,0 @@ |
@@ -8,2 +8,4 @@ """ | ||
| """ | ||
| from __future__ import print_function | ||
| from builtins import str | ||
| import uuid | ||
@@ -79,3 +81,3 @@ import logging | ||
| """ | ||
| counter = self.counter.next() | ||
| counter = next(self.counter) | ||
@@ -132,3 +134,3 @@ self.log.info("senderID:%s Saying hello (%d)." % (self.senderID, counter)) | ||
| """ | ||
| print 'Lost connection. Reason:', reason | ||
| print('Lost connection. Reason:', reason) | ||
@@ -139,3 +141,3 @@ | ||
| """ | ||
| print 'Connection failed. Reason:', reason | ||
| print('Connection failed. Reason:', reason) | ||
| ReconnectingClientFactory.clientConnectionFailed(self, connector, reason) | ||
@@ -142,0 +144,0 @@ |
@@ -8,2 +8,3 @@ """ | ||
| """ | ||
| from __future__ import print_function | ||
| import logging | ||
@@ -110,3 +111,3 @@ | ||
| """ | ||
| print 'Lost connection. Reason:', reason | ||
| print('Lost connection. Reason:', reason) | ||
@@ -117,3 +118,3 @@ | ||
| """ | ||
| print 'Connection failed. Reason:', reason | ||
| print('Connection failed. Reason:', reason) | ||
| ReconnectingClientFactory.clientConnectionFailed(self, connector, reason) | ||
@@ -120,0 +121,0 @@ |
@@ -8,2 +8,3 @@ """ | ||
| """ | ||
| from __future__ import print_function | ||
| import logging | ||
@@ -121,3 +122,3 @@ | ||
| """ | ||
| print 'Lost connection. Reason:', reason | ||
| print('Lost connection. Reason:', reason) | ||
@@ -128,3 +129,3 @@ | ||
| """ | ||
| print 'Connection failed. Reason:', reason | ||
| print('Connection failed. Reason:', reason) | ||
| ReconnectingClientFactory.clientConnectionFailed(self, connector, reason) | ||
@@ -131,0 +132,0 @@ |
@@ -9,2 +9,3 @@ """ | ||
| """ | ||
| from __future__ import print_function | ||
| import pprint | ||
@@ -19,3 +20,3 @@ | ||
| msg = stomper.connect('bob','1234') | ||
| print "msg:\n%s\n" % pprint.pformat(msg) | ||
| print("msg:\n%s\n" % pprint.pformat(msg)) | ||
@@ -77,3 +78,3 @@ #>>> 'CONNECT\nlogin:bob\npasscode:1234\n\n\x00\n' | ||
| response = responder.react(server_msg) | ||
| print "response:\n%s\n" % pprint.pformat(response) | ||
| print("response:\n%s\n" % pprint.pformat(response)) | ||
@@ -92,3 +93,3 @@ #>>> 'ACK\nmessage-id: some-message-id\n\n\x00\n' | ||
| """ | ||
| print "Got a message:\n%s\n" % msg['body'] | ||
| print("Got a message:\n%s\n" % msg['body']) | ||
@@ -103,3 +104,3 @@ # do something with the message... | ||
| response = responder2.react(server_msg) | ||
| print "response:\n%s\n" % pprint.pformat(response) | ||
| print("response:\n%s\n" % pprint.pformat(response)) | ||
| #>>> 'ACK\nmessage-id: some-message-id\n\n\x00\n' | ||
@@ -113,3 +114,3 @@ | ||
| send_message = stomper.send(DESTINATION, 'hello there') | ||
| print "1. send_message:\n%s\n" % pprint.pformat(send_message) | ||
| print("1. send_message:\n%s\n" % pprint.pformat(send_message)) | ||
@@ -124,3 +125,3 @@ #>>> 'SEND\ndestination: /queue/inbox\n\nhello there\x00\n' | ||
| msg.body = "hello queue a" | ||
| print "2. send_message:\n%s\n" % pprint.pformat(msg.pack()) | ||
| print("2. send_message:\n%s\n" % pprint.pformat(msg.pack())) | ||
@@ -127,0 +128,0 @@ #>>> 'SEND\ncustom-header:1234\ndestination:/queue/a\n\nhello queue a\n\n\x00\n' |
@@ -32,2 +32,4 @@ """ | ||
| """ | ||
| from __future__ import absolute_import | ||
| from builtins import object | ||
| import re | ||
@@ -39,4 +41,4 @@ import uuid | ||
| import utils | ||
| import stompbuffer | ||
| from . import utils | ||
| from . import stompbuffer | ||
@@ -65,3 +67,8 @@ # This is used as a return from message responses functions. | ||
| try: | ||
| stringTypes = (str, unicode) | ||
| except NameError: | ||
| stringTypes = (str,) | ||
| def get_log(): | ||
@@ -415,5 +422,5 @@ return logging.getLogger("stomper") | ||
| mtype = type(msg) | ||
| if mtype in types.StringTypes: | ||
| if mtype in stringTypes: | ||
| msg = unpack_frame(msg) | ||
| elif mtype == types.DictType: | ||
| elif mtype == dict: | ||
| pass | ||
@@ -423,3 +430,3 @@ else: | ||
| if self.states.has_key(msg['cmd']): | ||
| if msg['cmd'] in self.states: | ||
| # print("reacting to message - %s" % msg['cmd']) | ||
@@ -459,3 +466,3 @@ returned = self.states[msg['cmd']](msg) | ||
| transaction_id = None | ||
| if msg['headers'].has_key('transaction-id'): | ||
| if 'transaction-id' in msg['headers']: | ||
| transaction_id = msg['headers']['transaction-id'] | ||
@@ -480,3 +487,3 @@ | ||
| brief_msg = "" | ||
| if msg['headers'].has_key('message'): | ||
| if 'message' in msg['headers']: | ||
| brief_msg = msg['headers']['message'] | ||
@@ -505,3 +512,3 @@ | ||
| brief_msg = "" | ||
| if msg['headers'].has_key('receipt-id'): | ||
| if 'receipt-id' in msg['headers']: | ||
| brief_msg = msg['headers']['receipt-id'] | ||
@@ -508,0 +515,0 @@ |
@@ -33,2 +33,4 @@ """ | ||
| """ | ||
| from __future__ import absolute_import | ||
| from builtins import object | ||
| import re | ||
@@ -40,4 +42,4 @@ import uuid | ||
| import utils | ||
| import stompbuffer | ||
| from . import utils | ||
| from . import stompbuffer | ||
@@ -66,3 +68,8 @@ # This is used as a return from message responses functions. | ||
| try: | ||
| stringTypes = (str, unicode) | ||
| except NameError: | ||
| stringTypes = (str,) | ||
| def get_log(): | ||
@@ -455,5 +462,5 @@ return logging.getLogger("stomper") | ||
| mtype = type(msg) | ||
| if mtype in types.StringTypes: | ||
| if mtype in stringTypes: | ||
| msg = unpack_frame(msg) | ||
| elif mtype == types.DictType: | ||
| elif mtype == dict: | ||
| pass | ||
@@ -463,3 +470,3 @@ else: | ||
| if self.states.has_key(msg['cmd']): | ||
| if msg['cmd'] in self.states: | ||
| # print("reacting to message - %s" % msg['cmd']) | ||
@@ -500,3 +507,3 @@ returned = self.states[msg['cmd']](msg) | ||
| transaction_id = None | ||
| if msg['headers'].has_key('transaction-id'): | ||
| if 'transaction-id' in msg['headers']: | ||
| transaction_id = msg['headers']['transaction-id'] | ||
@@ -521,3 +528,3 @@ | ||
| brief_msg = "" | ||
| if msg['headers'].has_key('message'): | ||
| if 'message' in msg['headers']: | ||
| brief_msg = msg['headers']['message'] | ||
@@ -546,3 +553,3 @@ | ||
| brief_msg = "" | ||
| if msg['headers'].has_key('receipt-id'): | ||
| if 'receipt-id' in msg['headers']: | ||
| brief_msg = msg['headers']['receipt-id'] | ||
@@ -549,0 +556,0 @@ |
@@ -9,2 +9,3 @@ """ | ||
| """ | ||
| from builtins import object | ||
@@ -11,0 +12,0 @@ import re |
@@ -33,3 +33,3 @@ ###################################################################### | ||
| return False | ||
| if type ( msg ) != types.DictType: | ||
| if type ( msg ) != dict: | ||
| return False | ||
@@ -36,0 +36,0 @@ if msg [ 'cmd' ] != cmd: |
@@ -22,3 +22,3 @@ """ | ||
| import stomper | ||
| import stomper.stomp_10 as stomper | ||
@@ -25,0 +25,0 @@ |
@@ -22,3 +22,4 @@ """ | ||
| import stomper.stomp_11 as stomper | ||
| import stomper | ||
| #.stomp_11 as stomper | ||
@@ -25,0 +26,0 @@ |
+25
-9
| Metadata-Version: 1.1 | ||
| Name: stomper | ||
| Version: 0.2.9 | ||
| Version: 0.4.0 | ||
| Summary: This is a transport neutral client implementation of the STOMP protocol. | ||
@@ -86,9 +86,4 @@ Home-page: https://github.com/oisinmulvihill/stomper | ||
| Ralph Bean has worked to add support for this version of STOMP. This will | ||
| become the default protocol used in stomper 0.3.x releases. | ||
| This is the default version of the of STOMP used in stomper versions 0.3.x. | ||
| For now it can be used as follows:: | ||
| import stomper.stomp_11 as stomper | ||
| * https://stomp.github.io/stomp-specification-1.1.html | ||
@@ -99,5 +94,9 @@ | ||
| This is the default version of the of STOMP used in stomper versions 0.2.x. | ||
| The default will change in stomper versions 0.3.x. | ||
| This is no longer the default protocol version. To use it you can import it as | ||
| follows:: | ||
| import stomper.stomp_10 as stomper | ||
| This is the default version used in stomper version 0.2.x. | ||
| * https://stomp.github.io/stomp-specification-1.0.html | ||
@@ -109,2 +108,18 @@ | ||
| 0.4.0 | ||
| ~~~~~ | ||
| Thanks to Lumír 'Frenzy' Balhar (https://github.com/frenzymadness) contributing | ||
| python3 support. | ||
| 0.3.0 | ||
| ~~~~~ | ||
| This release makes STOMP v1.1 the default protocol. To stick with STOMP v1.0 | ||
| you can continue to use stomper v0.2.9 or change the import in your code to:: | ||
| import stomper.stomp_10 as stomper | ||
| **Note** Any fixes to STOMP v1.0 will only be applied to version >= 0.3. | ||
| 0.2.9 | ||
@@ -114,2 +129,3 @@ ~~~~~ | ||
| Thanks to Ralph Bean for contributing the new protocol 1.1 support: | ||
| * https://github.com/oisinmulvihill/stomper/issues/6 | ||
@@ -116,0 +132,0 @@ * https://github.com/oisinmulvihill/stomper/pull/7 |
+24
-8
@@ -78,9 +78,4 @@ ======= | ||
| Ralph Bean has worked to add support for this version of STOMP. This will | ||
| become the default protocol used in stomper 0.3.x releases. | ||
| This is the default version of the of STOMP used in stomper versions 0.3.x. | ||
| For now it can be used as follows:: | ||
| import stomper.stomp_11 as stomper | ||
| * https://stomp.github.io/stomp-specification-1.1.html | ||
@@ -91,5 +86,9 @@ | ||
| This is the default version of the of STOMP used in stomper versions 0.2.x. | ||
| The default will change in stomper versions 0.3.x. | ||
| This is no longer the default protocol version. To use it you can import it as | ||
| follows:: | ||
| import stomper.stomp_10 as stomper | ||
| This is the default version used in stomper version 0.2.x. | ||
| * https://stomp.github.io/stomp-specification-1.0.html | ||
@@ -101,2 +100,18 @@ | ||
| 0.4.0 | ||
| ~~~~~ | ||
| Thanks to Lumír 'Frenzy' Balhar (https://github.com/frenzymadness) contributing | ||
| python3 support. | ||
| 0.3.0 | ||
| ~~~~~ | ||
| This release makes STOMP v1.1 the default protocol. To stick with STOMP v1.0 | ||
| you can continue to use stomper v0.2.9 or change the import in your code to:: | ||
| import stomper.stomp_10 as stomper | ||
| **Note** Any fixes to STOMP v1.0 will only be applied to version >= 0.3. | ||
| 0.2.9 | ||
@@ -106,2 +121,3 @@ ~~~~~ | ||
| Thanks to Ralph Bean for contributing the new protocol 1.1 support: | ||
| * https://github.com/oisinmulvihill/stomper/issues/6 | ||
@@ -108,0 +124,0 @@ * https://github.com/oisinmulvihill/stomper/pull/7 |
+3
-5
@@ -14,3 +14,3 @@ """ | ||
| ProjectUrl = "https://github.com/oisinmulvihill/stomper" | ||
| Version = '0.2.9' | ||
| Version = '0.4.0' | ||
| Author = 'Oisin Mulvihill' | ||
@@ -36,5 +36,3 @@ AuthorEmail = 'oisin dot mulvihill at gmail com' | ||
| # Recover the ReStructuredText docs: | ||
| fd = file("README.rst") | ||
| Description = fd.read() | ||
| fd.close() | ||
| Description = open("README.rst").read() | ||
@@ -52,3 +50,3 @@ TestSuite = 'stomper.tests' | ||
| needed = [] | ||
| needed = ['future'] | ||
| if sys.version_info < (2, 5): | ||
@@ -55,0 +53,0 @@ needed += [ |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
118752
1.49%26
4%2328
0.82%