[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