Issue with Pollar
I am getting below exception
org.springframework.beans.factory.BeanCreationExce ption: Error creating bean with name 'org.springframework.integration.config.ConsumerEn dpointFactoryBean#1': Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: No poller has been defined for endpoint 'org.springframework.integration.config.ConsumerEn dpointFactoryBean#1', and no default poller is available within the context.
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.initializeBean(Abstract AutowireCapableBeanFactory.java:1420)
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.doCreateBean(AbstractAu towireCapableBeanFactory.java:519)
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.createBean(AbstractAuto wireCapableBeanFactory.java:456)
at org.springframework.beans.factory.support.Abstract BeanFactory$1.getObject(AbstractBeanFactory.java:2 93)
at org.springframework.beans.factory.support.DefaultS ingletonBeanRegistry.getSingleton(DefaultSingleton BeanRegistry.java:222)
at org.springframework.beans.factory.support.Abstract BeanFactory.doGetBean(AbstractBeanFactory.java:290 )
at org.springframework.beans.factory.support.Abstract BeanFactory.getBean(AbstractBeanFactory.java:192)
at org.springframework.beans.factory.support.DefaultL istableBeanFactory.preInstantiateSingletons(Defaul tListableBeanFactory.java:567)
at org.springframework.context.support.AbstractApplic ationContext.finishBeanFactoryInitialization(Abstr actApplicationContext.java:895)
at org.springframework.context.support.AbstractApplic ationContext.refresh(AbstractApplicationContext.ja va:425)
at org.springframework.context.support.ClassPathXmlAp plicationContext.<init>(ClassPathXmlApplicationCon text.java:139)
at org.springframework.context.support.ClassPathXmlAp plicationContext.<init>(ClassPathXmlApplicationCon text.java:83)
at com.messaging.springintegration.test.main(test.jav a:35)
Caused by: java.lang.IllegalArgumentException: No poller has been defined for endpoint 'org.springframework.integration.config.ConsumerEn dpointFactoryBean#1', and no default poller is available within the context.
at org.springframework.util.Assert.notNull(Assert.jav a:112)
at org.springframework.integration.config.ConsumerEnd pointFactoryBean.initializeEndpoint(ConsumerEndpoi ntFactoryBean.java:180)
at org.springframework.integration.config.ConsumerEnd pointFactoryBean.afterPropertiesSet(ConsumerEndpoi ntFactoryBean.java:135)
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.invokeInitMethods(Abstr actAutowireCapableBeanFactory.java:1477)
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.initializeBean(Abstract AutowireCapableBeanFactory.java:1417)
... 12 more
-------------------------------------------------------------------------------------------------------------------------------------------------
My configuration file is
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:jms="http://www.springframework.org/schema/integration/jms"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schem...-beans-3.0.xsd http://www.springframework.org/schema/integration http://www.springframework.org/schem...ration-2.0.xsd http://www.springframework.org/schema/integration/jms http://www.springframework.org/schem...on-jms-2.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<context:component-scan base-package="com.messaging.springintegration" />
<int:channel id="output" >
<int:queue capacity="10" />
</int:channel>
<int:channel id="input" />
<jms:outbound-channel-adapter channel="input" destination-name="requestQueueamit15" />
<jms:message-driven-channel-adapter channel="output" destination-name="requestQueueamit15" />
<int:header-value-router header-name="type" ignore-channel-name-resolution-failures="true"
input-channel="output">
<int:mapping value="inventory" channel="inventory"/>
</int:header-value-router>
<int:channel id="inventory">
<int:queue capacity="10" />
</int:channel>
<int:outbound-channel-adapter channel="inventory" ref="shouter" method="shout">
<intoller fixed-rate="3000"/>
</int:outbound-channel-adapter>
-------------------------------------------------------------------------------------------------------------------------------
I want to know why do we need Pller in my case because I am putting the message from MQ to output channel and than my Router will route the message to channel Inventory by checking the header.Although inventory is Pollable so i have defined the Inbound adaptor which will to process the inventory messages.
So my question is why do we need Poller some extra pollar.
Reply With Quote
