Dmytro Puzhay created CAMEL-6844:
------------------------------------
Summary: Add PollingConsumerPollStrategy option to AMQPComponent
Key: CAMEL-6844
URL: https://issues.apache.org/jira/browse/CAMEL-6844
Project: Camel
Issue Type: Bug
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)
