You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by "Chiodoni Andrea (JIRA)" <ji...@apache.org> on 2010/07/02 10:28:51 UTC
[jira] Closed: (CAMEL-2872) camel-amqp not receiving messages
[ 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:********@wcwe00iu.local1277754493315/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:********@wcwe00iu.local1277754493315/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.