Need help to run jencks consumer

View: New views
1 Messages — Rating Filter:   Alert me  

Need help to run jencks consumer

by zaoliu :: Rate this Message:

Reply to Author | View Threaded | Show Only this Message

I want to use jencks to build a consumer to get messages from Activemq server and I don't know how to configure the consumer with no transaction consumer which will use local jms transactions. Below is my configuration file:

<?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-2.5.xsd">
                 
<bean id="myJencks" class="org.jencks.JCAContainer">
         <property name="threadPoolSize" value="25"/>
  <property name="resourceAdapter">
         <bean id="activeMQResourceAdapter" class="org.apache.activemq.ra.ActiveMQResourceAdapter">
                 <property name="serverUrl" value="discovery:(multicast://default)"/>
         </bean>
  </property>
</bean>

<bean id="inboundConnector" class="org.jencks.JCAConnector">
        <!-- <property name="transactionManager" value=""/> -->
        <property name="jcaContainer" ref="myJencks" />
    <property name="activationSpec">
      <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
        <property name="destination" value="TOOL.DEFAULT"/>
        <property name="destinationType" value="javax.jms.Queue"/>
      </bean>
    </property>
    <property name="ref" value="JencksConsumer"/>
</bean>
 
<bean id="JencksConsumer" class="JencksConsumer"/>
</beans>

When I use the ClassPathXmlApplicationContext to parse these file, getting these exception :
Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'myJencks' defined in class path resource [spring.xml]: Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: bootstrapContext or transactionManager must be set
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1260)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:438)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:383)
        at java.security.AccessController.doPrivileged(Native Method)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:353)
        at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:245)
        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:169)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:242)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:400)
        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:736)
        at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:369)
        at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:123)
        at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:66)
        at ConsumerAdmin.main(ConsumerAdmin.java:8)
Caused by: java.lang.IllegalArgumentException: bootstrapContext or transactionManager must be set
        at org.jencks.JCAContainer.afterPropertiesSet(JCAContainer.java:75)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1288)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1257)
        ... 14 more

Does it mean the configuration must have a transaction mananger?