[rabbitmq-discuss] Apache Camel + RabbitMQ Configuration.
Syed
ssigabudeen at qatarairways.com.qa
Sun Oct 21 20:07:47 BST 2012
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
RabbitMQ 2.8.5
Camel - 2.10.0
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 at 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://rabbitmq.1065348.n5.nabble.com/Apache-Camel-RabbitMQ-Configuration-tp22739.html
Sent from the RabbitMQ mailing list archive at Nabble.com.
More information about the rabbitmq-discuss
mailing list