Time and event controlled message processing

• US 8,793,325 B2
• Filed: 07/26/2004
• Issued: 07/29/2014
• Est. Priority Date: 07/26/2004
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Kessler, Joerg, Rossmanith, Stefan, Hofmann, Christoph, Surma, Peter, Dahl, Andreas
• Primary Examiner(s): Nguyen, Phuoc
• Assistant Examiner(s): Belani, Kishin G
• Application Number:
  US10/899,633
• Publication Number:
  US 20060020678A1
• Time in Patent Office: 3,655 Days
• Field of Search: 709/207, 709/206, 718/102, 370/235
• US Class Current: 709/207
• CPC Class Codes: H04L 67/62 Establishing a time schedule for servicing the requests

Abstract

A system and method for filtering messages in a messaging system is described. The system includes a user interface configured to receive user input for defining one or more message filters. Each message filter specifies predefined criteria by which a message is to be stopped. The system further includes a filter module comprising the one or more filters, and a queue connected with the filter module for queuing messages stopped according to one of the one or more filters. In a method, messages in the messaging system are stopped according to predefined criteria. Stopped messages are restarted according to a job executed by the messaging system.

Claims

1. A computer-implemented method of processing asynchronous messages in a messaging system, the method comprising:

receiving a message sent from a sender system at the messaging system, the messaging system comprising one or more filter locations;

stopping processing of the message based on evaluation of one or more attributes of the message according to criteria of a filter at one of the filter locations, the evaluated attributes being independent of other messages being processed by the messaging system;

storing information about the message in a persistence layer of the messaging system, the information comprising the filter location where processing of the message was stopped and a reference to a job according to which the message will be processed, the job defining one or more of a time and an event-related messaging transaction between the sender system and a receiver system according to a predefined set of business processes, the time and event-related messaging transaction being specified by the filter at the filter location where processing of the message was stopped; and

executing the job by the message system, the executing comprising restarting processing of the message, from the filter location where processing of the message was stopped, based on the information.

2. A method in accordance with claim 1, wherein the information further comprises a receiver identity, a sender identity, or a message size.

3. A method in accordance with claim 1, wherein the job defines an event that comprises an online state of a receiver system to which the message is to be delivered, and wherein the messaging system receives an offline message from the receiver system, stops delivery of the message to the receiver system, stores the messages in the persistence layer, receives an online message from the receiver system, and resumes processing of the message.

4. A method in accordance with claim 1, wherein the job defines a time by which processing of the message is to be restarted.

5. A method in accordance with claim 1, wherein the job includes the information about the message.

6. A method in accordance with claim 1, further comprising queuing the message in a message queue.

7. A method in accordance with claim 6, wherein restarting processing of the message includes processing the message in a queue order specified by the message queue.

8. A method in accordance with claim 7, wherein the queue order includes all messages processed by the messaging system in a time interval.

9. A method in accordance with claim 1, further comprising receiving the job in a filter module.

10. A method in accordance with claim 9, wherein the filter module is connected with the persistence layer.

17. A computer-implemented method as in claim 1, wherein the job comprises a set of business processes to be executed on the message.

18. A computer-implemented method as in claim 17, wherein the time or the event relates to the set of business processes.

11. A system for filtering messages in a messaging system, comprising:

a user interface configured to receive user input for defining one or more message filters, wherein each message filter specifies criteria by which processing of a message is to be stopped, each message filter evaluating one or more attributes of the message according to the criteria, the evaluated attributes being independent of other messages being processed by the messaging system;

a filter module comprising the one or more message filters;

a queue connected with the filter module for queuing the message if its processing is stopped;

a persistence layer that stores information about the message, the information comprising a filter location where processing of the message was stopped and a reference to a job according to which the message will be processed, each job defining one or more of a time and an event-related messaging transaction between the sender system and a receiver system according to a predefined set of business processes, the time and event-related messaging transaction being specified by the filter at the filter location where processing of the message was stopped; and

a job engine coupled with the messaging system, the job engine running one or more jobs, the message being chosen for the restarting, from the filter location where processing of the message was stopped, based on the information stored in the persistence layer.

12. A system in accordance with claim 11, wherein each job includes a set of business processes to be executed on the message.

13. A system in accordance with claim 12, wherein the time or the event relates to the set of business processes.

14. A system in accordance with claim 11, wherein the job engine is configured to restart processing of the messages according to a queue order.

15. A computer-implemented system for processing messages in a message processing platform, the system comprising:

a message communication system connected to at least one sender of a message and at least one receiver of the message and comprising one or more filter locations; and

code running on the message communication system, the code being configured to;

receive a message sent from a sender system at the messaging system;

stop processing of the message based on evaluation of one or more attributes of the message according to criteria of a filter at one of the filter locations, the evaluated attributes being independent of other messages being processed by the messaging system;

store information about the message in a persistence layer of the message communication system, the information comprising the filter location where processing of the message was stopped and a reference to a job according to which the message will be processed, the job defining one or more of a time and an event-related messaging transaction between the sender system and a receiver system according to a predefined set of business processes, the time and event-related messaging transaction being specified by the filter at the filter location where processing of the message was stopped; and

execute the job by the messaging communication system, the executing comprising restarting processing of the message, from the filter location where processing of the message was stopped, based on the information.

16. A system in accordance with claim 15, further comprising a queue for storing a copy of the message if its processing is stopped.