SYSTEM AND METHOD FOR MANAGING MESSAGE QUEUES IN A PEER-TO-PEER COMMUNICATION NETWORK

摘要

Disclosed is a method and system for managing one or more message queues in a peer-to-peer communication network. The system comprises of an initialization module, a queue manager, a load balancing module, a queue monitor and a fault detection and handling module. The initialization module initiates a communication channel between one or more peers through the message queue. The queue manager is configured to manage communication between peers through a unified communication system. The load balancing module uniformly distributes a load across the message queues for a transaction. The queue monitor is configured to monitor the message queues corresponding to a service and a transcode related to the service. The fault detection and handling module is configured to detect state of the server in the unified communication system and dynamically route the messages in the message queue to a next available server.

主权项

1. A method for managing one or more message queues in a peer-to-peer communication network to improve the efficiency and reliability of the peer-to-peer communications network, the method comprising:
providing a processor and a non-transitory memory coupled to said processor, wherein the non-transitory memory comprises programmed instructions; initiating a communication channel between two or more peers over a session through a message queue; managing communication between the peers through a unified communication system, the unified communication system including a plurality of received message queues on a plurality of servers, and enabling one or more of the peers to identify the message queue in order to transmit and receive a message, wherein managing further comprises:
uniformly distributing a load across the plurality of received message queues for a transaction in the unified communication system based upon a pre-defined condition; monitoring the plurality of received message queues corresponding to a service and a transcode related to the service, wherein monitoring further comprises:
detecting a load state of the server in the unified communication system to determine a load distribution of the unified communications system, wherein a received message in the received message queue is dynamically routed to a next available server based on the load distribution; wherein the managing, the distributing, the monitoring and the detecting are performed by the processor using the programmed instructions stored in the non-transitory memory.