summaryrefslogtreecommitdiff
path: root/qpid/python/server010
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-03-06 15:05:04 +0000
committerRafael H. Schloming <rhs@apache.org>2008-03-06 15:05:04 +0000
commit00a8a8b331934b6bebb18d9f2cccad363c939e63 (patch)
treecff36798ca177598860969079c43680faf9d3824 /qpid/python/server010
parent97cf15c41540b002dd88177c9cf5018ba419fab8 (diff)
downloadqpid-python-00a8a8b331934b6bebb18d9f2cccad363c939e63.tar.gz
preliminary support for message headers
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@634289 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/server010')
-rwxr-xr-xqpid/python/server0104
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/python/server010 b/qpid/python/server010
index ee47731a60..ecf76577ec 100755
--- a/qpid/python/server010
+++ b/qpid/python/server010
@@ -28,9 +28,9 @@ class SessionDelegate(Client):
def queue_query(self, qq):
return qq.type.result.type.new((qq.queue,), {})
- def message_transfer(self, cmd, header, body):
+ def message_transfer(self, cmd, headers, body):
m = Message(body)
- m.header = header
+ m.headers = headers
self.session.message_transfer(cmd.destination, cmd.accept_mode, cmd.acquire_mode, m)
def message_accept(self, messages):