我正在创建一条这样的路线:
<routes xmlns="http://camel.apache.org/schema/spring">
<route id="ESP_01.Handle_Movement">
<from uri="mqtt:ESP_01.Handle_Movement?host=tcp://localhost:1883&subscribeTopicName=ESP_01/Handle Movement&version=3.1&maxReadRate=0&qualityOfService=AtLeastOnce" />
<to uri="micrometer:timer:camel.proxy.mqtt.kafka.stream?action=start" />
<to uri="log://camel.proxy?groupInterval=3&level=INFO" />
<to uri="kafka://ESP_01.Handle_Movement?brokers=localhost:9092" />
<to uri="micrometer:timer:camel.proxy.mqtt.kafka.stream?action=stop" />
<to uri="micrometer:timer:camel.proxy.cache?action=start" />
<setHeader name="CamelCacheKey">
<constant>Test ESP_01.Handle_Movement</constant>
</setHeader>
<setHeader name="CamelCacheOperation">
<constant>Update</constant>
</setHeader>
<to uri="cache://Test ESP_01.Handle_Movement?maxElementsInMemory=10&eternal=true" />
<to uri="micrometer:timer:camel.proxy.cache?action=stop" />
</route>
</routes>
我有
<setHeader name="CamelCacheKey">
<constant>Test ESP_01.Handle_Movement</constant>
</setHeader>
<setHeader name="CamelCacheOperation">
<constant>Update</constant>
</setHeader>
但是,根据这个示例,我从title得到的错误消息是,缺少了required already existing name参数:
org.apache.camel.FailedToCreateRouteException: Failed to create route ESP_01.Handle_Movement at: >>> SetHeader[null, constant{Test ESP_01.Handle_Movement}] <<< in route: Route(ESP_01.Handle_Movement)[[From[mqtt:ESP_01.Handle_Movem... because of headerName must be specified
1条答案
按热度按时间yacmzcpb1#
这可能是由于<camel.version>2.24.3的bug造成的
在spring dsl中,验证的参数是
name
,而在标头的类中,参数名为headerName
,设置为空。如果我尝试使用headerName
spring dsl中的参数我得到这个错误: