0

我们正在编写 3 个消费者来消费来自Activemq队列名称的消息作为ThermalMapusing Apache Camel and Spring。

我是新手Spring，我试图从中获取特定的 beanId("amqLinkId") 值bean.xml。为此，我编写了以下 3 个文件。

变量声明.java

public class VariablesDeclarations {
private String amqLink;
public String getAmqLink() {
return amqLink;
}
public void setAmqLink(String amqLink) {
this.amqLink = amqLink;
}
}

FirstConsumer.java

import org.apache.camel.CamelContext;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class FirstConsumer {
        public static void main(String[] args) {
     ApplicationContext contextObject=new ClassPathXmlApplicationContext("bean.xml");
        //Forwarding cursor to ConsumersMiddileWare class using CamelContext
        CamelContext camelObject=contextObject.getBean("activeContext", CamelContext.class);
        System.out.println("H");
}
}

ConsumersMiddleware.java

import org.apache.camel.builder.RouteBuilder;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class ConsumersMiddileWare extends RouteBuilder{
@Override
public void configure() throws Exception {
    System.out.println("Bye");
    BeanFactory beanFactory=new ClassPathXmlApplicationContext(new String[]{"bean.xml"});
    VariablesDeclarations vd=(VariablesDeclarations) beanFactory.getBean("amqLinkId");
    System.out.println(vd.getAmqLink());
}
 }

bean.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
                    http://www.springframework.org/schema/beans     http://www.springframework.org/schema/beans/spring-beans.xsd
                    http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
                    http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.5.0.xsd
                    ">

<!-- Creating camelContext element for forwarding to another ConsumersMiddileware class -->
<camelContext id="activeContext" xmlns="http://camel.apache.org/schema/spring">
    <routeBuilder ref="consumerMiddileWareContext" />
</camelContext>
<bean id="consumerMiddileWareContext" class="ActivemqPackage.ConsumersMiddileWare"></bean>

<!-- Following bean created for getting variable values into classes-->
<bean id="amqLinkId" class="ActivemqPackage.VariablesDeclarations">
    <property name="amqLink" value="activemq:queue:ThermalMap"></property>
</bean>
</beans>

工作流程：

如果你运行FirstConsumer.java，它应该转发到ConsumersMiddileWare.java。我想amqLinkId从那里找到值bean.xml并分配给任何String对象。

如果我找到了amqLinkId价值，以后直接我想写下面的代码ConsumersMiddileWare.java

  String activeMqURI=vd.getAmqLink();
  from( activeMqURI).to("bean:activemqProcessor?method=processMessage");

问题：

如果我触发FirsrConsumer.java，它正在向前。ConsumersMiddileWare.java它会继续打印Bye而不是打印amqLinkId值，如下所示。

 Bye
 Bye
 Bye
 Bye
 .
 .

谁能解释清楚。

谢谢

4

2 回答 2

1

问题是您的项目无法找到 slf4j-simple-1.6.2.jar。检查您是否在我们的项目构建路径中拥有它。如果没有添加它，然后检查。此外，您报告的实际问题和您后来编辑的问题是完全不同的问题。

于 2013-09-21T10:56:13.137 回答
1

您可以使用 SpringRouteBuilder 代替 RouteBuilder。这个类有一些额外的方法来从spring应用程序上下文中获取bean（例如spring xml文件）

public class ConsumersMiddileWare extends SpringRouteBuilder{
@Override
public void configure() throws Exception {
    VariablesDeclarations vd = lookup("amqLinkId", VariablesDeclarations.class)' 
 }

另一种方法是在常规 RouteBuilder 中使用 camelContext.getRegistry

public class ConsumersMiddileWare extends RouteBuilder{
@Override
public void configure() throws Exception {
    VariablesDeclarations vd = context().getRegistry().lookup("amqLinkId", VariablesDeclarations.class)' 
 }
于 2013-09-21T11:54:31.957 回答