SYSTEMS AND METHODS OF REAL-TIME DATA SUBSCRIPTION AND REPORTING FOR TELECOMMUNICATIONS SYSTEMS AND DEVICES

• US 20130204959A1
• Filed: 02/02/2012
• Published: 08/08/2013
• Est. Priority Date: 02/02/2012
• Status: Active Grant

• Current Assignee: Dialogic, Inc. (Enghouse Systems Limited)
• Original Assignee: Dialogic, Inc. (Enghouse Systems Limited)
• Inventors: Zhang, Xingguo, Zhu, Yimin, Kumar, Nitesh, Atluri, Sudheera, Dukka, Parthasarathi
• Granted Patent: US 8,825,779 B2
• Time in Patent Office: Days
• US Class Current: 709/213
• CPC Class Codes: G06F 2209/544 Remote
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06Q 40/04 Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

Systems and methods of performing real-time data subscription and reporting for telecommunications systems and devices. The systems and methods employ a real-time data aggregation component that can manage subscription requests for real-time data objects stored on the telecommunications systems and devices from one or more users over a network, dynamically start and stop such subscription requests, cache the requested real-time data objects, and supply the real-time data to the respective users. By employing the real-time data aggregation component to handle such subscription requests for data from one or more users, the systems and methods can supply such data, including real-time data, to the respective users, while reducing the overhead on the telecommunications systems and devices and increasing overall system performance.

Claims

1. A system for providing real-time data subscription and reporting for telecommunications systems and devices, the system being communicably coupleable, over at least one network, to at least one first user client and at least one first telecommunications system or device, the system comprising:

a real-time data aggregation component including a cache memory, the real-time data aggregation component being operative;

in response to receipt of at least one first request for the real-time data from the first user client, to send at least one subscription start message for the real-time data to the first telecommunications system or device;

to receive the real-time data from the first telecommunications system or device;

to store the real-time data in the cache memory;

in response to receipt, at a predetermined time interval, of at least one second request for the real-time data from the first user client, to send, substantially immediately in response to the second request for the real-time data, the real-time data from the cache memory to the first user client; and

after having received no further request for the real-time data for a predetermined period of time, to send at least one subscription stop message for the real-time data to the first telecommunications system or device.

2. The system of claim 1 wherein the real-time data aggregation component is further operative, prior to sending the subscription stop message, to receive at least one update to the real-time data from the first telecommunications system or device, in response to at least one change in the real-time data.

3. The system of claim 1 wherein the real-time data includes first data on a first data object and second data on a second data object, and wherein the real-time data aggregation component is further operative:

to send at least one first subscription start message for the first data object to the first telecommunications system or device; and

to send at least one second subscription start message for the second data object to a second telecommunications system or device.

4. The system of claim 3 wherein the real-time data aggregation component is further operative:

to receive the first data on the first data object from the first telecommunications system or device; and

to receive the second data on the second data object from the second telecommunications system or device.

5. The system of claim 4 wherein the real-time data aggregation component is further operative to store the first data on the first data object, and the second data on the second data object, in the cache memory.

6. The system of claim 1 wherein the real-time data aggregation component is further operative to generate at least one list of user clients that have made at least one request for the real-time data, the list of user clients including the first user client.

7. The system of claim 6 wherein the real-time data aggregation component is further operative, after having received no further request for the real-time data for the predetermined period of time, to remove the first user client from the list of user clients.

8. The system of claim 7 wherein the real-time data aggregation component is further operative, in the event all user clients have been removed from the list of user clients, to send the subscription stop message to the first telecommunications system or device.

9. The system of claim 1 wherein the real-time data aggregation component is further operative to determine a time of a last request for the real-time data.

10. The system of claim 9 wherein the real-time data aggregation component is further operative to determine a time of a last update to the real-time data.

11. The system of claim 10 wherein the real-time data aggregation component is further operative to determine whether or not to send the subscription stop message to the first telecommunications system or device based at least on a comparison of the time of the last request for the real-time data, and the time of the last update to the real-time data.

12. The system of claim 10 wherein the real-time data aggregation component is further operative to obtain a difference between the time of the last update to the real-time data, and the time of the last request for the real-time data, and, in the event the difference between the time of the last update to the real-time data and the time of the last request for the real-time data exceeds a predetermined threshold value, to send the subscription stop message to the first telecommunications system or device.

13. The system of claim 1 wherein the real-time data aggregation component is further operative:

to receive at least one request for a first portion of data on a first data object from the first user client; and

to receive at least one request for a second portion of data on the first data object from a second user client.

14. The system of claim 13 wherein the real-time data aggregation component is further operative:

to consolidate the requests for the first portion of data and the second portion of data on the first data object into a consolidated subscription start message for the first and second portions of data on the first data object; and

to send the consolidated subscription start message to the first telecommunications system or device.

