### Question:
SpringHttpCommandBusConnector implements CommandBusConnector { @Override public Registration subscribe(String commandName, MessageHandler<? super CommandMessage<?>> handler) { return localCommandBus.subscribe(commandName, handler); } 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);  }### Answer:
@Test public void testSubscribeSubscribesCommandHandlerForCommandNameToLocalCommandBus() { String expectedCommandName = "commandName"; testSubject.subscribe(expectedCommandName, messageHandler); verify(localCommandBus).subscribe(expectedCommandName, messageHandler); }