module Communication

Defined in:

communication.cr

Constant Summary

SEPARATOR_COMMANDS = " "

Class Method Summary

• .handle_client(client : TCPSocket, queue_processor : Queuing::QueueProcessing)
• .parse_publish(parts)
• .parse_subscribe(parts)
• .parse_unsubscribe(parts)
• .parse_user_command(message : String)
• .send_back_msg(subscriber, queue, msg_type, msg)

Class Method Detail