我在Apache Camel中編寫了一個自定義組件。駱駝成功地創(chuàng)建了它的消費者并使用我的 URI，但沒有調(diào)用處理器。這是我的消費者代碼片段（在 Kotlin 中）：class SoroushBotConsumer (private val endpoint: MyEndpoint, processor: Processor) : DefaultConsumer(endpoint, processor) {    val objectMapper:ObjectMapper = ObjectMapper();    init {        startListening()    }    private fun startListening() {        val client = ClientBuilder.newBuilder().register(SseFeature::class.java).build()        val target = client.target("MY_URL"))        while(true){            var e: EventInput?  target.request().get(EventInput::class.java)!!            val inboundEvent = e.read()            val exchange = endpoint.createExchange()            exchange.getIn().body = objectMapper.readValue(inboundEvent.rawData,MessageModel::class.java)            try {                processor.process(exchange)            } catch (e: Exception) {                if (exchange.exception != null) {                exceptionHandler.handleException("Error processing exchange",exchange, exchange.exception)            }        }    }}在消費者中一切正常，但沒有處理器被執(zhí)行。這是我創(chuàng)建路線的方法！var context = DefaultCamelContext()context.addRoutes(object : RouteBuilder() {    override fun configure() {        from("myapp://getMessage/).process{            println(it.getIn())        }.to("myapp://sendMessage/")    }})context.start();Thread.sleep(100000);context.stop();它既不調(diào)用流程也不創(chuàng)建我的生產(chǎn)者。（它甚至不調(diào)用MyEndpoint::createProducer()）當我用另一個端點替換我的from語句時file，一切正常。更新：ScheduledPollConsumer當我從實現(xiàn)方法擴展我的消費者時pull，一切都很好。