Prioritizing producers and consumers of an enterprise messaging system

• US 20050246186A1
• Filed: 04/30/2004
• Published: 11/03/2005
• Est. Priority Date: 04/30/2004
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Nikolov, Radoslav I.
• Granted Patent: US 7,519,669 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: G06Q 10/107 Computer-aided management of electronic mailing [e-mailing]

Abstract

Methods and apparatuses for prioritizing producers and consumers in an enterprise messaging system are described herein. In one embodiment, an exemplary process is provided to receive multiple messages associated with a topic from multiple producers via multiple receiving threads, where the messages associated with the topic are subscribed to by one or more subscribers. The messages are delivered to the subscribers via a delivery thread. The priorities of the receiving threads and the delivery thread are configured such that a receiving rate of messages from the producers is substantially equivalent to a delivery rate of messages delivered to the subscribers. Other methods and apparatuses are also described.

Claims

1. A method for processing messages of an enterprise messaging system, the method comprising:

receiving a plurality of messages associated with a topic from a plurality of producers via a plurality of receiving threads, the messages associated with the topic being subscribed to by one or more subscribers;

delivering the messages to the one or more subscribers via a delivery thread; and

configuring priorities of the receiving threads and the delivery thread such that a receiving rate of messages from the producers is substantially equivalent to a delivery rate of messages delivered to the subscribers.

2. The method of claim 1, further comprising monitoring the receiving threads and the delivery thread to determine an amount of messages received from the producers and an amount of messages delivered to the subscribers, wherein the priorities of the receiving threads and the delivery thread are determined based on the amount of received messages and delivered messages within a predetermined time unit.

3. The method of claim 1, wherein the receiving threads include a first receiving thread having a first receiving rate and a second receiving thread having a second receiving rate, the first receiving rate being faster than the second receiving rate, and wherein the method further comprises configuring priorities of the first and second receiving threads such that an amount of messages received via the first receiving thread is substantially equivalent to an amount of messages received via the second receiving thread within a predetermined time unit.

4. The method of claim 1, further comprising:

determining whether an amount of messages received via the receiving threads is larger than an amount of messages delivered via the delivery thread within a given time unit; and

configuring at least one of the receiving threads to have a lower priority than the priority of the delivery thread if the amount of messages received is larger than the amount of messages delivered within the given time unit.

5. The method of claim 4, further comprising maintaining statistic information regarding receiving messages for each of the receiving threads, wherein the priorities of the at least one receiving thread is determined based in part on the statistic information associated with the respective receiving thread.

6. The method of claim 5, wherein the statistic information including at least one of receiving rate within a given time unit and frequency of having a relatively high receiving rate.

7. The method of claim 1, further comprising:

determining whether an amount of messages received via the receiving threads is larger than an amount of messages delivered via the delivery thread within a given time unit; and

suspending at least one of the receiving threads for a period of time if the amount of messages received is larger than the amount of messages delivered within the given time unit.

8. The method of claim 7, wherein an execution of the at least one receiving thread is suspended once for every predetermined number of executions of the delivery thread.

9. The method of claim 7, further comprising maintaining statistic information regarding receiving messages for each of the receiving threads, wherein the period of time for suspending at least one of the receiving threads is determined based in part on the statistic information associated with the respective receiving thread.

10. The method of claim 9, wherein the statistic information including at least one of receiving rate within a given time unit and frequency of having a relatively high receiving rate.

11. A machine-readable medium when executed by a processor, causes the processor to perform a method for processing messages, the method comprising:

receiving a plurality of messages associated with a topic from a plurality of producers via a plurality of receiving threads, the messages associated with the topic being subscribed to by one or more subscribers;

delivering the messages to the one or more subscribers via a delivery thread; and

configuring priorities of the receiving threads and the delivery thread such that a receiving rate of messages from the producers is substantially equivalent to a delivery rate of messages delivered to the subscribers.

12. The machine-readable medium of claim 11, wherein the method further comprises monitoring the receiving threads and the delivery thread to determine an amount of messages received from the producers and an amount of messages delivered to the subscribers, wherein the priorities of the receiving threads and the delivery thread are determined based on the amount of received messages and delivered messages within a predetermined time unit.

13. The machine-readable medium of claim 11, wherein the receiving threads include a first receiving thread having a first receiving rate and a second receiving thread having a second receiving rate, the first receiving rate being faster than the second receiving rate, and wherein the method further comprises configuring priorities of the first and second receiving threads such that an amount of messages received via the first receiving thread is substantially equivalent to an amount of messages received via the second receiving thread within a predetermined time unit.

14. The machine-readable medium of claim 11, wherein the method further comprises:

determining whether an amount of messages received via the receiving threads is larger than an amount of messages delivered via the delivery thread within a given time unit; and

configuring at least one of the receiving threads to have a lower priority than the priority of the delivery thread if the amount of messages received is larger than the amount of messages delivered within the given time unit.

15. The machine-readable medium of claim 14, wherein the method further comprises maintaining statistic information regarding receiving messages for each of the receiving threads, wherein the priorities of the at least one receiving thread is determined based in part on the statistic information associated with the respective receiving thread.

16. The machine-readable medium of claim 15, wherein the statistic information including at least one of receiving rate within a given time unit and frequency of having a relatively high receiving rate.

17. The machine-readable medium of claim 11, wherein the method further comprises:

determining whether an amount of messages received via the receiving threads is larger than an amount of messages delivered via the delivery thread within a given time unit; and

suspending at least one of the receiving threads for a period of time if the amount of messages received is larger than the amount of messages delivered within the given time unit.

18. The machine-readable medium of claim 17, wherein an execution of the at least one receiving thread is suspended once for every predetermined number of executions of the delivery thread.

19. The machine-readable medium of claim 17, wherein the method further comprises maintaining statistic information regarding receiving messages for each of the receiving threads, wherein the period of time for suspending at least one of the receiving threads is determined based in part on the statistic information associated with the respective receiving thread.

20. The machine-readable medium of claim 18, wherein the statistic information including at least one of receiving rate within a given time unit and frequency of having a relatively high receiving rate.

21. A data processing system, comprising:

a processor;

a memory coupled to the processor; and

a process when executed from the memory, causes the processor to

receive a plurality of messages associated with a topic from a plurality of producers via a plurality of receiving threads, the messages associated with the topic being subscribed to by one or more subscribers,

deliver the messages to the one or more subscribers via a delivery thread, and

configure priorities of the receiving threads and the delivery thread such that a receiving rate of messages from the producers is substantially equivalent to a delivery rate of messages delivered to the subscribers.

22. The data processing system of claim 21, wherein the process further causes the processor to:

determine whether an amount of messages received via the receiving threads is larger than an amount of messages delivered via the delivery thread within a given time unit; and

configure at least one of the receiving threads to have a lower priority than the priority of the delivery thread if the amount of messages received is larger than the amount of messages delivered within the given time unit.

23. The data processing system of claim 21, wherein the process further causes the processor to:

determine whether an amount of messages received via the receiving threads is larger than an amount of messages delivered via the delivery thread within a given time unit; and

suspend at least one of the receiving threads for a period of time if the amount of messages received is larger than the amount of messages delivered within the given time unit.

24. The data processing system of claim 23, wherein an execution of the at least one receiving thread is suspended once for every predetermined number of executions of the delivery thread.