@Test public void unregisterCommandHandler() { commandDispatcher.on(new CommandHandlerDisconnected(null, "clientId", "client", false)); }
@EventListener public void on(TopologyEvents.CommandHandlerDisconnected event) { handleDisconnection(event.clientIdentification(), event.isProxied()); }
CommandDispatcher { @EventListener public void on(TopologyEvents.CommandHandlerDisconnected event) { handleDisconnection(event.clientIdentification(), event.isProxied()); } }
CommandDispatcher { @EventListener public void on(TopologyEvents.CommandHandlerDisconnected event) { handleDisconnection(event.clientIdentification(), event.isProxied()); } CommandDispatcher(CommandRegistrationCache registrations, CommandCache commandCache,
                             CommandMetricsRegistry metricRegistry,
                             MeterFactory meterFactory,
                             @Value("${axoniq.axonserver.command-queue-capacity-per-client:10000}") int queueCapacity); }
CommandDispatcher { @EventListener public void on(TopologyEvents.CommandHandlerDisconnected event) { handleDisconnection(event.clientIdentification(), event.isProxied()); } CommandDispatcher(CommandRegistrationCache registrations, CommandCache commandCache,
                             CommandMetricsRegistry metricRegistry,
                             MeterFactory meterFactory,
                             @Value("${axoniq.axonserver.command-queue-capacity-per-client:10000}") int queueCapacity); void dispatch(String context, SerializedCommand request,
                         Consumer<SerializedCommandResponse> responseObserver, boolean proxied); MeterFactory.RateMeter commandRate(String context); @EventListener void on(TopologyEvents.CommandHandlerDisconnected event); void handleResponse(SerializedCommandResponse commandResponse, boolean proxied); FlowControlQueues<WrappedCommand> getCommandQueues(); int activeCommandCount(); }
CommandDispatcher { @EventListener public void on(TopologyEvents.CommandHandlerDisconnected event) { handleDisconnection(event.clientIdentification(), event.isProxied()); } CommandDispatcher(CommandRegistrationCache registrations, CommandCache commandCache,
                             CommandMetricsRegistry metricRegistry,
                             MeterFactory meterFactory,
                             @Value("${axoniq.axonserver.command-queue-capacity-per-client:10000}") int queueCapacity); void dispatch(String context, SerializedCommand request,
                         Consumer<SerializedCommandResponse> responseObserver, boolean proxied); MeterFactory.RateMeter commandRate(String context); @EventListener void on(TopologyEvents.CommandHandlerDisconnected event); void handleResponse(SerializedCommandResponse commandResponse, boolean proxied); FlowControlQueues<WrappedCommand> getCommandQueues(); int activeCommandCount();  }