You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Timothy A. Bish (Jira)" <ji...@apache.org> on 2020/08/13 18:10:00 UTC
[jira] [Closed] (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:all-tabpanel ]
Timothy A. Bish closed PROTON-2264.
-----------------------------------
Resolution: Invalid
Questions like this should be directed to the Qpid Users mailing list.
The ActiveMQ prefetch settings don't come into play for the AMQP based protocol clients as they offer credit to the broker which in turn dispatches up to that amount of messages if there is a pending backlog to dispatch from. You would offer a single credit for each of your consumers and refill as needed or some variation on that pattern depending on how much backlog you want. The broker dispatches in round robin fashion to all consumers on a given Queue.
> 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