Spring Integration - Attribute 'channel' must appear on element 'int-jdbc:inbound-channel-adapter'

[vijay bharath]

Hi,

I am new to the spring integration, doing practice at my local pc. I am trying to create a program, which get data from db(Oracle) and show them in the console using inbound adapter, but getting below error. Kindly help me to short out this issue. Enclosed error as well as configuration xml.


Feb 28, 2016 10:27:07 AM org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [jdbcInboundApplicationContext.xml]
Exception in thread "main" org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 12 in XML document from class path resource
[jdbcInboundApplicationContext.xml] is invalid; nested exception is org.xml.sax.SAXParseException; lineNumber: 12; columnNumber: 110; cvc-complex-type.4:
Attribute 'channel' must appear on element 'int-jdbc:inbound-channel-adapter'.

at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:399)
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:336)
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:304)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:181)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:217)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:188)
at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:252)
at org.springframework.context.support.AbstractXmlApplicationContext.loadBeanDefinitions(AbstractXmlApplicationContext.java:127)
at org.springframework.context.support.AbstractXmlApplicationContext.loadBeanDefinitions(AbstractXmlApplicationContext.java:93)
at org.springframework.context.support.AbstractRefreshableApplicationContext.refreshBeanFactory(AbstractRefreshableApplicationContext.java:129)
at org.springframework.context.support.AbstractApplicationContext.obtainFreshBeanFactory(AbstractApplicationContext.java:537)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:452)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:83)
at com.javarticles.spring.integration.jdbc.SpringIntegrationJdbcInboundExample.main(SpringIntegrationJdbcInboundExample.java:16)

Configuration 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" 
	xmlns:int="http://www.springframework.org/schema/integration"	
	xmlns:jdbc="http://www.springframework.org/schema/jdbc" 
	xmlns:int-jdbc="http://www.springframework.org/schema/integration/jdbc"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:p="http://www.springframework.org/schema/p"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
                           http://www.springframework.org/schema/beans/spring-beans.xsd 
                           http://www.springframework.org/schema/integration
                           http://www.springframework.org/schema/integration/spring-integration.xsd 
                           http://www.springframework.org/schema/integration/jdbc 
                           http://www.springframework.org/schema/integration/jdbc/spring-integration-jdbc.xsd 
                           http://www.springframework.org/schema/jdbc 
                           http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd">

	<int-jdbc:inbound-channel-adapter id="dataChannel"
		query="SELECT STUDENT_ID,STUDENT_NAME FROM STUDENTS S WHERE S.STUDENT_ID=1" data-source="dataSource" />

	<int:channel id="dataChannel">
		<int:queue />
	</int:channel>

	<bean id="dataSource"
		class="org.springframework.jdbc.datasource.DriverManagerDataSource">
		<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
		<property name="url" value="jdbc:oracle:thin:@localhost:1521:ORCL" />
		<property name="username" value="#####" />
		<property name="password" value="#####" />
	</bean>
</beans>

[Karthik Shiraly]

Welcome to CodeRanch!

As the error says, the bean is missing a 'channel' attribute. How will Spring know which channel to attach this adapter to, if it's not specified?
'id' is an identifier given to every bean, and should be unique.
So you should have something like this:

 <int-jdbc:inbound-channel-adapter channel="dataChannel" id="dataChannelAdapter"
        query="SELECT STUDENT_ID,STUDENT_NAME FROM STUDENTS S WHERE S.STUDENT_ID=1" data-source="dataSource" />

[vijay bharath]

Hi,

Thanks, now It is working.

I am facing another error. Kindly help me to fix on this. Enclosed error and sample code.

Error :
Exception in thread "main" java.lang.ClassCastException: org.springframework.integration.channel.QueueChannel cannot be cast to org.springframework.messaging.PollableChannel
org.springframework.integration.MessageDeliveryException: failed to send message to channel 'dataChannel' within timeout: -1

Code :

lic static void main(String[] args) throws InterruptedException, IOException, SQLException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                "jdbcInboundApplicationContext.xml");
        try {            
            PollableChannel pollableChannel = (PollableChannel) context.getBean("dataChannel");
            Message<List<Map<String, Object>>> msg = (Message<List<Map<String, Object>>>) pollableChannel.receive(1000);
            List<Map<String, Object>> rows = msg.getPayload();
            for (Map<String, Object> row : rows) {
                ...
            }
        } finally {
            context.close();
        }

[Karthik Shiraly]

Check if your classpath has multiple versions or copies of the same spring JARs.

[And henceforth please enclose any code snippets you put here inside code tags - https://coderanch.com/t/659781/Wiki/Code-Tags explains how to do this]