camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Syed <ssigabud...@qatarairways.com.qa>
Subject Failed to connect using Camel + RabbitMq Configuration
Date Sun, 21 Oct 2012 19:21:05 GMT
Hi, 

I am using the below specification, I am not able to establish connection
with RabbitMQ using the below configuration. 

Set the VM arguments -Dqpid.dest_syntax=BURL -Dqpid.amqp.version=0-91 

Camel - 2.10.0 
RabbitMQ 2.8.5 
QPID Client - 0.16 

Camel Configuration 
------------------------- 

        <bean id="amqp"
class="org.apache.camel.component.amqp.AMQPComponent">
        <property name="connectionFactory">
                <bean class="org.apache.qpid.client.AMQConnectionFactory">
                <constructor-arg index="0" type="java.lang.String" 
                       
value="amqp://guest:guest@host/?brokerlist='tcp://localhost:5672'" />
                </bean>
        </property>
        </bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
                <route>
                        <from uri="amqp:queue:Master" />
                        <to
uri="file:D:/delete/?fileName=mydata-${date:now:yyyyMMddhhmmssSSS}.txt" />
                </route>
        </camelContext>

Camel Console Log 
------------------------ 

12/10/21 21:32:27 INFO client.AMQConnection:
Connection:amqp://guest:********@host/?brokerlist='tcp://localhost:5672' 
12/10/21 21:32:27 INFO protocol.AMQProtocolSession: Using ProtocolVersion
for Session:0-91 
12/10/21 21:32:27 INFO handler.ClientMethodDispatcherImpl: New Method
Dispatcher:AMQProtocolSession[null] 
12/10/21 21:32:27 INFO client.AMQConnection: Connecting with ProtocolHandler
Version:0-91 
12/10/21 21:32:27 INFO state.StateWaiter: New StateWaiter :AMQState: id = 1
name: CONNECTION_NOT_STARTED:[AMQState: id = 4 name: CONNECTION_OPEN,
AMQState: id = 6 name: CONNECTION_CLOSED] 
12/10/21 21:32:27 INFO protocol.AMQProtocolSession: Setting ProtocolVersion
to :0-91 
12/10/21 21:32:27 INFO handler.ClientMethodDispatcherImpl: New Method
Dispatcher:AMQProtocolSession[AMQConnection: 
Host: localhost 
Port: 5672 
Virtual Host: 
Client ID: host 
Active session count: 0] 
12/10/21 21:32:27 INFO security.DynamicSaslRegistrar: Additional SASL
providers successfully registered. 
12/10/21 21:32:27 INFO security.CallbackHandlerRegistry: Callback handlers
available for SASL mechanisms: [EXTERNAL, GSSAPI, CRAM-MD5-HASHED, CRAM-MD5,
AMQPLAIN, PLAIN, ANONYMOUS] 
12/10/21 21:32:27 INFO client.AMQConnection: Connected with ProtocolHandler
Version:0-91 
12/10/21 21:32:27 INFO spring.SpringCamelContext: Route: route1 started and
consuming from: Endpoint[amqp://queue:Master] 
12/10/21 21:32:27 INFO spring.SpringCamelContext: Total 1 routes, of which 1
is started. 
12/10/21 21:32:27 INFO spring.SpringCamelContext: Apache Camel 2.10.0
(CamelContext: camel-1) started in 1.000 seconds 
12/10/21 21:32:27 INFO client.AMQSession: Created
session:org.apache.qpid.client.AMQSession_0_8@13e9934 

Rabbit MQ Log 
------------------ 
=INFO REPORT==== 21-Oct-2012::21:32:27 === 
accepting AMQP connection <0.783.0> (127.0.0.1:3917 -> 127.0.0.1:5672) 

=WARNING REPORT==== 21-Oct-2012::21:32:28 === 
closing AMQP connection <0.783.0> (127.0.0.1:3917 -> 127.0.0.1:5672): 
connection_closed_abruptly 

Kindly let me know what needs to be done.. 

Thanks & REgards 
Jawahar 



--
View this message in context: http://camel.465427.n5.nabble.com/Failed-to-connect-using-Camel-RabbitMq-Configuration-tp5721351.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message