@Test
    void verifyAction() {
        val registeredService = RegisteredServiceTestUtils.getRegisteredService();
        var obj = mgr.get(registeredService);
        assertNull(obj);
        assertFalse(mgr.contains(registeredService));

        val id = new PublisherIdentifier();
        val cache = DistributedCacheObject.<RegisteredService>builder()
            .value(registeredService)
            .publisherIdentifier(id)
            .build();

        mgr.set(registeredService, cache, true);
        assertFalse(mgr.getAll().isEmpty());
        obj = mgr.get(registeredService);
        assertNotNull(obj);
        val result = mgr.findAll(obj1 -> obj1.getValue().equals(registeredService));
        assertFalse(result.isEmpty());
        mgr.remove(registeredService, cache, true);
        assertTrue(mgr.getAll().isEmpty());
    }
This is {@link RegisteredServiceHazelcastDistributedCacheManagerTests}.

@author Misagh Moayyed
@since 5.3.0
support/cas-server-support-service-registry-stream-hazelcast/src/test/java/org/apereo/cas/services/RegisteredServiceHazelcastDistributedCacheManagerTests.java