@Bean
    public RegisterClientServerDisruptorPublisher registerClientServerDisruptorPublisher(final List<ShenyuClientRegisterService> shenyuClientRegisterService, final DiscoveryService discoveryService) {
        RegisterClientServerDisruptorPublisher publisher = RegisterClientServerDisruptorPublisher.getInstance();
        Map<String, ShenyuClientRegisterService> registerServiceMap = shenyuClientRegisterService.stream().collect(Collectors.toMap(ShenyuClientRegisterService::rpcType, Function.identity()));
        publisher.start(registerServiceMap, discoveryService);
        return publisher;
    }
@Test
    public void testRegisterClientServerDisruptorPublisher() {
        DiscoveryService discoveryService = mock(DiscoveryService.class);
        List<ShenyuClientRegisterService> shenyuClientRegisterService = new ArrayList<>();
        RegisterClientServerDisruptorPublisher publisher = registerCenterConfiguration
                .registerClientServerDisruptorPublisher(shenyuClientRegisterService, discoveryService);
        assertNotNull(publisher);
    }