[
https://issues.apache.org/activemq/browse/CAMEL-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiodoni Andrea closed CAMEL-2872.
----------------------------------
Resolution: Won't Fix
Posted on the mailing list
> 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.