@Test void testLocalSegmentReturnsLocalCommandBus() { assertEquals(localSegment, testSubject.localSegment()); }
@Override public CommandBus localSegment() { return localSegment; }
AxonServerCommandBus implements CommandBus, Distributed<CommandBus> { @Override public CommandBus localSegment() { return localSegment; } }
AxonServerCommandBus implements CommandBus, Distributed<CommandBus> { @Override public CommandBus localSegment() { return localSegment; } AxonServerCommandBus(Builder builder); }
AxonServerCommandBus implements CommandBus, Distributed<CommandBus> { @Override public CommandBus localSegment() { return localSegment; } AxonServerCommandBus(Builder builder); static Builder builder(); @StartHandler(phase = Phase.INBOUND_COMMAND_CONNECTOR) void start(); @Override void dispatch(CommandMessage<C> command); @Override void dispatch(CommandMessage<C> commandMessage,
                                CommandCallback<? super C, ? super R> commandCallback); @Override Registration subscribe(String commandName, MessageHandler<? super CommandMessage<?>> messageHandler); @Override CommandBus localSegment(); @Override Registration registerHandlerInterceptor(
            MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor); @Override Registration registerDispatchInterceptor(
            MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor); @ShutdownHandler(phase = Phase.INBOUND_COMMAND_CONNECTOR) CompletableFuture<Void> disconnect(); @ShutdownHandler(phase = Phase.OUTBOUND_COMMAND_CONNECTORS) CompletableFuture<Void> shutdownDispatching(); }
AxonServerCommandBus implements CommandBus, Distributed<CommandBus> { @Override public CommandBus localSegment() { return localSegment; } AxonServerCommandBus(Builder builder); static Builder builder(); @StartHandler(phase = Phase.INBOUND_COMMAND_CONNECTOR) void start(); @Override void dispatch(CommandMessage<C> command); @Override void dispatch(CommandMessage<C> commandMessage,
                                CommandCallback<? super C, ? super R> commandCallback); @Override Registration subscribe(String commandName, MessageHandler<? super CommandMessage<?>> messageHandler); @Override CommandBus localSegment(); @Override Registration registerHandlerInterceptor(
            MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor); @Override Registration registerDispatchInterceptor(
            MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor); @ShutdownHandler(phase = Phase.INBOUND_COMMAND_CONNECTOR) CompletableFuture<Void> disconnect(); @ShutdownHandler(phase = Phase.OUTBOUND_COMMAND_CONNECTORS) CompletableFuture<Void> shutdownDispatching();  }