Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4F6BCC2AC for ; Tue, 18 Jun 2013 20:08:19 +0000 (UTC) Received: (qmail 26135 invoked by uid 500); 18 Jun 2013 20:08:18 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 26100 invoked by uid 500); 18 Jun 2013 20:08:18 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 26092 invoked by uid 99); 18 Jun 2013 20:08:18 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Jun 2013 20:08:18 +0000 X-ASF-Spam-Status: No, hits=1.3 required=5.0 tests=URI_HEX X-Spam-Check-By: apache.org Received-SPF: error (athena.apache.org: local policy) Received: from [216.139.250.139] (HELO joe.nabble.com) (216.139.250.139) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Jun 2013 20:08:14 +0000 Received: from [192.168.236.139] (helo=joe.nabble.com) by joe.nabble.com with esmtp (Exim 4.72) (envelope-from ) id 1Up2BI-0007s1-29 for users@activemq.apache.org; Tue, 18 Jun 2013 13:07:08 -0700 Date: Tue, 18 Jun 2013 13:06:53 -0700 (PDT) From: Ethan Winograd To: users@activemq.apache.org Message-ID: <1371586013039-4668332.post@n4.nabble.com> In-Reply-To: <1371479694661-4668250.post@n4.nabble.com> References: <1371479694661-4668250.post@n4.nabble.com> Subject: Re: prefetch size variations with nms connections MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org ok I realized what we were doing wrong... Instead of creating a consumer from an IQueue I was creating it from an IDestination, which was not seeing the query params I was setting. This page helped: http://activemq.apache.org/nms/activemq-destination-options.html So rather than doing: IMessageConsumer _consumer = _session.CreateConsumer (_destination); I switched it to IMessageConsumer _consumer = _session.CreateConsumer(queueWithParams); using a string made of queueName?params -- View this message in context: http://activemq.2283324.n4.nabble.com/prefetch-size-variations-with-nms-connections-tp4668250p4668332.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.