Servicing database operations using a messaging server

• US 10,235,384 B2
• Filed: 04/30/2014
• Issued: 03/19/2019
• Est. Priority Date: 06/14/2010
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Megginson, Richard Allen
• Primary Examiner(s): Fan, Hua
• Application Number:
  US14/265,706
• Publication Number:
  US 20140237009A1
• Time in Patent Office: 1,784 Days
• CPC Class Codes: G06F 16/182 Distributed file systems
• CPC Class Codes: G06F 16/282 Hierarchical databases, e.g. IMS, LDAP data stores or Lotus Notes

Abstract

A client computing system publishes a database operation request to a global exchange on an advanced message queuing protocol (AMQP) server, wherein the database operation request identifies an operation to be performed on a database using a different application layer protocol. The client computing system obtains database operation result data from a client queue, on the AMQP server, that corresponds to the client computing system in response to publishing the database operation request and converts the database operation result data from a wire level format to a data format for the different application layer protocol.

Claims

1. A method comprising:

subscribing, by a client computing system, to a client queue on an advanced message queuing protocol (AMQP) server to obtain database operation result messages that pertain to operations performed on a lightweight directory access protocol (LDAP) based database maintained on a directory server;

publishing, by the client computing system, a database operation request to a global exchange on the AMQP server, wherein the database operation request identifies an operation to be performed on the LDAP based database, wherein the client computing system is not compatible with LDAP;

obtaining, by the client computing system, database operation result data from the database operation result messages in the client queue that corresponds to the client computing system in response to publishing the database operation request, wherein the AMQP server pushes the database operation result messages comprising the database operation result data to the client computing system in response to the client computing system having subscribed to the client queue; and

converting, by the client computing system, the database operation result data from a wire level format to a data format that is compatible with the client computing system.

2. The method of claim 1, wherein the database operation request specifies a client exchange for publishing database operation result data, the client exchange corresponding to the client queue for allowing the client computing system access to the database operation result data.

3. The method of claim 1, further comprising:

configuring communication with the AMQP server to publish database operation requests to the global exchange, the global exchange having a corresponding global queue that has a plurality of directory servers as subscribers.

4. The method of claim 1, wherein the database operation request comprises a search request and the database operation result data comprises one or more entries that satisfy search criteria in the database operation request and a result code that indicates whether the search operation succeeded.

5. The method of claim 1, wherein the database operation request comprises a request to update an entry in the LDAP based database and the database operation result data comprises a result code that indicates whether the update operation succeeded.

6. A non-transitory computer-readable storage medium storing instructions which, when executed, cause a processing device to:

subscribe, by the processing device in a client computing system, to a client queue on an advanced message queuing protocol (AMQP) server to obtain database operation result messages that pertain to operations performed on a lightweight directory access protocol (LDAP) based database maintained on a directory server;

publish, by the processing device in the client computing system, a database operation request to a global exchange on the AMQP server, wherein the database operation request identifies an operation to be performed on the LDAP based database, wherein the client computing system is not compatible with LDAP;

obtain, by the processing device in the client computing system, database operation result data from the database operation result messages in the client queue that corresponds to the client computing system in response to publishing the database operation request, wherein the AMQP server pushes the database operation result messages comprising the database operation result data to the client computing system in response to the client computing system having subscribed to the client queue; and

convert, by the processing device in the client computing system, the database operation result data from a wire level format to a data format that is compatible with the client computing system.

7. The non-transitory computer-readable storage medium of claim 6, wherein the database operation request specifies a client exchange for publishing database operation result data, the client exchange corresponding to the client queue for allowing the client computing system access to the database operation result data.

8. The non-transitory computer-readable storage medium of claim 6, wherein the instructions further cause the processing device to:

configure communication with the AMQP server to publish database operation requests to the global exchange, the global exchange having a corresponding global queue that has a plurality of directory servers as subscribers.

9. The non-transitory computer-readable storage medium of claim 6, wherein the database operation request comprises a search request and the database operation result data comprises one or more entries that satisfy search criteria in the database operation request and a result code that indicates whether the search operation succeeded.

10. The non-transitory computer-readable storage medium of claim 6, wherein the database operation request comprises a request to update an entry in the LDAP based database and the database operation result data comprises a result code that indicates whether the update operation succeeded.

11. A system comprising:

a persistent storage unit to store configuration data that associates a database operation request with a global exchange hosted by an advanced message queuing protocol (AMQP) server; and

a message-based client system coupled to the persistent storage unit to subscribe to a client queue on the AMQP server to obtain database operation result messages that pertain to operations performed on a lightweight directory access protocol (LDAP) based database maintained on a directory server, to publish the database operation request to the global exchange on the AMQP server, wherein the database operation request identifies an operation to be performed on the LDAP based database, wherein the client system is not compatible with LDAP, to obtain the database operation result data from the database operation result messages in the client queue that corresponds to the system in response to publishing the database operation request, wherein the AMQP server pushes the database operation result messages comprising the database operation result data to the client computing system in response to the client computing system having subscribed to the client queue, and to convert the database operation result data from a wire level format to a data format that is compatible with the client computing system.

12. The system of claim 11, wherein the database operation request specifies a client exchange for publishing database operation result data, the client exchange corresponding to the client queue for allowing the client computing system access to the database operation result data.

13. The system of claim 11 wherein the message-based client system further to configure communication with the AMQP server to publish database operation requests to the global exchange, the global exchange having a corresponding global queue that has a plurality of directory servers as subscribers.

14. The system of claim 11, wherein the database operation request comprises a search request and the database operation result data comprises one or more entries that satisfy search criteria in the database operation request and a result code that indicates whether the search operation succeeded.

15. The system of claim 11, wherein the database operation result data comprises a result code that indicates whether the update operation succeeded.