You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@karaf.apache.org by "Ondrej Mrekaj (Jira)" <ji...@apache.org> on 2024/06/19 12:11:00 UTC
[jira] [Updated] (KARAF-7842) How to set exclusive consumer for ws connector?

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

Ondrej Mrekaj updated KARAF-7842:
---------------------------------
    Description: 
Hello,

I attempted to edit the {{broker.xml}} file as follows:
{code:java}
    <destinationPolicy>
      <policyMap>
        <policyEntries>
          <policyEntry queue=">" allConsumersExclusiveByDefault="true"/>
        </policyEntries>
      </policyMap>
    </destinationPolicy> {code}
Additionally, I modified the connection string by adding {{{}?consumer.exclusive=true{}}}, so it now looks like this:

 
{code:java}
wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
However, the {{Exclusive}} attribute is still being set to {{{}false{}}}. What might be causing this issue?

I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client connects using the WebSocket protocol.

Thank you.

  was:
Hello,

I attempted to edit the {{broker.xml}} file as follows:
{code:java}
    <destinationPolicy>
      <policyMap>
        <policyEntries>
          <policyEntry queue=">" allConsumersExclusiveByDefault="true"/>
        </policyEntries>
      </policyMap>
    </destinationPolicy> {code}

Additionally, I modified the connection string by adding {{{}?consumer.exclusive=true{}}}, so it now looks like this:

 
{code:java}
wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
However, the {{Exclusive}} attribute is still being set to {{{}false{}}}. What might be causing this issue?

I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client connects using the WebSocket protocol.

Thank you.

 

 

 


> How to set exclusive consumer for ws connector?
> -----------------------------------------------
>
>                 Key: KARAF-7842
>                 URL: https://issues.apache.org/jira/browse/KARAF-7842
>             Project: Karaf
>          Issue Type: Question
>         Environment: ActiveMQ versions 5.15.3 and 5.18.3.
>            Reporter: Ondrej Mrekaj
>            Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>     <destinationPolicy>
>       <policyMap>
>         <policyEntries>
>           <policyEntry queue=">" allConsumersExclusiveByDefault="true"/>
>         </policyEntries>
>       </policyMap>
>     </destinationPolicy> {code}
> Additionally, I modified the connection string by adding {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>  
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}. What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client connects using the WebSocket protocol.
> Thank you.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)