公开(公告)号：US20210320970A1

公开(公告)日：2021-10-14

申请号：US17304785

申请日：2021-06-25

Applicant: Verizon Patent and Licensing Inc.

Inventor： Amit GUPTA ,  Sarvesh AGRAWAL ,  Vijaya KOSURI ,  Pramod KALYANASUNDARAM ,  Lakshmi CHAKARAPANI ,  Srinivas S. HALEMBAR

IPC: H04L29/08 ,  H04L12/24 ,  H04L12/863 ,  H04L12/851

Abstract: A device receives a notification indicating a failure of a first server device responsible for a primary message queue that includes messages at a time of the failure. A second server device is responsible for a standby message queue to which the messages are replicated, where a position in the standby message queue and a message time are assigned to each of the replicated messages. The device obtains a record time that identifies the message time of one of the messages that was last obtained from the primary message queue prior to the failure, compares an adjusted record time and the message time of one or more of the messages of the standby message queue to determine a starting position in the standby message queue, and processes messages obtained from the standby message queue beginning at one of the messages assigned to the position that matches the starting position.

公开(公告)号：US20230147246A1

公开(公告)日：2023-05-11

申请号：US18149761

申请日：2023-01-04

Applicant: Verizon Patent and Licensing Inc.

Inventor： Amit GUPTA ,  Sarvesh AGRAWAL ,  Vijaya KOSURI ,  Pramod KALYANASUNDARAM ,  Lakshmi CHAKARAPANI ,  Srinivas S. HALEMBAR

IPC: G06F11/14 ,  H04L67/1034 ,  H04L41/0668 ,  H04L47/62 ,  H04L47/24 ,  H04L67/61 ,  H04L67/62

CPC classification number: G06F11/1451 ,  H04L67/1034 ,  H04L41/0668 ,  H04L47/622 ,  H04L47/24 ,  H04L67/61 ,  H04L67/62 ,  G06F11/1471 ,  G06F11/1474

Abstract: A device receives a notification indicating a failure of a first server device responsible for a primary message queue that includes messages at a time of the failure. A second server device is responsible for a standby message queue to which the messages are replicated, where a position in the standby message queue and a message time are assigned to each of the replicated messages. The device obtains a record time that identifies the message time of one of the messages that was last obtained from the primary message queue prior to the failure, compares an adjusted record time and the message time of one or more of the messages of the standby message queue to determine a starting position in the standby message queue, and processes messages obtained from the standby message queue beginning at one of the messages assigned to the position that matches the starting position.