@Test
    void verifyPublisher() {
        val registeredService = RegisteredServiceTestUtils.getRegisteredService();
        val casRegisteredServiceStreamPublisherIdentifier = new PublisherIdentifier("123456");
        
        val publisher = new DefaultCasRegisteredServiceStreamPublisher(mgr);
        val clientInfo = ClientInfoHolder.getClientInfo();
        publisher.publish(registeredService,
            new CasRegisteredServiceDeletedEvent(this, registeredService, clientInfo),
            casRegisteredServiceStreamPublisherIdentifier);
        publisher.publish(registeredService,
            new CasRegisteredServiceSavedEvent(this, registeredService, clientInfo),
            casRegisteredServiceStreamPublisherIdentifier);
        publisher.publish(registeredService,
            new CasRegisteredServiceLoadedEvent(this, registeredService, clientInfo),
            casRegisteredServiceStreamPublisherIdentifier);
        assertFalse(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