Method and system for mediating published message streams for selective distribution

• US 20070198641A1
• Filed: 02/21/2006
• Published: 08/23/2007
• Est. Priority Date: 02/21/2006
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Dorai, Chitra, Strom, Robert, Stern, Edith
• Granted Patent: US 7,529,794 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 67/306 User profiles
• CPC Class Codes: H04L 67/55 Push-based network services
• CPC Class Codes: H04L 67/56 Provisioning of proxy services store-and-forward switching systems in data switching networks H04L12/54
• CPC Class Codes: H04L 67/564 Enhancement of application control based on intercepted application data

Abstract

A computer implemented method, system and computer program product for delivering published messages to at least one subscriber in a publish-subscribe messaging system. A computer implemented method for delivering published messages to a subscriber includes receiving a plurality of message streams, and analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality. At least one message that satisfies the criteria is delivered to the subscriber.

Claims

1. A computer implemented method for delivering published messages to a subscriber, comprising:

receiving a plurality of message streams;

analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality; and

delivering at least one message that satisfies the criteria to the subscriber.

2. The computer implemented method according to claim 1, wherein analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality, comprises:

analyzing at least one comparable message from each of the plurality of message streams in accordance with the criteria.

3. The computer implemented method according to claim 2, wherein analyzing at least one comparable message from each of the plurality of message streams in accordance with the criteria, comprises:

ranking messages from each of the plurality of message streams that satisfy the criteria, and wherein delivering at least one message that satisfies the criteria to the subscriber, comprises;

delivering a subset of the ranked messages that most satisfies the subscriber criteria to the subscriber.

4. The computer implemented method according to claim 3, and further comprising:

selecting the number of ranked messages comprising the subset.

5. The computer implemented method according to claim 1, wherein analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality, comprises:

analyzing messages from each of the plurality of message streams that are in a neighborhood of an analyzed message; and

wherein delivering at least one message that satisfies the criteria to the subscriber, comprises;

delivering at least one message that is in a neighborhood of an analyzed message and that satisfies the criteria to the subscriber.

6. The computer implemented method according to claim 1, wherein delivering at least one message that satisfies the criteria to the subscriber, comprises:

delivering all messages from all message streams containing said at least one message that satisfies the criteria to the subscriber for a predetermined time period.

7. The computer implemented method according to claim 1, and further comprising:

repeating the receiving, analyzing and delivering steps for each of a plurality of consecutive predetermined time periods.

8. The computer implemented method according to claim 1, wherein analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality, comprises:

analyzing at least one message from each of the plurality of message streams in accordance with criteria established by a plurality of subscribers, wherein each of the plurality of subscribers specify a message content and a message content quality; and

wherein delivering at least one message that satisfies the criteria to the subscriber, comprises;

delivering at least one message that satisfies the criteria of each of the plurality of subscribers to each subscriber.

9. The computer implemented method according to claim 1, wherein the message content quality criteria comprises:

at least one of brightness, focus, noisiness, image clarity, image resolution, sound clarity and measurement precision.

10. A computer program product, comprising:

a computer usable medium having computer usable program code for delivering published messages to a subscriber, the computer program product comprising;

computer usable program code configured for receiving a plurality of message streams;

computer usable program code configured for analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality; and

computer usable program code configured for delivering at least one message that satisfies the criteria to the subscriber.

11. The computer program product according to claim 10, wherein the computer usable program code configured for analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality, comprises:

computer usable program code configured for ranking messages from each of the plurality of message streams that satisfy the criteria, and wherein the computer usable program code configured for delivering at least one message that satisfies the criteria to the subscriber, comprises;

computer usable program code configured for delivering a subset of the ranked messages that most satisfies the subscriber criteria to the subscriber.

12. The computer program product according to claim 11, and further comprising:

computer usable program code configured for selecting the number of ranked messages comprising the subset.

13. The computer program product according to claim 10, wherein the computer usable program code configured for analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality, comprises:

computer usable program code configured for analyzing messages from each of the plurality of message streams that are in a neighborhood of an analyzed message, and wherein the computer usable program code configured for delivering at least one of the at least one ordered message to each at least one subscriber, comprises;

computer usable program code configured for delivering at least one message that is in a neighborhood of an analyzed message and that satisfies the criteria to the subscriber.

14. The computer program product according to claim 10, wherein the computer usable program code configured for delivering at least one message that satisfies the criteria to the subscriber, comprises:

computer usable program code configured for delivering at least one message that satisfies the criteria to the subscriber for a predetermined time period.

15. The computer program product according to claim 10, and further comprising:

computer usable program code configured for repeating the receiving, analyzing and delivering steps for each of a plurality of consecutive predetermined time periods

16. The computer program product according to claim 10, wherein the computer usable program code configured for analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying message content and message content quality, comprises:

computer usable program code configured for analyzing at least one message from each of the plurality of message streams in accordance with criteria established by a plurality of subscribers, wherein each of the plurality of subscribers specify a message content and a message content quality, and wherein the computer usable program code configured for delivering at least one message that satisfies the criteria to the subscriber, comprises;

computer usable program code configured for delivering at least one message that satisfies the criteria of each of the plurality of subscribers to each subscriber.

17. A publish-subscribe messaging system for delivering published messages to at least one subscriber, comprising:

at least one message broker for receiving a plurality of message streams;

an analyzer for analyzing at least one message from each of the plurality of message streams in accordance with criteria established by the subscriber specifying a message content and a message content quality; and

;

a mechanism for delivering at least one message that satisfies the criteria from the message broker to the subscriber.

18. The publish-subscribe messaging system according to claim 17, wherein the analyzer comprises a mechanism for ranking messages from each of the plurality of message streams that satisfy the criteria, and wherein the delivering mechanism comprises a mechanism for delivering a subset of the ranked messages that most satisfies the subscriber criteria to the subscriber.

19. The publish-subscribe messaging system according to claim 18, wherein the delivering mechanism comprises a mechanism for delivering at least one message that satisfies the criteria to the subscriber for a plurality of consecutive predetermined time periods.

20. A computer implemented method for delivering published messages to at least one subscriber, comprising:

receiving criteria for each at least one subscriber specifying a message content and a message content quality;

receiving a plurality of message streams; and

delivering at least one message from at least one of the plurality of received message streams that satisfies the criteria for each at least one subscriber to each at least one subscriber.