@Override
    public Response requestReply(Request request, Connection connection) {
        if (request instanceof NotifySubscriberRequest) {
            NotifySubscriberRequest notifyRequest = (NotifySubscriberRequest) request;
            serviceInfoHolder.processServiceInfo(notifyRequest.getServiceInfo());
            return new NotifySubscriberResponse();
        }
        return null;
    }
@Test
    void testRequestReply() {
        //given
        ServiceInfoHolder holder = mock(ServiceInfoHolder.class);
        NamingPushRequestHandler handler = new NamingPushRequestHandler(holder);
        ServiceInfo info = new ServiceInfo("name", "cluster1");
        Request req = NotifySubscriberRequest.buildNotifySubscriberRequest(info);
        //when
        Response response = handler.requestReply(req, new TestConnection(new RpcClient.ServerInfo()));
        //then
        assertTrue(response instanceof NotifySubscriberResponse);
        verify(holder, times(1)).processServiceInfo(info);
    }