summaryrefslogtreecommitdiff
path: root/python/qpid/messaging
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2010-07-12 13:43:27 +0000
committerRafael H. Schloming <rhs@apache.org>2010-07-12 13:43:27 +0000
commit3f68fda129c0d62f63e663877aa1da3cbe9a540d (patch)
tree56dbe86bb77d842fc95b754196c5d256c7de85ae /python/qpid/messaging
parent60f49675c9fb71dd7884c74054e748cd853b8b12 (diff)
downloadqpid-python-3f68fda129c0d62f63e663877aa1da3cbe9a540d.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')
-rw-r--r--python/qpid/messaging/message.py16
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
}