[Twisted-Python] Reconnecting PB Client
Does anyone have some example code for building a reconnecting PB client? This is what I have now: from twisted.spread import pb from twisted.internet import reactor from twisted.python import util events = pb.PBClientFactory() reactor.connectTCP("localhost", 8789, events) queue = events.getRootObject()
On Jul 14, 2006, at 4:40 AM, Don Smith wrote:
Does anyone have some example code for building a reconnecting PB client?
I'm trying to do something similar, and not sure where to begin. The docs show how to make a reconnecting client when you define your own protocol, which might help as a starting point: http://twistedmatrix.com/projects/core/documentation/howto/clients.html Does anyone else have any idea how to do this with Perspective Broker? Robert
On Jul 14, 2006, at 4:40 AM, Don Smith wrote:
Does anyone have some example code for building a reconnecting PB client?
I do something like this: class Foo(object): # ... def connect(self): factory = FooMgrFactory() reactor.connectTCP(host, port, factory) return factory.getRootObject().addCallback (self._connected).addErrback( self._catchFailure) def _connected(self, rootObj): self.rootObj = rootObj rootObj.notifyOnDisconnect(self._disconnected) def _disconnected(self, rootObj): self.rootObj = None self.connected = False self.timer = reactor.callLater(defaultTimerDelay, self.connect) def doRemoteOp(self): try: if self.rootObj: self.rootObj.callRemote("foo", arg).addCallback (self.fooreturn) else: self.timer = reactor.callLater(defaultTimerDelay, self.connect) except pb.DeadReferenceError, e: self.rootObj = None self.timer = reactor.callLater(defaultTimerDelay, self.connect) Please advise if this is not a preferred method. Regards, Brendan
participants (3)
-
Brendan Boerner -
Don Smith -
Robert Gravina