diff options
author | Rafael H. Schloming <rhs@apache.org> | 2010-07-12 13:43:27 +0000 |
---|---|---|
committer | Rafael H. Schloming <rhs@apache.org> | 2010-07-12 13:43:27 +0000 |
commit | 4739ca25936b56e123a10aca584064478500dca4 (patch) | |
tree | 56dbe86bb77d842fc95b754196c5d256c7de85ae /python/qpid/messaging/message.py | |
parent | 3ece0b6afe552f832962ffea5a5143c7d54453d3 (diff) | |
download | qpid-python-4739ca25936b56e123a10aca584064478500dca4.tar.gz |
fixed payload of None for text/plain messages
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@963280 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/messaging/message.py')
-rw-r--r-- | python/qpid/messaging/message.py | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/python/qpid/messaging/message.py b/python/qpid/messaging/message.py index e2406f16e7..b70b365c16 100644 --- a/python/qpid/messaging/message.py +++ b/python/qpid/messaging/message.py @@ -49,11 +49,23 @@ TYPE_MAPPINGS={ DEFAULT_CODEC = (lambda x: x, lambda x: x) +def encode_text_plain(x): + if x is None: + return None + else: + return x.encode("utf8") + +def decode_text_plain(x): + if x is None: + return None + else: + return x.decode("utf8") + TYPE_CODEC={ "amqp/map": codec("map"), "amqp/list": codec("list"), - "text/plain; charset=utf8": (lambda x: x.encode("utf8"), lambda x: x.decode("utf8")), - "text/plain": (lambda x: x.encode("utf8"), lambda x: x.decode("utf8")), + "text/plain; charset=utf8": (encode_text_plain, decode_text_plain), + "text/plain": (encode_text_plain, decode_text_plain), "": DEFAULT_CODEC, None: DEFAULT_CODEC } |