[
https://issues.apache.org/jira/browse/CAMEL-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167846#comment-17167846
]
Devansh Arora commented on CAMEL-15355:
---------------------------------------
[~acosentino]
i tried using it like
&args=arg.queue.x-single-active-consumer=true
getting NPE
Caused by: java.lang.NullPointerException: nullaused by:
java.lang.NullPointerException: null at
org.apache.camel.util.PropertiesHelper.extractProperties(PropertiesHelper.java:33)
~[camel-util-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQEndpoint.getExchangeArgs(RabbitMQEndpoint.java:825)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.resolvedExchangeArguments(RabbitMQDeclareSupport.java:101)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.declareAndBindExchangeWithQueue(RabbitMQDeclareSupport.java:49)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.declareAndBindExchangesAndQueuesUsing(RabbitMQDeclareSupport.java:36)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQEndpoint.declareExchangeAndQueue(RabbitMQEndpoint.java:244)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitConsumer.openChannel(RabbitConsumer.java:353)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitConsumer.<init>(RabbitConsumer.java:59)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.createConsumer(RabbitMQConsumer.java:127)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.createConsumers(RabbitMQConsumer.java:99)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.doStart(RabbitMQConsumer.java:179)
~[camel-rabbitmq-3.4.0.jar:3.4.0] at
org.apache.camel.support.service.BaseService.start(BaseService.java:115)
~[camel-api-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:3025)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRouteConsumers(InternalRouteStartupManager.java:348)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartRouteConsumers(InternalRouteStartupManager.java:275)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:180)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.spring.boot.SpringBootCamelContext.doStart(SpringBootCamelContext.java:43)
~[camel-spring-boot-3.4.0.jar:3.4.0] at
org.apache.camel.support.service.BaseService.start(BaseService.java:115)
~[camel-api-3.4.0.jar:3.4.0] at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
~[camel-base-3.4.0.jar:3.4.0] at
org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:121)
~[camel-spring-3.4.0.jar:3.4.0]
> 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
> Priority: Minor
>
> 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)
