MESSAGE HANDLING MULTIPLEXER

• US 20140105220A1
• Filed: 12/17/2013
• Published: 04/17/2014
• 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
• Granted Patent: US 9,548,949 B2
• Time in Patent Office: Days
• US Class Current: 370/413
• 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. A method comprising:

receiving messages from a plurality of servers by a multiplexer executing on a processing device, wherein the multiplexer comprises an application programming interface, a building block layer, a channel layer, and a concurrent transport protocol stack;

coupling, by the multiplexer, a service name to each message with a corresponding destination service;

maintaining, by the multiplexer, a set of queues, one queue per service name;

adding, by the multiplexer, a message to a corresponding queue based on its service name, to form a single shared channel;

maintaining, by the multiplexer, an out-of-band thread pool and a regular thread pool of the concurrent transport protocol stack, wherein the out-of-band thread pool and the regular thread pool are coupled to receive the messages from the set of queues;

dispatching the messages marked as out-of-band from a sender to a thread of the out-of-bound thread pool; and

dispatching all other messages from the sender to a thread of the regular thread pool.

2. The method of claim 1 further comprising:

multiplexing the messages onto the single shared channel; and

sending the messages over the single shared channel.

3. The method of claim 1 further comprising:

determining the service name for each message from the single shared channel; and

channeling each message to the corresponding destination service based on the service name of each message.

4. The method of claim 1 further comprising concurrently dispatching messages to different services from a same server using the concurrent transport protocol stack.

5. The method of claim 4 further comprising processing one thread of the concurrent stack for messages to a same service from the same server.

6. The method of claim 1 wherein receiving messages comprise packets with concurrent transport protocol stack, wherein the concurrent transport protocol stack comprises at least one of a multicast receiver thread, a unicast receiver thread, or a connection table.

7. The method of claim 1 further comprising sending the messages up the concurrent transport protocol stack to a corresponding channel of the channel layer, the building block layered on top of the channel layer, and the application programming interface layered on top of the building block.

8. A machine-accessible storage medium including data that, when accessed by a machine, cause the machine to perform operations comprising:

receiving messages from a plurality of servers by a multiplexer executing on a processing device, wherein the multiplexer comprises an application programming interface, a building block layer, a channel layer, and a concurrent transport protocol stack;

coupling, by the multiplexer, a service name to each message with a corresponding destination service;

maintaining, by the multiplexer, a set of queues, one queue per service name;

adding, by the multiplexer, a message to a corresponding queue based on its service name, to form a single shared channel;

maintaining, by the multiplexer, an out-of-band thread pool and a regular thread pool of the concurrent transport protocol stack, wherein the out-of-band thread pool and the regular thread pool are coupled to receive the messages from the set of queues;

dispatching the messages marked as out-of-band from a sender to a thread of the out-of-bound thread pool; and

dispatching all other messages from the sender to a thread of the regular thread pool.

9. The machine-accessible storage medium of claim 8 wherein the operations further comprise:

multiplexing the messages onto the single shared channel; and

sending the messages over the single shared channel.

10. The machine-accessible storage medium of claim 8 wherein the operations further comprise:

determining the service name for each message from the single shared channel; and

channeling each message to the corresponding destination service based on the service name of each message.

11. The machine-accessible storage medium of claim 8 wherein the operations further comprise concurrently dispatching messages to different services from a same server using the concurrent transport protocol stack.

12. The machine-accessible storage medium of claim 11 wherein the operations further comprise processing one thread of the concurrent stack for messages to a same service from the same server.

13. The machine-accessible storage medium of claim 8 wherein receiving messages comprise packets with concurrent transport protocol stack, wherein the concurrent transport protocol stack comprises at least one of a multicast receiver thread, a unicast receiver thread, or a connection table.

14. The machine-accessible storage medium of claim 8 wherein the operations further comprise sending the messages up the concurrent transport protocol stack to a corresponding channel of the channel layer, the building block layered on top of the channel layer, and the application programming interface layered on top of the building block.

15. A method comprising:

maintaining, by a multiplexer executing on a processing device, a set of queues, one queue per service name;

maintaining, by the multiplexer, a thread pool, wherein the thread pool is coupled to receive the messages from the set of queues, wherein the thread pool comprises a regular thread pool and an out-of-bound thread pool;

receiving messages from a plurality of servers by the multiplexer;

associating, by the multiplexer, a service name to each message with a corresponding destination service;

adding, by the multiplexer, a message to a corresponding queue based on its service name;

forming a single shared channel by the multiplexer;

processing the messages from the set of queues with the thread pool over the single shared channel, wherein processing the messages comprises;

forming one thread from the regular thread pool for the messages from a sender, and

forming one thread from the out-of-band thread pool for the messages marked as out of band from the sender, wherein the messages processed with the one thread from the out-of-band thread pool are processed before the messages processed with the one thread from the regular thread pool.

16. The method of claim 15 further comprising:

multiplex the messages onto the single shared channel; and

sending the messages over the single shared channel.

17. The method of claim 15 further comprising:

determining by the multiplexer wherein the service name for each message from the single shared channel; and

channeling each message to the corresponding destination service based on the service name of each message.

18. The method of claim 15 further comprising concurrently dispatching, by the thread pool, the messages to different services from a same server.

19. The method of claim 15 wherein the processing the messages further comprises processing one thread for the messages to a same service from the same server.

20. The method of claim 15 wherein receiving messages comprise packets with concurrent transport protocol stack, wherein the concurrent transport protocol stack comprises at least one of a multicast receiver thread, a unicast receiver thread, or a connection table.