Axonframework,사용하는 방법 MessageDispatchInterceptor 와 함께 민감하는 저장소

I have read set-기반으로 일관성 검증을 블로그에 내가 원하는 검증을 통해 파견 interceptor. 나의 예를 따라,그러나 내가 사용하는 저장소 및 반응성 그것은 작동하지 않습니다. 가 두 블록고지 않습니다. 블록 오류가 발생하지만,없이 그것을 차단하지 않는 실행할 아무것도. 여기에는 나의 코드입니다.

class SubnetCommandInterceptor : MessageDispatchInterceptor<CommandMessage<*>> {

  @Autowired
  private lateinit var privateNetworkRepository: PrivateNetworkRepository

  override fun handle(messages: List<CommandMessage<*>?>): BiFunction<Int, CommandMessage<*>, CommandMessage<*>> {
    return BiFunction<Int, CommandMessage<*>, CommandMessage<*>> { index: Int?, command: CommandMessage<*> ->
      if (CreateSubnetCommand::class.simpleName == (command.payloadType.simpleName)){
        val interceptCommand = command.payload as CreateSubnetCommand
        privateNetworkRepository
          .findById(interceptCommand.privateNetworkId)
          // ..some validation logic here ex.
          // .filter { network -> network.isSubnetOverlap() }
          .switchIfEmpty(Mono.error(IllegalArgumentException("Requested subnet is overlap with the previous subnet.")))
          // .block() also doesn't work here it throws error
         // block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-
      }
      command
    }
  }
}