System and method for queuing data for an application server

• US 7,953,788 B2
• Filed: 09/29/2001
• Issued: 05/31/2011
• Est. Priority Date: 09/29/2001
• Status: Active Grant

• Current Assignee: Oracle America, Inc. (Oracle Corporation)
• Original Assignee: Siebel Systems Inc. (Oracle Corporation)
• Inventors: Freese, Agnes, Lim, Peter Siam Sy III, Fischer, Jeffrey
• Primary Examiner(s): Caldwell; Andrew
• Assistant Examiner(s): Biagini; Christopher D
• Application Number:
  US09/968,134
• Publication Number:
  US 20070250600A1
• Time in Patent Office: 3,531 Days
• Field of Search: 709/219, 709201-203, 707/4, 707/102, 707/202
• US Class Current: 709/202
• CPC Class Codes: A61K 47/62 the modifying agent being a protein, peptide or polyamino acid
• CPC Class Codes: G06F 2209/548 Queue
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A method for queuing data for an application server is described. The method includes creating a queue entry record corresponding to the data, storing a queue entry including the data and the corresponding queue entry record in a queue, and receiving a command regarding the data from the application server.

Claims

1. A computer program product comprising:

a non-transitory computer readable medium; and

computer-executable instructions encoded on the non-transitory computer readable medium and configured to perform acts comprising;

receiving a command and data object from an external application server;

converting the data object, wherein

the data object is received in a received format,

the received format is compatible with the external application server,

the converting converts the data object from the received format into a queue format,

the queue format is compatible with a queue,

the queue format comprises identifying information,

the identifying information is configured to identify the data object and application-specific information, and

the application-specific information is specific to the external application server;

creating a queue entry record corresponding to the data object;

determining whether a queue entry can be stored in the queue, wherein

the queue entry comprises the data object and the corresponding queue entry record;

if the queue entry can be stored in the queue, storing the queue entry in the queue;

attempting to locate the queue entry in the queue, using the identifying information; and

if the queue entry is located in the queue,

querying the queue,

processing the data object from the queue entry, wherein the processing comprises

converting the data object from the queue format into the received format,

converting the data object in the received format into an integration object, and

transforming the integration object into an internal integration object, wherein

the transforming uses a transformation data map, and

the integration object is recognizable by the application server.

2. The non-transitory computer readable medium of claim 1, wherein the queue entry further comprises a status record, and the computer-executable instructions are further configured to update the status record.

3. The non-transitory computer readable medium of claim 1, wherein the queue entry further comprises a status record, and the instructions are further configured to retrieve a status value in the status record and return the status value to the external application server.

4. The non-transitory computer readable medium of claim 1, wherein the computer-executable instructions are further configured to transmit the data object from the queue entry to the external application server.

5. The non-transitory computer readable medium of claim 1, wherein the computer-executable instructions are further configured to convert the data object to a file before storing the queue entry.

6. The non-transitory computer readable medium of claim 5, wherein the computer-executable instructions are further configured to retrieve the file from the queue entry and to convert the file to a property set.

7. The non-transitory computer readable medium of claim 1, wherein the computer-executable instructions are further configured to:

return an error regarding the data object to the external application server, if the queue entry cannot be stored in the queue.

8. The non-transitory computer readable medium of claim 1, wherein the computer-executable instructions are further configured to:

delete the queue entry from the queue, if the processing is successful; and

recover the data object from the queue entry, if the processing fails.

9. The non-transitory computer readable medium of claim 1, wherein the computer-executable instructions are further configured to:

return an error regarding the queue entry, if the queue entry cannot be located in the queue.

10. A method comprising:

receiving a command and data object from an external application server;

converting the data object, wherein

the data object is received in a received format,

the received format is compatible with the external application server,

the converting converts the data object from the received format into a queue format,

the queue format is compatible with a queue,

the queue format comprises identifying information,

the identifying information is configured to identify the data object and application-specific information, and

the application-specific information is specific to the external application server;

creating a queue entry record corresponding to the data object;

determining whether a queue entry can be stored in the queue, wherein

the queue entry comprises the data object and the corresponding queue entry record;

if the queue entry can be stored in the queue, storing the queue entry in the queue;

attempting to locate the queue entry in the queue using the identifying information; and

if the queue entry is located in the queue,

querying the queue entry,

processing the data object from the queue entry, wherein

the processing comprises

converting the data object from the queue format into the received format,

converting the data object in the received format into an integration object, and

transforming the integration object into an internal integration object, wherein

the transforming uses a transformation data map, and

the integration object is recognizable by the application server.

11. The method of claim 10, wherein the queue entry further comprises a status record, the method further comprising:

updating the status record.

12. The method of claim 10, wherein the queue entry further comprises a status record, the method further comprising:

retrieving a status value in the status record; and

returning the status value to the external application server.

13. The method of claim 10, further comprising:

retrieving the data object from the queue entry; and

transmitting the data object to the external application server.

14. The method of claim 10, wherein

the converting converts the data object to a file before storing the queue entry.

15. The method of claim 14, further comprising:

retrieving the file from the queue entry; and

converting the file to a property set.

16. The method of claim 10, further comprising:

returning an error regarding the data object to the external application server, if the queue entry cannot be stored in the queue.

17. The method of claim 10, further comprising:

deleting the queue entry from the queue, if the processing is successful; and

recovering the data object from the queue entry, if the processing fails.

18. The method of claim 10, further comprising:

returning an error regarding the queue entry, if the queue entry cannot be located in the queue.

19. A system comprising:

a processor; and

memory, coupled to the processor, wherein the memory stores program instructions executable by the processor to;

receive a command and data object from an external application server, wherein

the data object is received in a received format, and

the received format is compatible with the external application server;

convert the data object from the received format into a queue format, wherein

the queue format is compatible with a queue,

the queue format comprises identifying information,

the identifying information is configured to identify the data object and application-specific information, and

the application-specific information is specific to the external application server;

create a queue entry record corresponding to the data object;

determine whether a queue entry can be stored in a queue, wherein

the queue entry comprises the data object and the corresponding queue entry record;

store the queue entry, if the queue entry can be stored in the queue;

attempt to locate the queue entry in the queue using the identifying information;

query the queue entry, if the queue entry is located in the queue; and

process the data object from the queue entry, if the queue entry can be located in the queue, wherein

the program instructions are further executable to

convert the data object from the queue format into the received format,

convert the data object in the received format into an integration object, and

transform the integration object into an internal integration, object using a transformation data map, wherein

the integration object is recognizable by the application server.

20. The system of claim 19, wherein the queue entry further comprises a status record and the program instructions are further executable to update the status record.

21. The system of claim 19, wherein the queue entry further comprises a status record and the program instructions are further executable to retrieve a status value in the status record;

and return the status value to the external application server.

22. The system of claim 19, wherein the program instructions are further executable to:

retrieve the data object from the queue entry; and

transmit the data object to the external application server.

23. The system of claim 19, wherein the program instructions are further executable to:

convert the data object to a file before storing the queue entry.

24. The system of claim 23, wherein the program instructions are further executable to:

retrieve the file from the queue entry; and

convert the file to a property set.

25. The system of claim 19, wherein the program instructions are further executable to:

return an error regarding the data object to the external application server, if the queue entry cannot be stored in the queue.

26. The system of claim 19, wherein the program instructions are further executable to:

delete the queue entry from the queue, if the processing is successful; and

recover the data object from the queue entry, if the processing fails.

27. The system of claim 19, wherein the program instructions are further executable to:

return an error regarding the queue entry, if the queue entry cannot be located in the queue.