Microsoft Technology Licensing, LLC

Vignesh Somasundaram

Krishna Kannan

Chukwunwike I J Onianwa

Marvin Prieto Adriano

Michal Kaczmarek

The disclosure herein describes a message ordering system for processing and synchronizing chat messages in partitions to maintain messaging order and load balancing in a distributed system at scale. Messages are placed in partitions based on session identifiers (IDs). Messaging order is secured by a session receiver holding a lock over particular partitions. Receivers having subscription to messages in service bus are enabled to terminate on occurrence of a predetermined event, such as threshold wait time without receiving additional messages with a selected session ID from their partitions, activity level on a node, number of receivers on a node or other metrics. Session ID locks are released after a session ends, a receiver terminates or a node crashes for failure handling. New receivers are created to handle new incoming messages for additional load balancing and/or failover.

Processing and ordering messages in partitions

The disclosed technology is generally directed to online chat management services. In one example of the technology, organization information is accessed for tenants. The organization information includes, for each organization, configuration information for the organization. Each organization belongs to a corresponding tenant. Worker service instances are scheduled to perform fills associated with the organizations, such that sufficient fills are performed for each organization according to the configuration information for the organizations in the accessed organization information. Each fill includes: causing artifacts associated with a function to be created, such that the artifacts associated with the function are configured based on the corresponding tenant. Artifact information associated with the created artifacts is received, including at least one unique identifier associated with the created artifacts for the function. Server-side caching of a cache record that includes the artifact information associated with the created artifacts for the function is performed.

Growing community of inventors

Issaquah, WA, United States of America

Vignesh Somasundaram