From e9e915775bdb77b6483c48f111be3299b94f592b Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Thu, 6 Mar 2008 13:00:58 +0000
Subject: added codec for sequence_set; added id to Message; RangeSet ->
 RangedSet; added RangedSet.add(lower, upper)

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634255 13f79535-47bb-0310-9956-ffa450edef68
---
 python/qpid/session.py | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

(limited to 'python/qpid/session.py')

diff --git a/python/qpid/session.py b/python/qpid/session.py
index 334902bbf3..7702a19251 100644
--- a/python/qpid/session.py
+++ b/python/qpid/session.py
@@ -19,7 +19,7 @@
 
 from threading import Event, RLock
 from invoker import Invoker
-from datatypes import RangeSet, Struct, Future
+from datatypes import RangedSet, Struct, Future
 from codec010 import StringCodec
 from assembler import Segment
 from queue import Queue
@@ -170,7 +170,7 @@ class Receiver:
     self.session = session
     self.next_id = None
     self.next_offset = None
-    self._completed = RangeSet()
+    self._completed = RangedSet()
 
   def received(self, seg):
     if self.next_id == None or self.next_offset == None:
@@ -220,8 +220,6 @@ class Sender:
       else:
         idx += 1
 
-from queue import Queue, Closed, Empty
-
 class Delegate:
 
   def __init__(self, session):
@@ -238,6 +236,7 @@ class Client(Delegate):
   def message_transfer(self, cmd, headers, body):
     m = Message(body)
     m.headers = headers
+    m.id = cmd.id
     messages = self.session.incoming(cmd.destination)
     messages.put(m)
     msg.debug("RECV: %s", m)
-- 
cgit v1.2.1