ฉันต้องอ่านที่ตั้งค่า-จาก มุมมการตรวจสอบบล็อก และฉันอยากจะพิสูจน์ความถูกต้องขอผ่านส่ interceptor. ฉันทำตามกตัวอย่างเช่นแต่ฉันใช้ reactive เก็บและมันไม่ได้ผลสำหรับฉัน ฉันพยายามทั้งสองบล็อกและไม่ใช่แบบเดียวกันหมด กับบล็อคทำให้เกิดข้อผิดพลาด,แต่ไม่มีบล็อกมันไม่ได้เรียกประมวลผลอะไรเลย นี่คือตอบสนองรหัสผม
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
}
}
}