CPC H04L 63/104 (2013.01) [H04L 63/102 (2013.01); H04L 63/20 (2013.01); H04L 67/562 (2022.05)] | 20 Claims |
1. A method comprising:
publishing, at a data processing system, a first message for a first type of event, wherein the first type of event comprises a request to identify and fetch users for a group based on a rule, and wherein the rule identifies users that qualify for membership in the group;
obtaining, by a first subscriber of the data processing system, the first message;
fetching, by the first subscriber of the data processing system, a plurality of user identifiers associated with a plurality of the users that satisfy the rule;
identifying, by the first subscriber of the data processing system, a first group of user identifiers of the plurality of user identifiers based on a first configurable property that is a threshold of user identifiers or users to be processed for a group add operation;
splitting, by the first subscriber of the data processing system, the first group of user identifiers into subgroups of user identifiers based on a second configurable property that is a threshold of the user identifiers or the users to be processed for the group add event to be processed by each thread or subscriber, wherein the subgroups of user identifiers comprise a first subgroup of user identifiers and a second subgroup of user identifiers;
publishing, by the first subscriber of the data processing system, a second message for a second type of event for each subgroup of the first group of user identifiers, wherein the second type of event comprises a request to add the subgroup of user identifiers to the group;
obtaining, by a second subscriber of the data processing system, the second message for the first subgroup of user identifiers;
adding, by a second subscriber of the data processing system, the first subgroup of user identifiers to the group to assign group membership to a first subgroup of the users associated with the first subgroup of user identifiers;
obtaining, by a third subscriber of the data processing system, the second message for the second subgroup of user identifiers; and
adding, by a third subscriber of the data processing system, the second subgroup of user identifiers to the group to assign group membership to a second subgroup of the users associated with the second subgroup of user identifiers.
|