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 18:37:00 UTC
[jira] [Commented] (PROTON-2264) How to set "activemq.prefetchSize"
header with ruby-binding?
[ https://issues.apache.org/jira/browse/PROTON-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177248#comment-17177248 ]
Kiza commented on PROTON-2264:
------------------------------
Thank you. I will use mailing list next time instead.
> How to set "activemq.prefetchSize" header 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, where I need to set "activemq.prefetchSize" to 1. 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