@Test public void testLocalSegmentReturnsExpectedCommandBus() { Optional<CommandBus> result = testSubject.localSegment(); assertTrue(result.isPresent()); assertEquals(localCommandBus, result.get()); }
@Override public Optional<CommandBus> localSegment() { return Optional.of(localCommandBus); }
SpringHttpCommandBusConnector implements CommandBusConnector { @Override public Optional<CommandBus> localSegment() { return Optional.of(localCommandBus); } }
SpringHttpCommandBusConnector implements CommandBusConnector { @Override public Optional<CommandBus> localSegment() { return Optional.of(localCommandBus); } protected  SpringHttpCommandBusConnector(Builder builder); }
SpringHttpCommandBusConnector implements CommandBusConnector { @Override public Optional<CommandBus> localSegment() { return Optional.of(localCommandBus); } protected  SpringHttpCommandBusConnector(Builder builder); @StartHandler(phase = Phase.EXTERNAL_CONNECTIONS) void start(); static Builder builder(); @Override void send(Member destination, CommandMessage<? extends C> commandMessage); @Override void send(Member destination,
                            CommandMessage<C> commandMessage,
                            CommandCallback<? super C, R> callback); @Override CompletableFuture<Void> initiateShutdown(); @Override Registration subscribe(String commandName, MessageHandler<? super CommandMessage<?>> handler); @Override Optional<CommandBus> localSegment(); @PostMapping("/command") CompletableFuture<?> receiveCommand(@RequestBody SpringHttpDispatchMessage<C> dispatchMessage); @Override Registration registerHandlerInterceptor(
            MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor); }
SpringHttpCommandBusConnector implements CommandBusConnector { @Override public Optional<CommandBus> localSegment() { return Optional.of(localCommandBus); } protected  SpringHttpCommandBusConnector(Builder builder); @StartHandler(phase = Phase.EXTERNAL_CONNECTIONS) void start(); static Builder builder(); @Override void send(Member destination, CommandMessage<? extends C> commandMessage); @Override void send(Member destination,
                            CommandMessage<C> commandMessage,
                            CommandCallback<? super C, R> callback); @Override CompletableFuture<Void> initiateShutdown(); @Override Registration subscribe(String commandName, MessageHandler<? super CommandMessage<?>> handler); @Override Optional<CommandBus> localSegment(); @PostMapping("/command") CompletableFuture<?> receiveCommand(@RequestBody SpringHttpDispatchMessage<C> dispatchMessage); @Override Registration registerHandlerInterceptor(
            MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor);  }