Queuing connector to promote message servicing

• US 7,937,433 B1
• Filed: 09/23/2003
• Issued: 05/03/2011
• Est. Priority Date: 09/23/2003
• Status: Active Grant

• Current Assignee: CenturyLink Intellectual Property LLC (Lumen Technologies, Inc.)
• Original Assignee: Embarq Holdings Company LLC (Lumen Technologies, Inc.)
• Inventors: Kumar, Nandhu
• Primary Examiner(s): Chea; Philip J
• Application Number:
  US10/668,732
• Time in Patent Office: 2,779 Days
• Field of Search: 709/205, 709/206, 709/207, 709/200, 709/203, 709/204, 719314-315
• US Class Current: 709/203
• CPC Class Codes: G06F 9/544 Buffers; Shared memory; Pipes

Abstract

A system for delivering messages to a business component is provided. A Java Message Service (JMS) enabled connector from a first JMS enabled queue, and from a second queue, a file based queue using a polling notification type of architecture, which will act as a JMS enabled queue with a publication/subscription notification type of architecture through the use of a JMS enabled wrapper which acts on the second queue. The JMS enabled connector serves as the interface to the business component, and is operable to transform the message, and further operable to record, in a standard format, information about messages delivered from the first queue and from the second queue. A method for delivering messages to a business component is also provided.

Claims

1. A system for message service, comprising:

a memory operable to store computer executable instructions;

a processor operable to execute the computer executable instructions, said instructions comprising;

a business component utilizing messages;

a first queue to manage message services, the first queue employing a polling notification type architecture;

a second queue employing a publication/subscription notification type of architecture;

a wrapper to enable the first queue to operate a publication/subscription notification type of architecture, wherein the wrapper performs the function of querying the first queue to determine the existence of new messages; and

a queue connector in communication with the first queue via the wrapper, wherein the wrapper publishes new messages to the queue connector, the queue connector further in communication with the business component and the second queue, the queue connector receiving messages from the first queue via the wrapper and sending the messages being received from the first queue via the wrapper to the business component, thereby enabling a user to utilize the business component to access information in the messages from the first queue the queue connector further sending messages being received from the second queue to the business component.

2. The system of claim 1, wherein the queue connector removes a portion of the received messages undesired for use by the business component.

3. The system of claim 1, wherein an address identifying a location of at least one of the messages of the first queue is located in a file.

4. The system of claim 1, wherein an address identifying the location of at least one of the messages of the first queue is on a socket connection.

5. The system of claim 1, wherein an address identifying the location of at least one of the messages of the first queue is on a port connection.

6. The system of claim 1, wherein the queue connector adds information to the received messages desired for use by the business component.

7. The system of claim 1, wherein the queue connector is further operable to communicate the messages from the business component to at least one of the first and second queues.

8. The system of claim 1, wherein the second queue is further defined as a Java Message Service OMS) queue.

9. The system of claim 8, wherein the JMS queue receives messages from a file.

10. The system of claim 8, wherein the JMS queue receives messages from a Universal Resource Identifiers (URI) remotely.

11. The system of claim 1, wherein the wrapper is further defined as a JMS enabled wrapper.

12. The system of claim 1, wherein the second queue is further defined as JMS standards application programming interface (API) operable for inter-client communication.

13. The system of claim 1, wherein the queue connector changes a priority of the received messages based on information provided by the business component.

14. The system of claim 1, wherein the queue connector deletes or filters the received messages based on information provided by the business component.

15. The system of claim 1, wherein the queue connector is operable to control a rate of flow in which the received messages are delivered to the business component.

16. A system of a queue connector to promote message services, comprising:

a memory operable to store computer executable instructions;

a processor operable to execute the computer executable instructions, said instructions comprising;

a first component to communicate messages with a publication/subscription notification type queue;

a second component configured to communicate messages with a polling notification type queue, by registering with a wrapper, the wrapper providing a publication/subscription type notification to the queue connector of new messages in the polling notification type queue, wherein the wrapper performs the function of querying the polling notification type queue to determine the existence of the new messages;

a business component interface to communicate with business components thereby enabling a user to utilize the business components to access information in the messages; and

a transaction component to verify that messages from one of the queues are received by the business components before the messages are consumed, the transaction component deleting a message from one of the queues upon verification of receipt of the message by the business components from the queue from which the message originated.

17. The system of claim 16, further comprising a logging component to record information related to the messages including a record of at least some of a message communicated between one of the publication/subscription notification type queue and the polling notification type queue other than the publication/subscription type queue and the business component.

18. The system of claim 17, wherein the record includes a date and time associated with each of the messages.

19. The system of claim 17, wherein the record includes a tracekey associated with each of the messages.

20. The system of claim 19, wherein the tracekey includes information related to the message.

21. The system of claim 20, wherein the information included with the tracekey includes a location of the message.

22. The system of claim 20, wherein the information included with the tracekey includes an origin of the message.

23. The system of claim 20, wherein the information included with the tracekey includes a type of the message.

24. The system of claim 20, wherein the information included with the tracekey includes a size of the message.

25. The system of claim 16, wherein the first component is a Vitria businessware component.

26. The system of claim 16, wherein the notification type queue is an MQ series queue.

27. The system of claim 16, wherein the wrapper queries the first queue to determine if a new message has been received by the first queue.

28. The system of claim 16, wherein the wrapper queries the second component to determine if a new message has been received by the second component.