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

Patent metadata

Field	Value
Publication number	US-10169992-B2
Application number	US-201815867387-A
Country	US
Kind code	B2
Filing date	Jan 10, 2018
Priority date	Jan 16, 2014
Publication date	Jan 1, 2019
Grant date	Jan 1, 2019

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.

First claim

The invention claimed is:

1. 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 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, who had not previously registered to receive messages pertaining to said created temporal topic, based on social media to be associated with said temporal subscription; and
publishing said temporal publication to said subscribers associated with said temporal subscription.

2. The system as recited in claim 1 , wherein said subscribers are identified to be associated with said temporal subscription based on said social media using natural language processing.

3. The system as recited in claim 1 , 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.

4. The system 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 system as recited in claim 1 , wherein said one or more sensors reside within an automobile.

6. The system as recited in claim 1 , wherein the program instructions of the computer program further comprise:
removing said temporal topic, said temporal publication and said temporal subscription after a period of time has elapsed.

Assignees

• IBM

Inventors

• Cuomo Gennaro A
• Singh Gari R
• Yadav Meeta

Classifications

• G08G1/0133

  for classifying traffic situation · CPC title

• H04W4/21

  for social networking applications · CPC title

• G06F17/3087

  Physics · mapped topic

• H04L51/14

  Electricity · mapped topic

• H04W4/50

  Service provisioning or reconfiguring · CPC title