Message handling multiplexer

• US 8,611,378 B2
• Filed: 05/29/2007
• Issued: 12/17/2013
• Est. Priority Date: 05/29/2007
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Ban, Bela, Blagojevic, Vladimir
• Primary Examiner(s): Banks Harold, Marsha D
• Assistant Examiner(s): WYLLIE, CHRISTOPHER T
• Application Number:
  US11/807,624
• Publication Number:
  US 20080298363A1
• Time in Patent Office: 2,394 Days
• Field of Search: 370/230, 370/392, 370/400, 370/401, 370/465, 709/203, 709/212, 709/223, 709/226, 709/219
• US Class Current: 370/535
• CPC Class Codes: H04L 12/1881 with schedule organisation, e.g. priority, sequence management
• CPC Class Codes: H04L 49/90 Buffering arrangements

Abstract

A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A multiplexer receives messages from different servers. A service name is coupled to each message with the corresponding destination service. A single shared channel is formed. The messages are processed over the single shared channel.

Claims

1. An apparatus for processing messages comprising:

a memory; and

a processor operable to execute a group communication architecture from the memory, the group communication architecture including;

an application programming interface for receiving and sending messages;

a building block layer coupled to the application programming interface;

a multiplexer coupled to the building block, wherein the multiplexer is to maintain a set of queues, one queue per service name, and to maintain a thread pool, wherein the thread pool is coupled to receive the messages from the set of queues;

a channel layer coupled to the multiplexer; and

a transport protocol stack coupled to the channel layer for implementing properties specified by the channel layer,

wherein the multiplexer is to receive messages from a plurality of servers, to couple a service name to each message with a corresponding destination service, to add a message to a corresponding queue based on its service name, to form a single shared channel, and to process the messages from the set of queues with the thread pool over the single shared channel, and

wherein the transport protocol stack comprises a concurrent stack consisting of an out of band thread pool and a regular thread pool, the regular thread pool to form one thread for every messages from a sender, and the out of band thread pool to form one thread for messages marked as out of band from the sender, wherein messages processed with the thread from the out of band thread pool are processed before messages processed with the regular thread pool.

2. The apparatus of claim 1 wherein the multiplexer is to further multiplex the messages onto the single shared channel, and to send the messages over the single shared channel.

3. The apparatus of claim 1 wherein the multiplexer is to further determine the service name for each message from the single shared channel, and to channel each message to the corresponding destination service based on the service name of each message.

4. The apparatus of claim 1 wherein the multiplexer is to further form the thread pool to concurrently dispatch messages to different services from a same server.

5. The apparatus of claim 4 wherein the multiplexer is to further process one thread for messages to a same service from the same server.