Legend:
- Unmodified
- Added
- Removed
-
cometd.py
r38 r39 337 337 self.connection = conn 338 338 339 def messageReceived(self, message): 340 print "MESSAGE RECEIVED" 341 self.sendMessage(message) 339 def messageReceived(self, message, channel): 340 self.sendMessage(message,channel) 342 341 pass 343 342 344 def sendMessage(self, message ):343 def sendMessage(self, message, channel): 345 344 if self.connection is not None: 346 print "Sending ---- Delivering" 347 self.connection.deliver(message) 345 self.connection.deliver({"data":message, "channel":channel}) 348 346 else: 349 347 #FIXME make own exception … … 726 724 success["id"] = message["id"] 727 725 728 print "MOOMOOMESSAGE: %s " % message729 726 client = self.clients[message["clientId"]] 730 client.messageReceived(message )727 client.messageReceived(message["data"],message["channel"]) 731 728 return success 732 729 # FIXME: aggregate ACKs!
