@Override
    public void receive(final ThrottledSubmission submission) throws Exception {
        val ldapProperties = context.getCasProperties().getAuthn().getThrottle().getLdap();

        val searchFilter = '(' + ldapProperties.getSearchFilter() + ')';
        val filter = LdapUtils.newLdaptiveSearchFilter(searchFilter, CollectionUtils.wrapList(submission.getUsername()));
        val response = connectionFactory.executeSearchOperation(ldapProperties.getBaseDn(),
            filter, ldapProperties.getPageSize(), ReturnAttributes.NONE.value());
        if (LdapUtils.containsResultEntry(response)) {
            val entry = response.getEntry();
            LOGGER.debug("Locating LDAP entry [{}]", entry);
            val attrMap = new HashMap<String, Set<String>>();
            attrMap.put(ldapProperties.getAccountLockedAttribute(), Set.of(Boolean.TRUE.toString()));
            connectionFactory.executeModifyOperation(entry.getDn(), CollectionUtils.wrap(attrMap));
        }
    }
This is {@link LdapThrottledSubmissionReceiver}.

@author Misagh Moayyed
@since 6.6.0
support/cas-server-support-throttle-ldap/src/main/java/org/apereo/cas/web/support/LdapThrottledSubmissionReceiver.java