camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dmytro Puzhay (JIRA)" <>
Subject [jira] [Created] (CAMEL-6844) Add PollingConsumerPollStrategy option to AMQPComponent
Date Wed, 09 Oct 2013 12:20:43 GMT
Dmytro Puzhay created CAMEL-6844:

             Summary: Add PollingConsumerPollStrategy option to AMQPComponent
                 Key: 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" (

= 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(
        at org.apache.camel.impl.DefaultComponent.createEndpoint(

= 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

View raw message