在Spring应用程序中添加Apache Camel自定义组件/endpoint

Question

我试图在Spring Boot应用程序中实现一个自定义endpoint。

目标是将路由用作:from（“...”）.process（“...”）.to（“my:...”）；

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配置类中，我有：

  @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文件：

class=com.my.endpoint.MyComponent

我已经完全阅读了“Apache Camel在行动，第二版”，但是，目前，我不能继续我的项目，因为？

Answer 1

这是因为自定义组件必须通过@uriendpoint注释进行注释。