camel-amqp not receiving messages
---------------------------------
Key: CAMEL-2872
URL: https://issues.apache.org/activemq/browse/CAMEL-2872
Project: Apache Camel
Issue Type: Test
Affects Versions: 2.3.0
Environment: mac, qpid 0.6, jdk 1.6
Reporter: Chiodoni Andrea
I'm currently testing camel with AMQP (qpid 0.6 on mac).
I see messages on the queue (using jmx) I see camel connecting as a consumer to
the desired amqp queue (using jmx I see the number of consumers increasing when
I start camel) but messages does not get into the camel route. Here my camel
setup
<bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
<property name="connectionFactory">
<bean class="org.apache.qpid.client.AMQConnectionFactory">
<property name="connectionURLString"
value="amqp://guest:guest@/localhost?brokerlist='tcp://localhost:5672'" />
</bean>
</property>
</bean>
<route id="test-amqp">
<from uri="amqp:queue:test" />
<to uri="file:target/events" />
</route>
I'm using camel 2.3 on JDK 1.6 (mac).
When I start camel (with mvn camel:run) I get the following log entries:
31 [org.apache.camel.spring.Main.main()] INFO
org.apache.qpid.jms.failover.FailoverSingleServer - No delay between connect
retries, use tcp://host:port?connectdelay='value' to enable.
47 [org.apache.camel.spring.Main.main()] INFO
org.apache.qpid.client.AMQConnection -
Connection:amqp://guest:*****[email protected]/localhost?brokerlist='tcp://localhost:5672'
144 [IoReceiver - localhost/127.0.0.1:5672] WARN
org.apache.qpid.transport.ClientDelegate - Ignoring the idle timeout 0 set by
the connection, using the brokers max value 65535
1825 [org.apache.camel.spring.Main.main()] INFO
org.apache.qpid.jms.failover.FailoverSingleServer - No delay between connect
retries, use tcp://host:port?connectdelay='value' to enable.
1826 [org.apache.camel.spring.Main.main()] INFO
org.apache.qpid.client.AMQConnection -
Connection:amqp://guest:*****[email protected]/localhost?brokerlist='tcp://localhost:5672'
1834 [IoReceiver - localhost/127.0.0.1:5672] WARN
org.apache.qpid.transport.ClientDelegate - Ignoring the idle timeout 0 set by
the connection, using the brokers max value 65535
1898 [DefaultMessageListenerContainer-1] INFO org.apache.qpid.client.AMQSession
- Prefetching delayed existing messages will not flow until requested via
receive*() or setML().
1909 [DefaultMessageListenerContainer-1] INFO
org.apache.qpid.client.AMQSession.Dispatcher - Dispatcher-Channel-1 created
1910 [Dispatcher-Channel-1] INFO org.apache.qpid.client.AMQSession.Dispatcher -
Dispatcher-Channel-1 started
Any help is welcome!
Thanks
Andrea
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
