将Spring bean传递给Camel组件

Question

我有一个类型为FooComponent的自定义组件，它通过以下行添加到路由中：

from("foo://bar?args=values&etc")
        .bean(DownstreamComponent.class)
        ...

创建一个终结点和消费者（类型为FOFOCER），该终结点和消费者反过来会发出消息，这些消息将到达DownStreComponent和管道的其余部分。

为了进行监控，我需要FooComponent消费者调用一个非驼峰对象上的方法，我正在创建一个Springbean。Camel管道对性能非常敏感，因此我无法将FooComponent分成两半，并将监视器调用作为Camel组件插入它们之间（我的首选解决方案，因为FooComponent不必真正了解监视器）。我不愿意将方法调用变成驼峰消息，稍后将由管道中的监控组件拾取，因为管道过滤稍后会变得复杂，我不想过度干预。

在FooConsumer的某个地方，我有：

// in the class
@Autowired
Monitor monitor;

// inside the consumer's run method
monitor.noticeSomething();

问题是监视器永远不会被设置为监视器bean，监视器bean是在应用程序的其余部分中创建的。据我所知，这是因为对Spring来说，Fef消费者本身是不可见的——这种类型的对象通常是在FefComponent中创建的。

那么，如何让efComponent找到它需要使用的Monitor实例呢？

• 创建路线时，我可以传递它吗？这似乎很棘手，因为这个定义是一个虚假的URL”foo://bar?args=values




Answer 1

最简单的方法是在FooComponent类上创建一个Monitor属性，并像其他bean一样连接它。

<bean id="monitorBean" class="my.Monitor"/>

<bean id="foo" class="my.FooComponent">
    <property name="monitor" ref="monitorBean"/>
</bean>

然后在您的FooConsumer中，当您需要获得显示器时，请拨打：

Monitor monitor = ((FooComponent) getEndpoint().getComponent()).getMonitor();

如果要按每个终结点更改监视器bean，则可以使用Camel的漂亮#语法来定位具有该id的bean，并将其注入Endpoint属性。

foo:something?monitor=#monitorBean

然后，要在你的FOMER中使用它，你只需说：

Monitor monitor = ((FooEndpoint) getEndpoint()).getMonitor();

Answer 2

如果你有一个Monitor的单例实例，你应该能够在efComponent类中@Autowire它。因为Camel在创建efComponent时会让Spring依赖注入。

然后，当您从组件创建endpoint/使用者时，可以传递monitor实例。