[
https://issues.apache.org/jira/browse/CAMEL-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13804081#comment-13804081
]
Dmytro Puzhay commented on CAMEL-6844:
--------------------------------------
Hey, I don't believe the bug is minor, it effectively prevents from using
polling consumer for AMQPComponent, as it is impossible to do error handling
without PollingConsumerPollStrategy.
> Add PollingConsumerPollStrategy option to AMQPComponent
> -------------------------------------------------------
>
> Key: CAMEL-6844
> URL: https://issues.apache.org/jira/browse/CAMEL-6844
> Project: Camel
> Issue Type: Improvement
> Components: camel-amqp
> Reporter: Dmytro Puzhay
>
> 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
--
This message was sent by Atlassian JIRA
(v6.1#6144)
