Changeset 39
- Timestamp:
- 02/07/08 06:13:01 (11 months ago)
- Files:
-
- 2 modified
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! -
tabled.py
r37 r39 92 92 BasePokerTableHandler.__init__(self) 93 93 94 def messageReceived(self,message): 95 print "########### Hey we recieved a message %s" % message 96 self.dataReceived(message["data"]) 94 def messageReceived(self,message,channel): 95 self.dataReceived(message) 97 96 98 97 def sendMessageViaTransport(self,data): 99 print "##########3Sending Message %s" % data 100 cometd.Client.sendMessage(self,{"data":data,"channel":"/poker"}) 98 cometd.Client.sendMessage(self,data,"/poker") 101 99 102 100
