Peer-to-peer collaboration of publishers in a publish-subscription environment
First Claim
1. A method for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:
- establishing P2P communication between a set of publisher systems in the pub/sub messaging environment;
identifying a set of data that is common to the set of publisher systems having a potential to be cached;
generating a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable;
sharing the unique identifier among the set of publisher systems;
associating the set of data with the unique identifier;
sending a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment;
receiving the first message on the broker system;
locating the unique identifier;
causing the set of data to be stored in a cache;
sending the first message to a set of subscriber systems in the pub/sub messaging environment;
receiving a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data;
locating the unique identifier in the abbreviated message;
retrieving the set of data from the cache;
replacing the unique identifier with the set of data in the second message to yield a completed message; and
sending the completed message to the set of subscriber systems.
2 Assignments
0 Petitions
Accused Products
Abstract
Embodiments of the present invention provide an approach for an enhanced pub/sub environment whereby a peer group of publishers is defined and can collaborate to determine when to cache data being sent to a common broker or brokers. Specifically, in a typical embodiment, configuration data or the like will be read to define a peer group among the publisher systems in the pub/sub messaging environment. Once such a group has been identified, communication therebetween will be established. Once cacheable data has been identified, a unique identifier/set of cache keys will be generated corresponding thereto and associated with the set of data. A message comprising the set of data and corresponding unique identifier will then be sent to a broker system (e.g., from the publisher system(s)), which will store (or have stored) the set of data in a cache, and pass the underlying message along to applicable subscriber system(s).
-
Citations
17 Claims
-
1. A method for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:
-
establishing P2P communication between a set of publisher systems in the pub/sub messaging environment; identifying a set of data that is common to the set of publisher systems having a potential to be cached; generating a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable; sharing the unique identifier among the set of publisher systems; associating the set of data with the unique identifier; sending a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment; receiving the first message on the broker system; locating the unique identifier; causing the set of data to be stored in a cache; sending the first message to a set of subscriber systems in the pub/sub messaging environment; receiving a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data; locating the unique identifier in the abbreviated message; retrieving the set of data from the cache; replacing the unique identifier with the set of data in the second message to yield a completed message; and sending the completed message to the set of subscriber systems. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A system for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:
-
at least one bus; at least one processor coupled to the at least one bus; and at least one memory medium coupled to the at least one bus, the at least one memory medium comprising instructions to; establish P2P communication between a set of publisher systems in the pub/sub messaging environment; identify a set of data that is common to the set of publisher systems having a potential to be cached; generate a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable; share the unique identifier among the set of publisher systems; associate the set of data with the unique identifier; send a first message having the set of data and the unique identifier to a broker system in the messaging pub/sub environment; receive the first message on the broker system; locate the unique identifier; cause the set of data to be stored in a cache; send the first message to a set of subscriber systems in the messaging pub/sub environment; receive a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data; locate the unique identifier in the abbreviated message; retrieve the set of data from the cache; replace the unique identifier with the set of data in the second message to yield a completed message; and send the completed message to the set of subscriber systems. - View Dependent Claims (8, 9, 10, 11)
-
-
12. At least one computer program product for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, the at least one computer program product comprising at least one non-transitory computer readable storage media, and program instructions stored on the at least one non-transitory computer readable storage media, to:
-
establish P2P communication between a set of publisher systems in the pub/sub messaging environment; identify a set of data that is common to the set of publisher systems having a potential to be cached; generate a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable; share the unique identifier among the set of publisher systems; associate the set of data with the unique identifier; send a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment; receive the first message on the broker system; locate the unique identifier; cause the set of data to be stored in a cache; send the first message to a set of subscriber systems in the pub/sub messaging environment; receive a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data; locate the unique identifier in the abbreviated message; retrieve the set of data from the cache; replace the unique identifier with the set of data in the second message to yield a completed message; and send the completed message to the set of subscriber systems. - View Dependent Claims (13, 14, 15, 16)
-
-
17. A method for deploying a system for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:
providing a computer infrastructure being operable to; establish P2P communication between a set of publisher systems in the pub/sub messaging environment; identify a set of data that is common to the set of publisher systems having a potential to be cached; generate a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable; share the unique identifier among the set of publisher systems; associate the set of data with the unique identifier; send a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment; receive the first message on the broker system; locate the unique identifier; cause the set of data to be stored in a cache; send the first message to a set of subscriber systems in the pub/sub messaging environment; receive a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data; locate the unique identifier in the abbreviated message; retrieve the set of data from the cache; replace the unique identifier with the set of data in the second message to yield a completed message; and send the completed message to the set of subscriber systems.
Specification