camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chiodoni Andrea (JIRA)" <j...@apache.org>
Subject [jira] Closed: (CAMEL-2872) camel-amqp not receiving messages
Date Fri, 02 Jul 2010 08:28:51 GMT

     [ 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.


Mime
View raw message