camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dmytro Puzhay (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CAMEL-6844) Add PollingConsumerPollStrategy option to AMQPComponent
Date Thu, 24 Oct 2013 11:31:01 GMT

     [ https://issues.apache.org/jira/browse/CAMEL-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Dmytro Puzhay updated CAMEL-6844:
---------------------------------

    Priority: Major  (was: Minor)

> 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)

Mime
View raw message