Topic-based data routing in a publish-subscribe messaging environment

A computer-implemented method to route data in a publish-subscribe messaging environment, comprising:

• receiving, by a message broker, topic metadata at a first instance according to a first interval into a predefined fixed topic, wherein the topic metadata comprise information about a list of topics published by an agent running in an endpoint and each topic in the list of topics corresponds to an application running in the endpoint;
• obtaining, by a topic list subscriber, the list of topics from the message broker by subscribing to the predefined fixed topic;
• assigning, by a subscription manager, topics in the list of topics to a first subscriber and a second subscriber according to a criteria;
• receiving, by the message broker, data associated with the applications from the agent according to a second interval;
• and
• routing, by the message broker, the received data corresponding to the topics to the first and second subscribers in accordance with the topics assigned to the first and second subscribers, wherein at least one topic assigned to the first subscriber is different from the topics assigned to the second subscriber.

A non-transitory computer readable storage medium having instructions that when executed by a processor, cause the processor to:

• receive, by a message broker, a plurality of topic metadata at a first instance according to a first interval from a plurality of agents running in a plurality of endpoints, wherein each topic metadata comprise information about a list of topics published by an agent running in an endpoint and each topic in the list of topics corresponds to an application running in the endpoint;
• store the plurality of topic metadata to a predefined fixed topic in the message broker;
• obtain a plurality of list of topics as published by the plurality of agents via subscribing to the predefined fixed topic;
• assign topics in the plurality of list of topics to a first subscriber and a second subscriber according to a criteria;
• receive data associated with a plurality of applications from the plurality of agents according to a second interval;
• and
• route the received data corresponding to the topics to the first and second subscribers based on the assigned topics, wherein at least one topic assigned to the first subscriber is different from the topics assigned to the second subscriber.