[
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: [email protected]
For additional commands, e-mail: [email protected]
