[
https://issues.apache.org/jira/browse/CAMEL-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167907#comment-17167907
]
Devansh Arora edited comment on CAMEL-15355 at 7/30/20, 1:15 PM:
-----------------------------------------------------------------
previously we were using camel-rabbitmq 2.24.x, then we could configure
arguments like
*public class QueueArgsSACConfigurer implements ArgsConfigurer {*
*@Override*
*public void configurArgs(Map<String, Object> map) \{ map.put("x-max-priority",
3); map.put("x-single-active-consumer", true); }*
*}*
and in endpoint url we could add this bean definition
it used to work fine then.
but in camel-rabbitmq 3.x ArgsConfigurer was deprecated.
and we then we switched to endpoint url based args and found this prblm
was (Author: [email protected]):
previously we were using camel-rabbitmq 2.24.x, then we could configure
arguments like
*public class QueueArgsSACConfigurer implements ArgsConfigurer {*
*@Override*
*public void configurArgs(Map<String, Object> map) \{ map.put("x-max-priority",
3); map.put("x-single-active-consumer", true); }*
*}*
and in endpoint url we could add this bean definition
it used to work fine then.
but in camel-rabbitmq 3.x ArgsConfigurer was deprecated.
> unacceptable_type,longstr error if we set
> 'arg.queue.x-single-active-consumer=true in rabbitmq endpoint url
> ------------------------------------------------------------------------------------------------------------
>
> Key: CAMEL-15355
> URL: https://issues.apache.org/jira/browse/CAMEL-15355
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 3.4.0
> Reporter: Devansh Arora
> Assignee: Claus Ibsen
> Priority: Minor
> Fix For: 3.5.0, 3.4.3
>
>
> We are using camel-rabbitmq to create a single-active-consumer.
> to create a single active consumer we need to give a queue arg in endpoint
> uri as
> *&arg.queue.x-single-active-consumer=true*
> We get error below error if we set this argument
> Caused by: com.rabbitmq.client.ShutdownSignalException: channel error;
> protocol method: #method<channel.close>(reply-code=406,
> reply-text=PRECONDITION_FAILED - invalid arg 'x-single-active-consumer' for
> queue 'testQ4' in vhost 'vh1': {*unacceptable_type,longstr*}, class-id=50,
> method-id=10)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
