System and method for tracking notifications in a publish subscribe system
IPC분류정보
국가/구분
United States(US) Patent
등록
국제특허분류(IPC7판)
G06F-017/30
출원번호
US-0943567
(2007-11-20)
등록번호
US-8165992
(2012-04-24)
발명자
/ 주소
Rooney, Sean G.
출원인 / 주소
International Business Machines Corporation
대리인 / 주소
Whitham, Curtis, Christofferson & Cook, P.C.
인용정보
피인용 횟수 :
2인용 특허 :
54
초록▼
A system and method are provided for tracking notification messages from a message publisher to a message subscriber. The system includes a plurality of entities that are operatively coupled to one another via an electronic network, and each entity includes at least one processor configured as a mes
A system and method are provided for tracking notification messages from a message publisher to a message subscriber. The system includes a plurality of entities that are operatively coupled to one another via an electronic network, and each entity includes at least one processor configured as a message publisher, a channel and/or a message subscriber. According to the invention, at least one entity is configured as a channel, which is assigned to the function of acting as a meta-channel and comprises (i) means for receiving one or more channel descriptions; and (ii) means for publishing a digest of one or more channel descriptions and/or message transformations to facilitate tracking of message transformations from raw forms to processed forms. The system may have more than one meta-channel, and the meta-channels may subscribe to or publish to each other.
대표청구항▼
1. A method for tracking notification messages from a message publisher to a message subscriber, in a publish/subscribe system having one or more entities each configured as one or more of a message publisher, a channel and a message subscriber, the method comprising: subscribing to a meta-channel,
1. A method for tracking notification messages from a message publisher to a message subscriber, in a publish/subscribe system having one or more entities each configured as one or more of a message publisher, a channel and a message subscriber, the method comprising: subscribing to a meta-channel, said meta-channel receiving descriptions of one or more associated channels, each said channel description indicating how notifications are presented by a publisher, or aggregated or transformed by a publisher so as to supercede notifications received by the publisher acting as a subscriber and thereby reduce a load upon the system, so that a subscriber to a channel having aggregated or transformed notifications receives the aggregation or transformation rather than the superceded notifications, the aggregation or transformation then becoming incorporated into subsequent notifications when the subscriber is configured as a publisher after having further aggregated or transformed what has been received from the channel;receiving a digest of said channel descriptions from said meta-channel, said digest indicating how notifications are superceded thereby enabling a subscriber or a publisher, respectively, to discriminate between channels and to switch to channels providing superceding notifications based on said discrimination, wherein said switching of channels based on said discrimination serves to automatically reconfigure said publish/subscribe system in response to overloading or failure of one or more channels in said system;receiving a digest of one or more transformation description messages from said meta-channel, said digest enabling a subscriber to track evolution of message transformations from raw forms to processed forms and to switch publishers based on said tracking, the evolution progressing from superceded to superceding notifications; andusing said transformation description messages to track said evolution of message transformations in order to determine where to subscribe. 2. The method of claim 1, further comprising: subscribing to a first channel in response to the tracking of message transformations; and dropping a subscription to a second channel in response to determining that the first channel publishes one or more notifications in a more processed form than a notification from the second channel. 3. The method of claim 1, wherein the message transformations in processed form comprise aggregations of messages in raw form. 4. The method of claim 1, wherein the message transformations in processed form comprise transformations of messages in raw form. 5. The method of claim 1, further comprising publishing aggregated notifications. 6. The method of claim 1, further comprising publishing transformed notifications. 7. The method of claim 1, wherein the message transformations are formatted in accordance with XML specifications. 8. The method of claim 1, wherein the digest of said channel descriptions describes one or more of a channel and the meta-channel. 9. The method of claim 1, wherein each of the one or more channel descriptions comprises one or more of: the publish/subscribe system's type; information needed to connect to a channel associated with the channel description; one or more message types that is accepted by the channel associated with the channel description; and one or more message types that is currently being published or subscribed to by the channel associated with the channel description. 10. The method of claim 1, wherein each of the one or more channel descriptions comprises load information pertaining to the channel associated with the channel description. 11. The method of claim 10, further comprising: in response to the load information, discriminating between first and second channels offering similar functionality. 12. The method of claim 11, further comprising: subscribing to the first channel in response to determining that the second channel is overloaded. 13. The method of claim 11, further comprising: publishing to the first channel in response to determining that the second channel is overloaded. 14. The method of claim 1, wherein each of the one or more channel descriptions comprises information pertaining to a refresh period between a publication of a first channel description and a publication of a second channel description. 15. The method of claim 14, further comprising: in response to the information pertaining to the refresh period, and in response to nonreception of a second channel description after a time period proportional to the refresh period, determining that a channel has stopped publishing notifications. 16. The method of claim 15, further comprising adjusting a refresh period for a channel in response to information pertaining to a refresh period for the meta-channel. 17. The method of claim 1, wherein the transformation description message pertaining to an entity comprises one or more of: information identifying a set of channels and message types for messages that the entity is reading; information identifying a set of channels and message types for messages that the entity is writing; and a refresh period.
연구과제 타임라인
LOADING...
LOADING...
LOADING...
LOADING...
LOADING...
이 특허에 인용된 특허 (54)
Saulpaugh, Thomas E.; Slaughter, Gregory L.; Pouyoul, Eric, Addressing message gates in a distributed computing environment.
Young Jun Chong KR; Jae Young Kim KR; Sung Choon Kang KR; Jae Ick Choi KR; Jae Hong Park KR, Apparatus and method for automatic selection of broadband frequency channel using double frequency conversion.
Gelvin, David C.; Girod, Lewis D.; Kaiser, William J.; Merrill, William M.; Newberg, Fredric; Pottie, Gregory J.; Sipos, Anton I.; Vardhan, Sandeep, Apparatus for internetworked hybrid wireless integrated network sensors (WINS).
Thubert,Pascal; Wetterwald,Patrick; Molteni,Marco; Forster,David Charlton, Arrangement for router attachments between roaming mobile routers in a clustered network.
Gandhi,Amar S.; Layman,Andrew J.; Weisman,Daniel R.; Pather,Shyamalan; Zintel,William Michael, Data driven remote device control model with general programming interface-to-network messaging adapter.
Slaughter, Gregory L.; Saulpaugh, Thomas E.; Traversat, Bernard A.; Abdelaziz, Mohamed M.; Duigou, Michael J., Mechanism and apparatus for using messages to look up documents stored in spaces in a distributed computing environment.
Gelvin, David C.; Girod, Lewis D.; Kaiser, William J.; Merrill, William M.; Newberg, Fredric; Pottie, Gregory J.; Sipos, Anton I.; Vardhan, Sandeep, Method and apparatus for distributed signal processing among internetworked wireless integrated network sensors (WINS).
Gelvin, David C.; Girod, Lewis D.; Kaiser, William J.; Merrill, William M.; Newberg, Fredric; Pottie, Gregory J.; Sipos, Anton I.; Vardhan, Sandeep, Method and apparatus for internetworked wireless integrated network sensor (WINS) nodes.
Duigou,Michael J.; Abdelaziz,Mohamed M.; Traversat,Bernard A.; Saulpaugh,Thomas E.; Slaughter,Gregory L., Method and apparatus for proximity discovery of services.
Brandenberg, Carl Brock; Kay, Robert L.; Maxwell, Kenneth J.; Cotter, R. Brandon, Method and apparatus for scheduling presentation of digital content on a personal communication device.
Gelvin, David C.; Girod, Lewis D.; Kaiser, William J.; Merrill, William M.; Newberg, Fredric; Pottie, Gregory J.; Sipos, Anton I.; Vardhan, Sandeep, Method for collecting data using compact internetworked wireless integrated network sensors (WINS).
Shamoon,Talal G.; Hill,Ralph D.; Radcliffe,Chris D.; Hwa,John P.; Sibert,W. Olin; Van Wie,David M., Methods and apparatus for persistent control and protection of content.
Chandra,Mala; Evans,Steven R.; Kruempelstaedter,John; Khalsa,Kirpal; McFarland,Joshua, Methods and apparatus providing electronic messages that are linked and aggregated.
Palliyil, Sudarshan; Venkateshamurthy, Shivakumara; Vijayaraghavan, Srinivas Belur; Aswathanarayana, Tejasvi, Methods, apparatus and computer programs for enhanced access to resources within a network.
Dwork,Cynthia; Naor,Simeon; Ravikumar,Shanmugasundaram; Sivakumar,Dandapani, System and method for aggregating ranking results from various sources to improve the results of web searching.
Donner,Irah H.; Donner,Zachary J.; Donner,Jason J., System and method for reallocating and/or upgrading and/or selling tickets, other even admittance means, goods and/or services.
Agarwal, Kanak B.; Bohrer, Patrick J.; Gheith, Ahmed; Kistler, Michael D.; Rajamony, Ramakrishnan, Client-side fault tolerance in a publish-subscribe system.
※ AI-Helper는 부적절한 답변을 할 수 있습니다.