在 Spring 应用程序中添加 Apache Camel 自定义组件/端点 [英] Adding Apache Camel custom component/endpoint in a Spring application
问题描述
我正在尝试在 Spring Boot 应用程序中实现自定义端点.
I'm trying to implement a custom endpoint in a Spring Boot application.
目标是使用路由作为:from("...").process("...").to("my:...");代码>
现在,我有 3 个类:一个 DefaultConsumer、一个 DefaultEndpoint、一个 DefaultComponent:
Now, I have 3 classes: a DefaultConsumer, a DefaultEndpoint, a DefaultComponent:
package com.my.endpoint;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.support.DefaultEndpoint;
public class MyEndpoint extends DefaultEndpoint {
public MyEndpoint(String uri, MyComponent myComponent) {
}
...
}
package com.my.endpoint;
import org.apache.camel.Endpoint;
import org.apache.camel.Processor;
import org.apache.camel.support.DefaultConsumer;
public class MyConsumer extends DefaultConsumer {
public MyConsumer(Endpoint endpoint, Processor processor) {
super(endpoint, processor);
}
}
package com.my.endpoint;
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.DefaultComponent;
import java.util.Map;
@Component("my")
public class MyComponent extends DefaultComponent {
public MyComponent(CamelContext camelContext) {
super(camelContext);
}
...
}
现在:我如何注册?
在 Spring 配置类中,我有:
In a Spring configuration class, I have:
@Override
public void configure() throws Exception {
camelContext.addComponent("my", new MyComponent(camelContext));
但不起作用:
Caused by: org.apache.camel.NoSuchEndpointException: No endpoint could be found for: my, please check your classpath contains the needed Camel component jar.
所以,我在 services/org/apache/camel/component/my 中添加了 META-INF 文件:
So, I added the META-INF file in services/org/apache/camel/component/my:
class=com.my.endpoint.MyComponent
但这也是行不通的.
没有关于如何实现这一点的完整教程.
There is no complete tutorial on how to implement this.
有什么帮助吗?
注意:我正在尝试实现一个端点,因为我需要使用我的数据类型来集成我的系统.我尝试使用 Transformer 但失败了:在 Apache 中设置自定义数据类型骆驼处理器
Note: I'm trying to implement an Endpoint because I need to integrate my systems using my data types. I tried using Transformer but failed because of this: Set a custom DataType in Apache Camel Processor
之前,我尝试使用数据类型转换器,但因此失败(标记为重复,因为人们懒得真正理解问题):在 Apache Camel 中强制对 Rest 使用者进行类型转换
Before, I tried using data type converter, but failed because of this (marked duplicate because people are too lazy to really understand questions): Enforce type conversion on Rest consumer in Apache Camel
我已完整阅读Apache Camel In Action,第二版";但是,目前,我无法继续我的项目,因为?
I've FULLY read "Apache Camel In Action, Second Edition" but, at the moment, I can't continue with my project because of?
推荐答案
这是因为自定义组件必须通过@UriEndpoint
注解进行注解.
This is because custom component must be annotated by @UriEndpoint
annotation.
这篇关于在 Spring 应用程序中添加 Apache Camel 自定义组件/端点的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!