Using AMQP for replication

A system comprising:

• One or more processors
• a persistent storage unit to store a lightweight directory access protocol (LDAP)-based database;
• and
• a message-based replication system hosted by a first directory server coupled to the persistent storage unit to
• receive update data, the update data indicating an update to be made to the LDAP-based database,
• establish communication with an advanced message queuing protocol (AMQP) server to publish update data and to subscribe to update data that is published by a plurality of directory servers, the update data indicating a change made to LDAP-based databases that are managed by the plurality of directory servers,
• convert the update data into an LDAP data format and to update the LDAP-based database using the LDAP formatted update data based on a determination that the update data is received from the AMQP server, and
• update the LDAP-based database using the received update data, convert the update data into a wire level data format, and to publish the wire level formatted update data to the AMQP server based on a determination that the update data is not received from the AMQP server, wherein the AMQP server allows a second directory server that subscribes to the AMQP server to obtain data representing the update.

A non-transitory computer-readable storage medium including instructions that, when executed by a computer system, cause the computer system to perform a set of operations comprising:

• receiving update data, by the computing system, the computing system being a first computing system, the update data indicating an update to be made to a lightweight directory access protocol (LDAP)-based database that is coupled to the first computing system;
• establishing communication with an advanced message queuing protocol (AMQP) server to publish update data and to subscribe to update data that is published by a plurality of directory servers, the update data indicating a change made to LDAP-based databases that are managed by the plurality of directory servers;
• converting, by the first computing system, the update data into an LDAP data format based on a determination that the update data is received from the AMQP server and updating the LDAP-based database using the LDAP formatted update data;
• and
• updating, by the first computing system, the LDAP-based database using the received update data based on a determination that the update data is not received from the AMQP server, converting the update data into a wire level data format, and publishing the wire level formatted update data to the AMQP server, wherein the AMQP server allows a second computing system that subscribes to the AMQP server to obtain data representing the update.