diff options
Diffstat (limited to 'python/qpid/driver.py')
| -rw-r--r-- | python/qpid/driver.py | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/python/qpid/driver.py b/python/qpid/driver.py index 93961e5ed0..3ea6655aca 100644 --- a/python/qpid/driver.py +++ b/python/qpid/driver.py @@ -123,6 +123,9 @@ HEADER="!4s4B" EMPTY_DP = DeliveryProperties() EMPTY_MP = MessageProperties() +SUBJECT = "qpid.subject" +TO = "qpid.to" + class Driver: def __init__(self, connection): @@ -739,11 +742,11 @@ class Driver: if msg.subject is not None: if mp.application_headers is None: mp.application_headers = {} - mp.application_headers["subject"] = msg.subject + mp.application_headers[SUBJECT] = msg.subject if msg.to is not None: if mp.application_headers is None: mp.application_headers = {} - mp.application_headers["to"] = msg.to + mp.application_headers[TO] = msg.to if msg.durable: dp.delivery_mode = delivery_mode.persistent enc, dec = get_codec(msg.content_type) @@ -787,8 +790,8 @@ class Driver: msg = Message(content) msg.id = mp.message_id if ap is not None: - msg.to = ap.get("to") - msg.subject = ap.get("subject") + msg.to = ap.get(TO) + msg.subject = ap.get(SUBJECT) msg.user_id = mp.user_id if mp.reply_to is not None: msg.reply_to = reply_to2addr(mp.reply_to) |