diff --git a/Canguru/CanguruChat.py b/Canguru/CanguruChat.py index 97f762829d94bc01fd299e5b2e547a66ae800e2b..2fc5f92a9b3c5a8f1ccb7e78c9ad0b7fa9a789e0 100755 --- a/Canguru/CanguruChat.py +++ b/Canguru/CanguruChat.py @@ -30,6 +30,7 @@ import socket import threading import sys import binascii +import Queue HOST = "127.0.0.1" # Endereco IP do Servidor SEND_PORT = 5000 # Porta que o Servidor envia @@ -103,14 +104,16 @@ def client (): dest = (HOST, SEND_PORT) print 'Para sair digite exit\n' protocolMessage = Protocol() + queueMessage = Queue.PriorityQueue() protocolMessage.setDestiny() protocolMessage.setPriority() protocolMessage.setMessage() protocolMessage.setSizeof() protocolMessage.setCRC32() msg = protocolMessage.getEmpacotar() + queueMessage.put ((int(protocolMessage.priority), msg)) while protocolMessage.msg <> 'exit': - udp.sendto (msg, dest) + #udp.sendto (msg, dest) protocolMessage = Protocol() protocolMessage.setDestiny() protocolMessage.setPriority() @@ -118,6 +121,10 @@ def client (): protocolMessage.setSizeof() protocolMessage.setCRC32() msg = protocolMessage.getEmpacotar() + queueMessage.put ((int(protocolMessage.priority), msg)) + print queueMessage.get() + print queueMessage.get() + print queueMessage.get() threadServer._Thread__stop() udp.close()