15. The system of claim 14 wherein the real-time data aggregation component is further operative to consolidate at least one list of user clients that have made at least one request for the first and second portions of data on the first data object into a consolidated list of user clients, the consolidated list of user clients including the first user client and the second user client.

16. The system of claim 15 wherein the real-time data aggregation component is further operative, after having received no further requests for the first and second portions of data on the first data object for the predetermined period of time, to remove one or both of the first user client and the second user client from the consolidated list of user clients.

17. The system of claim 16 wherein the real-time data aggregation component is further operative:

in the event all user clients have been removed from the consolidated list of user clients, to consolidate the no further requests for the first and second portions of data on the first data object into a consolidated subscription stop message; and

to send the consolidated subscription stop message for the first and second portions of data on the first data object to the first telecommunications system or device.

18. The system of claim 1 wherein the real-time data aggregation component is further operative:

to send the subscription start message for the real-time data to the first telecommunications system or device, the subscription start message including a timeout value for the first telecommunications system or device; and

prior to expiration of the timeout value, to receive the real-time data from the first telecommunications system or device.

19. A method of providing real-time data subscription and reporting for telecommunications systems and devices, comprising the steps of:

in response to receipt of at least one first request for real-time data from a first user client, sending, by a real-time data aggregation component including a cache memory, at least one subscription start message for the real-time data to a first telecommunications system or device;

receiving, at the real-time data aggregation component, the real-time data from the first telecommunications system or device;

storing, by the real-time data aggregation component, the real-time data in the cache memory;

in response to receipt, at a predetermined time interval, of at least one second request for the real-time data from the first user client, sending, by the real-time data aggregation component substantially immediately in response to the second request for the real-time data, the real-time data from the cache memory to the first user client; and

after having received no further request for the real-time data for a predetermined period of time, sending, by the real-time data aggregation component, at least one subscription stop message for the real-time data to the first telecommunications system or device.

20. The method of claim 19 further comprising:

generating, by the real-time data aggregation component, at least one list of user clients that have made at least one request for the real-time data, the list of user clients including the first user client.

21. The method of claim 20 further comprising:

after having received no further request for the real-time data for the predetermined period of time, removing, by the real-time data aggregation component, the first user client from the list of user clients.

22. The method of claim 21 further comprising:

in the event all user clients have been removed from the list of user clients, sending, by the real-time data aggregation component, the subscription stop message to the first telecommunications system or device.

23. The method of claim 19 further comprising:

determining, by the real-time data aggregation component, a time of a last request for the real-time data.

24. The method of claim 23 further comprising:

determining, by the real-time data aggregation component, a time of a last update to the real-time data.

25. The method of claim 24 further comprising:

determining, by the real-time data aggregation component, whether or not to send the subscription stop message to the first telecommunications system or device based at least on a comparison of the time of the last request for the real-time data, and the time of the last update to the real-time data.

26. The method of claim 24 further comprising:

obtaining, by the real-time data aggregation component, a difference between the time of the last update to the real-time data, and the time of the last request for the real-time data; and

in the event the difference between the time of the last update to the real-time data and the time of the last request for the real-time data exceeds a predetermined threshold value, sending, by the real-time data aggregation component, the subscription stop message to the first telecommunications system or device.

27. The method of claim 19 further comprising:

receiving, at the real-time data aggregation component, at least one request for a first portion of data on a first data object from the first user client; and

receiving, at the real-time data aggregation component, at least one request for a second portion of data on the first data object from a second user client.

28. The method of claim 27 further comprising:

consolidating, by the real-time data aggregation component, the requests for the first portion of data and the second portion of data on the first data object into a consolidated subscription start message for the first and second portions of data on the first data object; and

sending, by the real-time data aggregation component, the consolidated subscription start message to the first telecommunications system or device.

29. The method of claim 28 further comprising:

consolidating, by the real-time data aggregation component, at least one list of user clients that have made at least one request for the first and second portions of data on the first data object into a consolidated list of user clients, the consolidated list of user clients including the first user client and the second user client.

30. The method of claim 29 further comprising:

after having received no further requests for the first and second portions of data on the first data object for the predetermined period of time, removing, by the real-time data aggregation component, one or both of the first user client and the second user client from the consolidated list of user clients.

31. The method of claim 30 further comprising:

in the event all user clients have been removed from the consolidated list of user clients, consolidating, by the real-time data aggregation component, the no further requests for the first and second portions of data on the first data object into a consolidated subscription stop message; and

sending, by the real-time data aggregation component, the consolidated subscription stop message for the first and second portions of data on the first data object to the first telecommunications system or device.

32. The method of claim 19 further comprising:

sending, by the real-time data aggregation component, the subscription start message for the real-time data to the first telecommunications system or device, the subscription start message including a timeout value for the first telecommunications system or device; and

prior to expiration of the timeout value, receiving, at the real-time data aggregation component, the real-time data from the first telecommunications system or device.