Addressable dispatchers in distributed computing

• US 10,019,296 B2
• Filed: 05/31/2007
• Issued: 07/10/2018
• Est. Priority Date: 05/31/2007
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Little, Mark Cameron
• Primary Examiner(s): Nawaz, Asad
• Assistant Examiner(s): HARLEY, JASON A
• Application Number:
  US11/809,896
• Publication Number:
  US 20080299947A1
• Time in Patent Office: 4,058 Days
• Field of Search: 706206
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46

Abstract

A method and apparatus for dispatching messages in a distributed computing system. A dispatcher receives a message. The dispatcher examines the message to determine whether the message is addressed to the dispatcher. If the message is addressed to the dispatcher, the dispatcher performs an action based on the message. If the message is not addressed to the dispatcher, the dispatcher passes on the message to a destination.

Claims

1. A method comprising:

receiving a message, wherein the message originated from a client or a service;

examining, by a processing device, the message to determine whether the message was addressed to a dispatcher by the client or the service from which the message originated and whether the message comprises an action to add or subtract a filter at the dispatcher, wherein when the message is addressed to the dispatcher, the dispatcher is a designated endpoint for the message at which the message will terminate;

in response to determining that the message comprises the action to add or subtract the filter and is addressed to the dispatcher, performing the action to add or subtract the filter at the dispatcher in view of the message, wherein the action causes the dispatcher to generate and send a response message to the client or the service from which the message originated, wherein the response message identifies a number of messages that the dispatcher has transmitted and an amount of time since the dispatcher was last reset; and

in response to determining that the message is not addressed to the dispatcher, appending data associated with encrypting the message to the message before passing on the message to another dispatcher that is the designated endpoint for the message, wherein the client or the service is in a service oriented architecture (SOA), and wherein the SOA comprises an enterprise service bus (ESB) having services that are managed using an infrastructure, and wherein the dispatcher is managed using the same infrastructure.

2. The method of claim 1, wherein the dispatcher is a service in the ESB.

3. The method of claim 1, wherein the response message further identifies a number of messages that the dispatcher has received.

4. The method of claim 1, wherein the performing the action at the dispatcher in view of the message is further in view of a timestamp of the message.

5. A non-transitory machine-accessible storage medium comprising instructions that, when executed by a processing device, cause the processing device to:

receive a message, wherein the message originated from a client or a service;

examine the message to determine whether the message was addressed to a dispatcher by the client or the service from which the message originated and whether the message comprises an action to add or subtract a filter at the dispatcher, wherein when the message is addressed to the dispatcher, the dispatcher is a designated endpoint for the message at which the message will terminate;

in response to determining that the message comprises the action to add or subtract the filter and is addressed to the dispatcher, perform, by the processing device, the action to add or subtract the filter at the dispatcher in view of the message, wherein the action causes the dispatcher to generate and send a response message to the client or the service from which the message originated, wherein the response message identifies a number of messages that the dispatcher has transmitted and an amount of time since the dispatcher was last reset; and

in response to determining that the message is not addressed to the dispatcher, append data associated with encrypting the message to the message before passing on the message to another dispatcher that is the designated endpoint for the message, wherein the client or the service is in a service oriented architecture (SOA), and wherein the SOA comprises an enterprise service bus (ESB) having services that are managed using an infrastructure, and wherein the dispatcher is managed using the same infrastructure.

6. The non-transitory machine-accessible storage medium of claim 5, wherein the dispatcher is a service in the ESB.

7. A system comprising:

a memory; and

a processing device, operatively coupled with the memory, to;

receive, at a dispatcher, a message that has originated from a client or a service;

examine the message to determine whether the message was addressed to the dispatcher by the client or the service from which the message originated and whether the message comprises an action to add or subtract a filter at the dispatcher, wherein when the message is addressed to the dispatcher, the dispatcher is a designated endpoint for the message at which the message will terminate;

perform the action in view of the message in response to determining that the message comprises the action to add or subtract the filter and is addressed to the dispatcher, wherein the action causes the dispatcher to generate and send a response message to the client or the service from which the message originated, wherein the response message identifies a number of messages that the dispatcher has transmitted and an amount of time since the dispatcher was last reset; and

append data associated with encrypting the message to the message before passing on the message to another dispatcher that is the designated endpoint for the message in a network in response to determining that the message is not addressed to the dispatcher, wherein the system comprises an enterprise service bus (ESB), the ESB having services that are managed using an infrastructure, and wherein the dispatcher is managed using the same infrastructure.

8. The system of claim 7, further comprising an additional processing device to:

receive the message at an additional dispatcher;

examine the message to determine whether the message is addressed to the additional dispatcher;

perform an action in view of the message in response to determining that the message is addressed to the additional dispatcher; and

perform a reciprocal operation to modify the message before passing the message on to the network or to at least one of the client and the service in response to determining that the message is not addressed to the dispatcher, wherein the reciprocal operation reverses a message modification achieved by the operation.

9. The system of claim 7, wherein the dispatcher is a service in the ESB.