You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Kiza (Jira)" <ji...@apache.org> on 2020/08/13 17:50:00 UTC
[jira] [Updated] (PROTON-2264) How to set "activemq.prefetchSize"
header and other customer headers with ruby-binding?
[ https://issues.apache.org/jira/browse/PROTON-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kiza updated PROTON-2264:
-------------------------
Summary: How to set "activemq.prefetchSize" header and other customer headers with ruby-binding? (was: How to set "activemq.prefetchSize" header with ruby-binding?)
> How to set "activemq.prefetchSize" header and other customer headers with ruby-binding?
> ---------------------------------------------------------------------------------------
>
> Key: PROTON-2264
> URL: https://issues.apache.org/jira/browse/PROTON-2264
> Project: Qpid Proton
> Issue Type: Bug
> Components: ruby-binding
> Reporter: Kiza
> Assignee: Alan Conway
> Priority: Trivial
>
> Not a bug, more like a question. But I cannot find a "question" issue type.
> When open a receiver to an address, how to set "activemq.prefetchSize" header?
> {code:ruby}
> def on_container_start(container)
> ssl_domain = nil
> if @use_ssl
> ssl_domain = Qpid::Proton::SSLDomain.new(Qpid::Proton::SSLDomain::MODE_CLIENT)
> end
> conn = container.connect(@url, user:@user, password:@password, ssl_domain:ssl_domain)
>
> conn.open_receiver(@address)
> end
> {code}
> I am using ActiveMQ v5.15.12 for the message broker.
> I want to implement competing consumers pattern. With default prefetch size, ActiveMQ will dispatch the messages to the consumers in a round-roubin manner till the prefetch space is full.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org