Content based message routing for supply chain information sharing
A supply chain message routing method includes registering in a supply chain information sharing data processing system, a multiplicity of different actors in a supply chain and generating a knowledge graph that includes different entities representative of corresponding ones of the actors joined by edges representative of relationships between respectively joined ones of the entities. The knowledge graph additionally indicates a role for each of the actors. The method also includes monitoring an event log of events published thereto by the different actors and responds to a new event posted to the event log by extracting from the event, keywords pertaining to the supply chain, mapping the keywords to one or more roles of the supply chain, identifying a set of entities in the knowledge graph corresponding to the roles, formulating a message from the new event, and publishing the formulated message to each entity in the identified set.
1. A supply chain message routing method comprising:
registering in a supply chain information sharing data processing system, a multiplicity of different actors in a supply chain;
generating a knowledge graph in memory of the system comprising different entities representative of corresponding ones of the actors of the supply chain joined by edges representative of relationships between respectively joined ones of the entities, the knowledge graph additionally indicating a role for each of the actors;
storing in the memory, both an access control list defining which ones of the different entities of the generated knowledge graph are permitted to view which types of messages according to particular content of the messages, and also an index of tokens mapping each of the tokens to one or more of synonymous keywords reflective of supply chain terminology;
monitoring an event log of events published thereto by the different actors of the knowledge graph; and,
responding to a new event posted to the event log by:
(1) extracting content from the event, the content comprising one or more keywords pertaining to the supply chain,
(2) generating uniform tokens from the keywords by locating in the index in the memory, the uniform tokens mapped to the extracted keywords, and then mapping the uniform tokens to one or more roles of the supply chain,
(3) interrogating the knowledge graph with the one or more roles, the knowledge graph responding by identifying a set of entities in the knowledge graph corresponding to the one or more roles,
(4) formulating a message from the new event,
filtering the set of the entities according to the access control list based upon a type of the message, and
(5) publishing the formulated message to each entity in the identified set as filtered so that the message is routed to the entities permitted to view the message according to the message type, not based upon a subscription to the event, but by the content of the event.
2. A supply chain data processing system configured for message routing, the system comprising:
a host computing system comprising one or more computers each with memory and at least one processor;
a supply chain information sharing application executing in the host computing system and registering a multiplicity of different actors in a supply chain, generating a knowledge graph in memory comprising different entities representative of corresponding ones of the actors of the supply chain joined by edges representative of relationships between respectively joined ones of the entities, the knowledge graph additionally indicating a role for each of the actors, and storing in the memory, both an access control list defining which ones of the different entities of the generated knowledge graph are permitted to view which types of messages according to particular content of the messages, and also an index of tokens mapping each of the tokens to one or more of synonymous keywords reflective of supply chain terminology; and,
a message router coupled to the supply chain information sharing application, the router comprising program instructions that during execution in the memory of the host computing system, perform:
monitoring an event log of events published thereto by the different actors of the knowledge graph; and,
responding to a new event posted to the event log by:
(1) extracting content from the event, the content comprising one or more keywords pertaining to the supply chain,
(2) generating uniform tokens from the keywords by locating in the index in the memory, the uniform tokens mapped to the extracted keywords, and then mapping the uniform tokens to one or more roles of the supply chain,
(3) interrogating the knowledge graph with the one or more roles, the knowledge graph responding by identifying a set of entities in the knowledge graph corresponding to the one or more roles,
(4) formulating a message from the new event,
(5) filtering the set of the entities according to the access control list based upon a type of the message, and
(6) publishing the formulated message to each entity in the identified set as filtered so that the message is routed to the entities permitted to view the message according to the message type, not based upon a subscription to the event, but by the content of the event.
3. A computer program product for supply chain message routing, the computer program product including a computer readable storage medium having program instructions embodied therewith, the program instructions executable by a device to cause the device to perform a method including:
registering in a supply chain information sharing data processing system, a multiplicity of different actors in a supply chain;
generating a knowledge graph in memory of the system comprising different entities representative of corresponding ones of the actors of the supply chain joined by edges representative of relationships between respectively joined ones of the entities, the knowledge graph additionally indicating a role for each of the actors;
storing in the memory, both an access control list defining which ones of the different entities of the generated knowledge graph are permitted to view which types of messages according to particular content of the messages, and also an index of tokens mapping each of the tokens to one or more of synonymous keywords reflective of supply chain terminology;
monitoring an event log of events published thereto by the different actors of the knowledge graph; and,
responding to a new event posted to the event log by:
(1) extracting content from the event, the content comprising one or more keywords pertaining to the supply chain,
(2) generating uniform tokens from the keywords by locating in the index in the memory, the uniform tokens mapped to the extracted keywords, and then mapping the uniform tokens to one or more roles of the supply chain,
(3) interrogating the knowledge graph with the one or more roles, the knowledge graph responding by identifying a set of entities in the knowledge graph corresponding to the one or more roles,
(4) formulating a message from the new event,
(5) filtering the set of the entities according to the access control list based upon a type of the message, and
(6) publishing the formulated message to each entity in the identified set as filtered so that the message is routed to the entities permitted to view the message according to the message type, not based upon a subscription to the event, but by the content of the event.