Changeset 756

Show
Ignore:
Timestamp:
08/03/08 08:15:13 (4 months ago)
Author:
sylvain
Message:

Support for items retrieval

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • oss/headstock/headstock/protocol/extension/pubsub.py

    r753 r756  
    321321                "xmpp.result"  : "Activity responses", 
    322322                "xmpp.error"   : "Activity response error", 
     323                "xmpp.all.get"     : "Activity requests", 
     324                "xmpp.all.set"     : "Activity responses", 
     325                "xmpp.all.result"  : "Activity responses", 
     326                "xmpp.all.error"   : "Activity response error", 
    323327                } 
    324328     
     
    534538               "retrieve.inbox"        : "", 
    535539               "retrieve.forward"      : "", 
     540               "retrieve.all.inbox"      : "", 
     541               "retrieve.all.forward"      : "", 
    536542               "create.inbox"        : "", 
    537543               "create.forward"      : "", 
     
    553559               "in.retrieve.set"          : "Retrieve items responses", 
    554560               "in.retrieve.result"       : "Retrieve items responses", 
     561               "in.retrieve.all.error"        : "Retrieve items response error", 
     562               "in.retrieve.all.get"          : "Retrieve items requests", 
     563               "in.retrieve.all.set"          : "Retrieve items responses", 
     564               "in.retrieve.all.result"       : "Retrieve items responses", 
    555565               "in.create.error"        : "Publish items response error", 
    556566               "in.create.get"          : "Publish items requests", 
     
    587597                "log"                     : "log", 
    588598                "retrieve.outbox"           : "", 
     599                "retrieve.all.outbox"           : "", 
    589600                "create.outbox"           : "", 
    590601                "purge.outbox"            : "", 
     
    599610                "out.retrieve.set"          : "Retrieve items responses", 
    600611                "out.retrieve.result"       : "Retrieve items responses", 
     612                "out.retrieve.all.error"       : "Retrieve items responses", 
     613                "out.retrieve.all.get"          : "Retrieve items requests", 
     614                "out.retrieve.all.set"          : "Retrieve items responses", 
     615                "out.retrieve.all.result"       : "Retrieve items responses", 
    601616                "out.create.get"          : "Publish items requests", 
    602617                "out.create.set"          : "Publish items responses", 
     
    728743        self.link((self, 'retrieve.all.inbox'), (itemretrievedisp, 'inbox'), passthrough=1) 
    729744        self.link((self, 'retrieve.all.forward'), (itemretrievedisp, 'forward'), passthrough=1) 
    730         self.link((self, 'in.retrieve.get'), (itemretrievedisp, 'forward'), passthrough=1) 
    731         self.link((self, 'in.retrieve.set'), (itemretrievedisp, 'forward'), passthrough=1) 
    732         self.link((self, 'in.retrieve.result'), (itemretrievedisp, 'forward'), passthrough=1) 
    733         self.link((self, 'in.retrieve.error'), (itemretrievedisp, 'forward'), passthrough=1) 
     745        self.link((self, 'in.retrieve.all.get'), (itemretrievedisp, 'forward'), passthrough=1) 
     746        self.link((self, 'in.retrieve.all.set'), (itemretrievedisp, 'forward'), passthrough=1) 
     747        self.link((self, 'in.retrieve.all.result'), (itemretrievedisp, 'forward'), passthrough=1) 
     748        self.link((self, 'in.retrieve.all.error'), (itemretrievedisp, 'forward'), passthrough=1) 
    734749        self.link((itemretrievedisp, 'outbox'), (self, 'retrieve.outbox'), passthrough=2) 
    735750        self.link((itemretrievedisp, 'xmpp.get'), (self, 'out.retrieve.get'), passthrough=2) 
     
    737752        self.link((itemretrievedisp, 'xmpp.result'), (self, 'out.retrieve.result'), passthrough=2) 
    738753        self.link((itemretrievedisp, 'xmpp.error'), (self, 'out.retrieve.error'), passthrough=2) 
     754        self.link((itemretrievedisp, 'xmpp.all.get'), (self, 'out.retrieve.all.get'), passthrough=2) 
     755        self.link((itemretrievedisp, 'xmpp.all.set'), (self, 'out.retrieve.all.set'), passthrough=2) 
     756        self.link((itemretrievedisp, 'xmpp.all.result'), (self, 'out.retrieve.all.result'), passthrough=2) 
     757        self.link((itemretrievedisp, 'xmpp.all.error'), (self, 'out.retrieve.all.error'), passthrough=2) 
    739758        self.link((itemretrievedisp, 'unknown'), (self, 'unknown'), passthrough=2) 
    740759        self.link((itemretrievedisp, 'log'), (self, 'log'), passthrough=2)