Messaging system failover

A device, comprising:

• one or more processors configured to:
• determine, based on comparing a first time and a second time, a starting position in a second message queue,
• wherein the first time is associated with one or more first messages that were obtained from a first message queue prior to failure of one or more devices associated with the first message queue, and
• wherein the second time is based on a historical lag time recorded prior to the failure;
• and
• process a second message obtained from the second message queue based on the starting position.

A non-transitory computer-readable medium storing a set of instructions, the set of instructions comprising:

• one or more instructions that, when executed by one or more processors of a device, cause the device to:
• determine, based on comparing a first time and a second time, a starting position in a second message queue,
• wherein the first time is associated with one or more first messages that were obtained from a first message queue prior to failure of one or more devices associated with the first message queue, and
• wherein the second time is based on a historical lag time recorded prior to the failure;
• and
• process a second message obtained from the second message queue based on the starting position.