Some restructuring of the client code:

 * Introduced three separate 'handlers' for the connection, channel and execution 'layers'.
 * Support for asynchronous retrieval of response or completion status.
 * Channel methods no longer included in execution layers command id count.



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

1 files changed, 1 insertions, 8 deletions

diff --git a/python/qpid/peer.py b/python/qpid/peer.py
index bedc96895b..2861d51165 100644
--- a/python/qpid/peer.py
+++ b/python/qpid/peer.py
@@ -376,7 +376,7 @@ class OutgoingCompletion:
 
   def next_command(self, method):
     #the following test is a hack until the track/sub-channel is available
-    if method.klass.name != "execution":
+    if method.is_l4_command():
       self.command_id = self.sequence.next()
 
   def reset(self):
@@ -425,13 +425,6 @@ class IncomingCompletion:
     self.mark = 0               #id of last command of whose completion notification was sent to the other peer
     self.channel = channel
 
-  def next_id(self, method):
-    #the following test is a hack until the track/sub-channel is available
-    if method.klass.name != "execution":
-      return self.sequence.next()
-    else:
-      return 0
-
   def reset(self):
     self.sequence = Sequence(1) #reset counter