Selection of communication strategies for message brokers or publish/subscribe communications
First Claim
1. A message brokering system for providing a publish/subscribe service for publisher and subscriber application programs, comprising:
- means for receiving published messages from one or more publisher application programs;
means for forwarding received messages to connected message brokering systems;
means, responsive to a communication characteristic of an inter-broker communication link between the message brokering system and one of said connected message brokering systems, for selecting a message filtering policy which is appropriate for the communication characteristic; and
means for controlling the forwarding of messages via the inter-broker communication link using the selected message filtering policy.
1 Assignment
0 Petitions
Accused Products
Abstract
Provided are methods, data processing systems and computer programs enabling selection of an appropriate message filtering policy for inter-broker communications within a message broker network. The policy determines whether a broker should forward messages to all its neighbour brokers (‘broadcast’) or should filter messages based on subscription information for connected brokers and, if filtering, what filtering rules to implement and when. Filtering rules may differentiate between different groups of message topics. The filtering policy selected may differ for different links within a single broker or multi-broker network and, additionally or alternatively, the communication strategy for the network or for specific links within the network may be changed according to current network use characteristics.
231 Citations
16 Claims
-
1. A message brokering system for providing a publish/subscribe service for publisher and subscriber application programs, comprising:
-
means for receiving published messages from one or more publisher application programs;
means for forwarding received messages to connected message brokering systems;
means, responsive to a communication characteristic of an inter-broker communication link between the message brokering system and one of said connected message brokering systems, for selecting a message filtering policy which is appropriate for the communication characteristic; and
means for controlling the forwarding of messages via the inter-broker communication link using the selected message filtering policy. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A data processing system comprising:
-
at least a first and a second message broker, connected via one or more inter-broker communication links and configured to provide a publish/subscribe service for publisher and subscriber application programs;
means, responsive to a communication characteristic of a communication link between the first and second message brokers, for selecting a message filtering policy which is appropriate for the communication characteristic; and
means for controlling the transmission of messages via the inter-broker communication link using the selected message filtering policy. - View Dependent Claims (12, 13)
-
-
14. A computer program product for providing a publish/subscribe brokering service for publisher and subscriber application programs, comprising program code recorded on a machine-readable recording medium, the program code comprising:
-
means for receiving published messages from one or more publisher application programs;
means for forwarding received messages to connected message brokering systems;
means, responsive to a communication characteristic of an inter-broker communication link between the message brokering system and one of said connected message brokering systems, for selecting a message filtering policy which is appropriate for the communication characteristic; and
means for controlling the forwarding of messages via the inter-broker communication link using the selected message filtering policy.
-
-
15. A method of communication in a publish/subscribe environment in which publisher application programs send messages to subscriber application programs via message brokers. The brokers are able to send messages to each other using a number of different communication protocols and to apply different filtering policies. The method comprises:
-
storing a definition of a message filtering policy for inter-broker communications for each of said communication protocols, the filtering policy either specifying no filtering or specifying a filtering rule;
responsive to receipt of a published message at a first message broker, referring to characteristics of the received message to determine an appropriate inter-broker communication protocol;
selecting the determined protocol and, if the selected protocol'"'"'s stored message filtering policy requires application of a filtering rule, applying the filtering rule to the message; and
transmitting the message to a second broker using the selected communication protocol only if transmission is consistent with the filtering rule.
-
-
16. A method of configuring a message brokering system for efficient inter-broker communications in a multi-broker publish/subscribe environment in which publishers publish messages via message brokers and subscribers register with message brokers to receive published messages, the method comprising:
-
responsive to a communication characteristic for a communication link between the message brokering system and another message brokering system, selecting a message filtering policy according to the determined communication characteristic; and
controlling the transmission of messages via the communication link using the selected message filtering policy.
-
Specification