Dynamically routing messages in a publish/subscribe system by creating temporal topics for subscriptions and publications

• US 9,940,835 B2
• Filed: 01/16/2014
• Issued: 04/10/2018
• Est. Priority Date: 01/16/2014
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Cuomo, Gennaro A., Singh, Gari R., Yadav, Meeta
• Primary Examiner(s): ALGIBHAH, HAMZA N
• Application Number:
  US14/156,581
• Publication Number:
  US 20150200877A1
• Time in Patent Office: 1,545 Days
• Field of Search: 709209
• CPC Class Codes: G06F 16/447 Temporal browsing, e.g. timeline
• CPC Class Codes: G06F 16/487 using geographical or spatial information, e.g. location
• CPC Class Codes: G06F 16/9537 Spatial or temporal dependent retrieval, e.g. spatiotemporal queries
• CPC Class Codes: G08G 1/0116 from roadside infrastructure, e.g. beacons
• CPC Class Codes: G08G 1/012 from other sources than vehicle or roadside beacons, e.g. mobile networks
• CPC Class Codes: G08G 1/0133 for classifying traffic situation
• CPC Class Codes: G08G 1/0141 for traffic information dissemination
• CPC Class Codes: G08G 1/096716 where the received information does not generate an automatic action on the vehicle control
• CPC Class Codes: G08G 1/096741 where the source of the transmitted information selects which information to transmit to each vehicle
• CPC Class Codes: G08G 1/096775 where the origin of the information is a central station
• CPC Class Codes: H04L 51/04 Real-time or near real-time messaging, e.g. instant messaging [IM]
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 51/222 using geographical location information, e.g. messages transmitted or received in proximity of a certain spot or area
• CPC Class Codes: H04L 51/52 for supporting social networking services
• CPC Class Codes: H04W 4/021 Services related to particular areas, e.g. point of interest [POI] services, venue services or geofences
• CPC Class Codes: H04W 4/21 for social networking applications
• CPC Class Codes: H04W 4/40 for vehicles, e.g. vehicle-to-pedestrians [V2P]
• CPC Class Codes: H04W 4/50 Service provisioning or reconfiguring
• CPC Class Codes: H04W 4/60 Subscription-based services using application servers or record carriers, e.g. SIM application toolkits

Abstract

A method, system and computer program product for dynamically routing messages in a publish/subscribe system. A messaging application receives messages from sensors (e.g., road condition sensors). Upon analyzing the messages using data analytics, an event (e.g., icy road condition) may be correlated with the analyzed messages. In such a scenario, a temporal topic based on the triggered event is created. Furthermore, a temporal publication (e.g., “icy road condition near exit 40”) and a temporal subscription are created. Potential subscribers to be associated with the temporal subscription are identified by using either geo-location information or social media information. Once those subscribers are identified, they are associated with the temporal subscription. The temporal publication is then published to the subscribers associated with the temporal subscription. In this manner, messages are dynamically routed to the appropriate subscribers that may have previously been excluded based on dynamically created temporal topics, subscriptions and publications.

Claims

1. A computer program product for dynamically routing messages in a publish-subscribe system, the computer program product comprising a computer readable storage medium having program code embodied therewith, the program code comprising the programming instructions for:

receiving one or more messages from one or more sensors;

analyzing said one or more messages using data analytics;

correlating one or more of said one or more analyzed messages with an event;

creating a temporal topic over a geo-location area for targeted potential subscribers in response to said one or more of said one or more analyzed messages being correlated with an event;

creating a temporal publication based on said event;

creating a temporal subscription to subscribe to said created temporal topic;

associating subscribers to said temporal subscription that are located within said geo-location area; and

publishing said temporal publication to said subscribers associated with said temporal subscription.

2. The computer program product as recited in claim 1, wherein the program code further comprises the programming instructions for:

projecting a polygon over said geo-location area of said targeted potential subscribers.

3. The computer program product as recited in claim 1, wherein said event corresponds to a driving condition meeting an alert threshold.

4. The computer program product as recited in claim 1, wherein said one or more messages received from said one or more sensors comprises one or more of the following:

biometric, road conditions, driver activity, weather information and geolocation.

5. The computer program product as recited in claim 1, wherein said one or more sensors reside within an automobile.

6. The computer program product as recited in claim 1, wherein the program code further comprises the programming instructions for:

removing said temporal topic, said temporal publication and said temporal subscription after a period of time has elapsed.

7. A system, comprising:

a memory unit for storing a computer program for dynamically routing messages in a publish-subscribe system; and

a processor coupled to the memory unit, wherein the processor is configured to execute the program instructions of the computer program comprising;

receiving one or more messages from one or more sensors;

analyzing said one or more messages using data analytics;

correlating one or more of said one or more analyzed messages with an event;

creating a temporal topic over a geo-location area for targeted potential subscribers in response to said one or more of said one or more analyzed messages being correlated with an event;

creating a temporal publication based on said event;

creating a temporal subscription to subscribe to said created temporal topic;

associating subscribers to said temporal subscription that are located within said geo-location area; and

publishing said temporal publication to said subscribers associated with said temporal subscription.

8. The system as recited in claim 7, wherein the program instructions of the computer program further comprises:

projecting a polygon over said geo-location area of said targeted potential subscribers.

9. The system as recited in claim 7, wherein said event corresponds to a driving condition meeting an alert threshold.

10. The system as recited in claim 7, wherein said one or more messages received from said one or more sensors comprises one or more of the following:

biometric, road conditions, driver activity, weather information and geolocation.

11. The system as recited in claim 7, wherein said one or more sensors reside within an automobile.

12. The system as recited in claim 7, wherein the program instructions of the computer program further comprises:

removing said temporal topic, said temporal publication and said temporal subscription after a period of time has elapsed.

13. A computer program product for dynamically routing messages in a publish-subscribe system, the computer program product comprising a computer readable storage medium having program code embodied therewith, the program code comprising the programming instructions for:

receiving one or more messages from one or more sensors;

analyzing said one or more messages using data analytics;

correlating one or more of said one or more analyzed messages with an event;

creating a temporal topic in response to said one or more of said one or more analyzed messages being correlated with said event;

creating a temporal publication based on said event;

creating a temporal subscription to subscribe to said created temporal topic;

identifying subscribers based on social media to be associated with said temporal subscription; and

publishing said temporal publication to said subscribers associated with said temporal subscription.

14. The computer program product as recited in claim 13, wherein said subscribers are identified to be associated with said temporal subscription based on said social media using natural language processing.

15. The computer program product as recited in claim 13, wherein said event corresponds to a topic of interest to said subscribers that are identified to be associated with said temporal subscription, wherein said subscribers that are identified to be associated with said temporal subscription did not previously register said topic of interest with a messaging application to receive messages related to said topic of interest.

16. The computer program product as recited in claim 13, wherein said one or more messages received from said one or more sensors comprises one or more of the following:

biometric, road conditions, driver activity, weather information and geolocation.

17. The computer program product as recited in claim 13, wherein said one or more sensors reside within an automobile.

18. The computer program product as recited in claim 13, wherein the program code further comprises the programming instructions for:

removing said temporal topic, said temporal publication and said temporal subscription after a period of time has elapsed.