How to set QPID parameters (e.g. durable=true) to Camel AMQPComponent?

[Ondrej_Fialka <on...@gmail.com>]

Hello, 
Can I ask for help, please?

I use Camel to route messages between various email, ftp and web service
endpoints. I want to add AMQP support as well. Recently I use RabbitMQ but I
want the application to handle any AMQP 0.9.1 broker. 

The problem is I did nor find any way how to set parameters like
/durable=true/ to the AMQPComponent. I know QPID can use these parameters,
but don't know how to pass them from Camel to QPID.
If I want to connect to a durable queue it fails on incompatible parameters.
This is because AMQP Component is inherited from JMSComponent and this
component does not accept the necessary parameters.

I construct the connection dynamically as Spring bean from configuration
file (this works):

/
String CONNECTION_STRING = "amqp://%s:%s@%s/%s?brokerlist='tcp://%s:%s'";

...

amqpFactoryName = "amqConnectionFactory-" + code;
		endpointPrefix = "amqp-" + code;

constructorArguments.addIndexedArgumentValue(0, connectionString,
"java.lang.String");
	
amqpConnectionFactoryBeanDefinition.setConstructorArgumentValues(constructorArguments);		
		amqpConnectionFactoryBeanDefinition.setAutowireCandidate(true);
		registry.registerBeanDefinition(amqpFactoryName,
amqpConnectionFactoryBeanDefinition);	
		
		GenericBeanDefinition amqpComponenetBeanDefinition = new
GenericBeanDefinition();
		amqpComponenetBeanDefinition.setBeanClass(AMQPComponent.class);
		amqpComponenetBeanDefinition.setAutowireCandidate(true);
		
		MutablePropertyValues values = new MutablePropertyValues();
		values.addPropertyValue("connectionFactory", new
RuntimeBeanReference(amqpFactoryName)); 		
		amqpComponenetBeanDefinition.setPropertyValues(values);
		
		registry.registerBeanDefinition(endpointPrefix,
amqpComponenetBeanDefinition);/

The Camel route is defined like this:

/from("amqp-in://BURL:direct://amq.direct//MyQueue")
.to(...)/
This works well. But if the queue I want to connect to is durable, I tried: 

/amqp-in://BURL:direct://amq.direct//MyQueue?durable=true/

this fails:
/Failed to resolve endpoint:
amqp-IN://BURL:direct://amq.direct//MyQueue?durable=true  There are 1
parameters that couldn't be set on the endpoint. Check the uri if the
parameters are spelt correctly and that they are properties of the endpoint.
Unknown parameters=[{durable=true}]/

I found out why it fails, but don't know how to make it work.

Is there any way to set the paramaters to the underlying QPID component? Or
a different way to solve this? As I sad, I would like to use generic AMQP
approach, not just RabbitMQ.

Thank you, any help is appreciated.

Ondrej




--
View this message in context: http://camel.465427.n5.nabble.com/How-to-set-QPID-parameters-e-g-durable-true-to-Camel-AMQPComponent-tp5757266.html
Sent from the Camel - Users mailing list archive at Nabble.com.