Timer-based message handling for executing stateful services in a stateless environment

    公开(公告)号:US11163619B2

    公开(公告)日:2021-11-02

    申请号:US16730125

    申请日:2019-12-30

    Abstract: A state-aware microservice system for managing messages and providing a service. The state-aware microservice system includes a plurality of instances of the service, a message broker, a memory, and an electronic processor. The processor is configured to receive, via an instance of the plurality, a message for the service and determine whether a processing of the message is consistent with a current state of the system. When the processing of the message is consistent, the processor process the message via one of the plurality of instances. When the processing of the message is not consistent, the processor transmits the message to a first queue of the message broker, determines, from a timer of the message, a time-to-live of the message, and transfers the message to a second queue of one of the plurality of instances in response to the time-to-live expiring.

    Method and system to seamlessly upgrade cloud-based call processing services

    公开(公告)号:US11304035B1

    公开(公告)日:2022-04-12

    申请号:US17101264

    申请日:2020-11-23

    Abstract: A method and system to preserve a group call state during a cloud-based call processing service upgrade is provided. Group call requests are queued through a message broker to instances of a call processing service. A cloud based database is selectively locked and unlocked by each instance of the call processing service as group call requests are processed with retrieved group call states A need to upgrade the call processing service is determined by an orchestration framework, which sends exit signals to current instances of the call processing service and starts new instances. In-progress group call requests are processed by their respective instances of the call processing service and acknowledgments are sent to a message broker upon completion. Unacknowledged group call requests are determined byte message broker and retransmitted to the new instances of the call processing service.

    Method and system to seamlessly upgrade audio services

    公开(公告)号:US11509766B2

    公开(公告)日:2022-11-22

    申请号:US17101318

    申请日:2020-11-23

    Abstract: A method and system to preserve group call audio during a cloud-based group call service upgrade are provided. Audio duplication requests are received and managed through a message broker and instances of an audio distribution service. When a determination is made that an audio distribution service needs to be upgraded, the group call is preserved by generating new instances of the audio distribution service. The new instances of the audio distribution service are added to a queue of the message broker, and old instance of the audio duplication service are gracefully shutdown. Each new instance of the audio distribution service is used to route an audio stream associated with each of the original audio duplication requests, while the olds instances of the audio duplication service are being gracefully shutdown.

    PRESERVING PERSISTENT LINK CONNECTIONS DURING A CLOUD-BASED SERVICE SYSTEM UPGRADE

    公开(公告)号:US20220164221A1

    公开(公告)日:2022-05-26

    申请号:US17101499

    申请日:2020-11-23

    Abstract: A method and a microservice system for preserving link connections during an upgrade. The system a memory and an electronic processor. The processor is configured to initiate a client process upgrade for a first instance of a plurality of instances, each configured to establish and maintain a link connection between at least one of a plurality of electronic endpoint devices, store state data regarding the link connection between the first instance and an electronic endpoint device, and instantiate, for the first instance, an upgraded instance of the link adapter service. The processor is configured to shut down the first instance, causing the first instance to terminate the link connection to the endpoint device, and immediately establish a new link connection between the endpoint device and the upgraded instance, a state of the new link connection being established according to the stored state data.

    TIMER-BASED MESSAGE HANDLING FOR EXECUTING STATEFUL SERVICES IN A STATELESS ENVIRONMENT

    公开(公告)号:US20210200609A1

    公开(公告)日:2021-07-01

    申请号:US16730125

    申请日:2019-12-30

    Abstract: A state-aware microservice system for managing messages and providing a service. The state-aware microservice system includes a plurality of instances of the service, a message broker, a memory, and an electronic processor. The processor is configured to receive, via an instance of the plurality, a message for the service and determine whether a processing of the message is consistent with a current state of the system. When the processing of the message is consistent, the processor process the message via one of the plurality of instances. When the processing of the message is not consistent, the processor transmits the message to a first queue of the message broker, determines, from a timer of the message, a time-to-live of the message, and transfers the message to a second queue of one of the plurality of instances in response to the time-to-live expiring.

Patent Agency Ranking