Apache-camel corda组件连接错误：无法创建路由route1

Question

我正在尝试使用该组件连接到 Corda，并使用 Apache Camel 的 Corda 组件再次将数据发送到 Apache ActiveMQ。

Corda 运行正常。特别是，cardapp-example 正在运行，并且 Notary-PartyA - PartyB 和 PartyC 都处于活动状态。我可以使用他们的终端查询。 ActiveMQ 工作正常，我用另一个输入源对其进行了测试。 我还尝试连接所有四个节点的不同本地主机端口，以及骆驼的corda组件网页中显示的示例。

public class CordaConnector {
    public void ConnectToCorda() throws Exception {
        CamelContext context = new DefaultCamelContext();
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        context.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("corda://localhost:10004?username=user1&password=test&operation=VAULT_TRACK&contractStateClass=#contractStateClass").
            }
        });

        while(true) {
            context.start();
        }
    }
}

我收到以下错误消息：

Exception in thread "main" org.apache.camel.FailedToCreateRouteException: Failed to create route route1: Route(route1)[From[corda://localhost:10004?username=user1&pa... because of Failed to resolve endpoint: corda://localhost:10004?contractStateClass=%23contractStateClass&operation=VAULT_TRACK&password=test&username=user1 due to: Error binding property (contractStateClass=#contractStateClass) with name: contractStateClass on bean: org.apache.camel.component.corda.CordaConfiguration@1de76cc7 with value: #contractStateClass
...

所以单独测试时，corda 工作正常，ActiveMQ 工作正常（输出不同），我尝试了不同的端口来查询信息。我还尝试了不同的命令来查询，例如：

from("corda://localhost:10000?username=user1&password=test&operation=NETWORK_MAP_FEED").
to("activemq:queue:try");

我已经检查了这个问题Failed to create route route1，但没有任何帮助。 对于可能的原因，我将不胜感激。

Answer 1

在您的路由 from uri 中，您正在使用值 #contractStateClass 设置 contractStateClass 属性：这引用了 Camel 注册表中名为 contractStateClass 的 bean。但是由于您没有在上下文注册表中绑定任何具有此名称的 bean，因此 Camel 无法解析此值：Error binding property (contractStateClass=#contractStateClass) with name: contractStateClass on bean: org.apache.camel.component.corda.CordaConfiguration@1de76cc7 with value: #contractStateClass

您只需要配置一个Class 类型的bean 并将其提供给camel 注册中心。类似的东西应该可以工作（骆驼版本 2.24.x）

import net.corda.core.contracts.OwnableState;
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.SimpleRegistry;

public class CordaConnector {

    public static void main(String[] args) {
        try {
            SimpleRegistry registry = new SimpleRegistry();
            registry.put("contractStateClass", OwnableState.class);
            CamelContext camelContext = new DefaultCamelContext(registry);
            camelContext.addRoutes(new RouteBuilder() {
                @Override
                public void configure() {
                    from("corda://localhost:10004?username=user1&password=test&operation=VAULT_TRACK&contractStateClass=#contractStateClass")
                            .log("got message");
                }
            });
            camelContext.start();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

}

编辑 for Camel v3.x：

import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.support.SimpleRegistry;

public class CordaConnector {

    public static void main(String[] args) {
        try {
            SimpleRegistry registry = new SimpleRegistry();
            registry.bind("contractStateClass", MyContractClass.class);
            CamelContext camelContext = new DefaultCamelContext(registry);
            camelContext.addRoutes(new RouteBuilder() {
                @Override
                public void configure() {
                    from("corda://localhost:10004?username=user1&password=test&operation=VAULT_TRACK&contractStateClass=#contractStateClass")
                            .log("got message");
                }
            });
            camelContext.start();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}