switched SUBJECT and TO to use a qpid prefix

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@835509 13f79535-47bb-0310-9956-ffa450edef68

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)