summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2007-01-04 20:45:57 +0000
committerRafael H. Schloming <rhs@apache.org>2007-01-04 20:45:57 +0000
commit9fae14cc56a6608cce8f398319a76ff8b7cb48be (patch)
treeaf747091bac2e00de78d0f442f537f232e2cc25d
parente0c2104bdae8a2f0b2cdaf56951ca585e3067d55 (diff)
downloadqpid-python-9fae14cc56a6608cce8f398319a76ff8b7cb48be.tar.gz
use pythonized names to reference spec constants
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492730 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--python/qpid/connection.py22
1 files changed, 11 insertions, 11 deletions
diff --git a/python/qpid/connection.py b/python/qpid/connection.py
index 6f6c26559c..0b788e091b 100644
--- a/python/qpid/connection.py
+++ b/python/qpid/connection.py
@@ -59,7 +59,7 @@ class Connection:
self.host = host
self.port = port
self.spec = spec
- self.FRAME_END = self.spec.constants.byname["frame end"].id
+ self.FRAME_END = self.spec.constants.bypyname["frame_end"].id
def connect(self):
sock = socket.socket()
@@ -78,14 +78,14 @@ class Connection:
def write(self, frame):
c = self.codec
- c.encode_octet(self.spec.constants.byname[frame.payload.type].id)
+ c.encode_octet(self.spec.constants.bypyname[frame.payload.type].id)
c.encode_short(frame.channel)
frame.payload.encode(c)
c.encode_octet(self.FRAME_END)
def read(self):
c = self.codec
- type = self.spec.constants.byid[c.decode_octet()].name
+ type = pythonize(self.spec.constants.byid[c.decode_octet()].name)
channel = c.decode_short()
payload = Frame.DECODERS[type].decode(self.spec, c)
end = c.decode_octet()
@@ -96,14 +96,14 @@ class Connection:
class Frame:
- METHOD = "frame method"
- HEADER = "frame header"
- BODY = "frame body"
- OOB_METHOD = "frame oob method"
- OOB_HEADER = "frame oob header"
- OOB_BODY = "frame oob body"
- TRACE = "frame trace"
- HEARTBEAT = "frame heartbeat"
+ METHOD = "frame_method"
+ HEADER = "frame_header"
+ BODY = "frame_body"
+ OOB_METHOD = "frame_oob_method"
+ OOB_HEADER = "frame_oob_header"
+ OOB_BODY = "frame_oob_body"
+ TRACE = "frame_trace"
+ HEARTBEAT = "frame_heartbeat"
DECODERS = {}