camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Not able to connect Oracle queue endpoint
Date Wed, 10 Nov 2010 16:13:12 GMT
Hi

You got this error
Caused by: java.lang.AbstractMethodError:
oracle.jms.AQjmsQueueConnectionFactory.createConnection(Lj
ava/lang/String;Ljava/lang/String;)Ljavax/jms/Connection;

Maybe try googling a bit. And there has been several posts at Camel
mailing list about how to use Camel with OracleAQ.
Mind that you may have to use Camel 2.4 or better because we have
fixed a couple of issues with OracleAQ not allows some API call in
JMX.



On Wed, Nov 10, 2010 at 3:19 PM, hraviprakash
<raviprakash.hariramrao@asia.xchanging.com> wrote:
>
> Hi,
>
> I want to poll a FTP Server and push the file to oracle queue. I use spring
> configuration and on while running I am getting the below error.  Please let
> me know whether the camel configurations are correct and let me know where
> its breaking.
> <p/>
> My pom.xml includes following libraries camel-core, camel-spring,
> activemq-camel, xbean-spring, camel-ftp, camel-jms, junit, commons-logging,
> log4j, ojdbc14, aqapi13, spring and orai18n
> <p/>
> My configurations are as <p/>
> <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.xsd">
>
>  <camelContext xmlns="http://camel.apache.org/schema/spring">
>    <package>org.fusesource.camel</package>
>    <route id="test">
>            <from
> uri="ftp://ravi@vmswinserver/ravi?password=ravi&amp;binary=true&amp;consumer.delay=60000"/>
>            <to uri="oracleQueue:queue:RAVI_TEST_Q"/>
>        </route>
>  </camelContext>
>
>        <!-- without the following bean instantiation, we will get an
> oracle.jms.AQjmsException with each and every received message -->
>    <bean id="requiredBeanForOracleAq"
> class="org.apache.activemq.ActiveMQConnectionFactory" />
>
>    <bean id="connectionFactoryOracleAQQueue"
> class="oracle.jms.AQjmsFactory" factory-method="getQueueConnectionFactory">
>        <constructor-arg index="0">
>            <value>jdbc:oracle:thin:@172.29.174.51:1521:vmsoff</value>
>        </constructor-arg>
>        <constructor-arg index="1" type="java.util.Properties">
>            <value></value>
>        </constructor-arg>
>    </bean>
>
>    <bean id="oracleQueueCredentials"
> class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
>        <property name="targetConnectionFactory">
>            <ref bean="connectionFactoryOracleAQQueue" />
>        </property>
>        <property name="username">
>            <value>ravi</value>
>        </property>
>        <property name="password">
>            <value>ravi</value>
>        </property>
>    </bean>
>
>    <bean id="message_converter"
> class="org.springframework.jms.support.converter.SimpleMessageConverter102"/>
>
>    <bean id="oracleQueue"
> class="org.apache.camel.component.jms.JmsComponent">
>        <property name="connectionFactory" ref="oracleQueueCredentials" />
>        <property name="messageConverter"
> ref="message_converter"></property>
>   </bean>
>
> </beans>
> <p/>Exceptions<p/>
> SEVERE: Caused by: [org.apache.camel.CamelExecutionException - Exception
> occurred during execution o
> n the exchange: Exchange[GenericFileMessage with file:
> GenericFile[publish.JPG]]]
> org.apache.camel.CamelExecutionException: Exception occurred during
> execution on the exchange: Excha
> nge[GenericFileMessage with file: GenericFile[publish.JPG]]
>        at
> org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1142)
>        at
> org.apache.camel.impl.DefaultExchange.setException(DefaultExchange.java:263)
>        at
> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBrid
> ge.process(AsyncProcessorTypeConverter.java:53)
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
>        at
> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)
>        at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)
>        at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java
> :98)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
>
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.jav
> a:68)
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java
> :98)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
>
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99)
>
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java
> :98)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
>
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.jav
> a:68)
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHand
> ler.java:290)
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:202
> )
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:256)
>        at
> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:99)
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java
> :98)
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
>
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.jav
> a:68)
>        at
> org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.j
> ava:313)
>        at
> org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java
> :144)
>        at
> org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:110)
>        at
> org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:98)
>        at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
>        at
> java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
>        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Scheduled
> ThreadPoolExecutor.java:98)
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Schedule
> dThreadPoolExecutor.java:181)
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadP
> oolExecutor.java:205)
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>        at java.lang.Thread.run(Thread.java:619)
> Caused by: java.lang.AbstractMethodError:
> oracle.jms.AQjmsQueueConnectionFactory.createConnection(Lj
> ava/lang/String;Ljava/lang/String;)Ljavax/jms/Connection;
>        at
> org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter.doCreateConnec
> tion(UserCredentialsConnectionFactoryAdapter.java:175)
>        at
> org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter.createConnecti
> on(UserCredentialsConnectionFactoryAdapter.java:150)
>        at
> org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:184)
>        at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:456)
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.ja
> va:195)
>        at
> org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:375)
>        at
> org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:320)
>        at
> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:150)
>        at
> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBrid
> ge.process(AsyncProcessorTypeConverter.java:50)
>        ... 38 more
> --
> View this message in context: http://camel.465427.n5.nabble.com/Not-able-to-connect-Oracle-queue-endpoint-tp3258725p3258725.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Mime
View raw message