in deployment/ecr/distributed-load-testing-on-aws-load-tester/ecslistener.py [0:0]
def messaging(server_socket):
"""Accept a message on a given socket and return message"""
connection_socket, addr = server_socket.accept()
#decode message
message = recv_message(connection_socket).decode()
print("Received: " + message)
i = 0
#Keep listening for message if not start (Limit 5 messages)
while(message != "start" and i < 5):
print("message " + i + ": " + message)
#Get message from client
message = recv_message(connection_socket).decode()
i += 1