def messaging()

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