Searched refs:messageDeliverer (Results 1 – 1 of 1) sorted by relevance
556 def __init__(self, messageDeliverer, useActiveChannels=True): argument557 self.messageDeliverer = messageDeliverer574 response = self.messageDeliverer.basketCaseReceived(ctx, messageData)576 …req.notifyFinish().addErrback(lambda err: self.messageDeliverer._unregisterDeferredAsOutputChannel…