[CAMEL-6844] Add PollingConsumerPollStrategy option to AMQPComponent

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Component/s: camel-amqp
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Dmytro Puzhay
• Created: 09/Oct/13 12:20
• Updated: 05/May/16 17:05
• Resolved: 05/May/16 17:05

Description

I try to use my custom PollingConsumerPollStrategy for AMQPComponent endpoint, but my enpoint can't be created. Answer from Claus Ibsen on the forum was "That option is not supported on amqpcomponent" (http://camel.465427.n5.nabble.com/PollingConsumerPollStrategy-for-AMQPComponent-endpoint-td5740198.html)

= Exception =

Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: amqp:queue:broadcast.MY_QUEUE?pollStrategy=%23MyPollingConsumerPollStrategy due to: 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=[

{pollStrategy=#MyPollingConsumerPollStrategy}

]
at org.apache.camel.impl.DefaultComponent.validateParameters(DefaultComponent.java:148)
at org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:105)

= In my RouteBuilder =

JndiRegistry registry = (JndiRegistry) ((PropertyPlaceholderDelegateRegistry) getContext().getRegistry()).getRegistry();

registry.bind(LoaderPollingConsumerPollStrategy.class.getSimpleName(), new MyPollingConsumerPollStrategy());

(AMQPComponent) AMQPComponent.amqpComponent("My AMQP broker URI");

Endpoint amqpEndpoint = this.amqpComponent.createEndpoint("amqp:queue:broadcast.MY_QUEUE?pollStrategy=#MyPollingConsumerPollStrategy"); // ResolveEndpointFailedException here