Return-Path: 
 <users-return-46669-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
X-Original-To: apmail-camel-users-archive@www.apache.org
Delivered-To: apmail-camel-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 941C610484
	for <apmail-camel-users-archive@www.apache.org>;
 Tue,  4 Feb 2014 17:39:10 +0000 (UTC)
Received: (qmail 87292 invoked by uid 500); 4 Feb 2014 17:39:09 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 87226 invoked by uid 500); 4 Feb 2014 17:39:09 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Received: (qmail 87218 invoked by uid 99); 4 Feb 2014 17:39:09 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 04 Feb 2014 17:39:09 +0000
X-ASF-Spam-Status: No, hits=-0.0 required=5.0
	tests=SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of joshua.watkins@gamesys.co.uk
 designates 93.93.84.17 as permitted sender)
Received: from [93.93.84.17] (HELO mx01.gamesys.co.uk) (93.93.84.17)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 04 Feb 2014 17:39:04 +0000
Received: from LDNEX12.Gamesys.corp (unknown [10.224.130.13])
	by mx01.gamesys.co.uk (Postfix) with ESMTP id E62A4CBA20
	for <users@camel.apache.org>; Tue,  4 Feb 2014 17:38:43 +0000 (UTC)
Received: from LDNEX22.Gamesys.corp ([169.254.4.64]) by LDNEX12.Gamesys.corp
 ([::1]) with mapi id 14.03.0174.001; Tue, 4 Feb 2014 17:38:43 +0000
From: Joshua Watkins <joshua.watkins@gamesys.co.uk>
To: "users@camel.apache.org" <users@camel.apache.org>
Subject: Re: Consumer distribituion over connections
Thread-Topic: Consumer distribituion over connections
Thread-Index: AQHPHg/8+vIuAfywpEyhnrR/bSgftJqlY8KA
Date: Tue, 4 Feb 2014 17:38:43 +0000
Message-ID: <CF16D530.48428%joshua.watkins@gamesys.co.uk>
In-Reply-To: <CF107AE3.472BE%joshua.watkins@gamesys.co.uk>
Accept-Language: en-US, en-GB
Content-Language: en-US
X-MS-Has-Attach: 
X-MS-TNEF-Correlator: 
user-agent: Microsoft-MacOutlook/14.12.0.110505
x-originating-ip: [10.224.196.10]
x-exclaimer-md-config: 082f0562-b41b-471a-8bd8-7031576410b5
Content-Type: text/plain; charset="us-ascii"
Content-ID: <3995E3316711414D901B52D664A27CDE@gamesys.co.uk>
Content-Transfer-Encoding: quoted-printable
MIME-Version: 1.0
X-Virus-Checked: Checked by ClamAV on apache.org

No one have any ideas on this?

I was thinking that I could up the max connections to something higher and
then setting the maximum number of active sessions per connection on the
PooledConnectionFactory. I don't really like this solution though as it
leads to an issue when you hit that max.



On 30/01/2014 23:06, "Joshua Watkins" <joshua.watkins@gamesys.co.uk> wrote:

>
>I am looking for a bit of advice. I have been trying to get a better
>balance of consumer per connection but have run into a bit of a sticky
>situation.
>
>So while using the AMQ 5.8 and the AMQ PooledConnectionFactory[1], I was
>setting my camel routes with Cache_None to enable more connections from
>the pool to be used. In addition to that I am using DMLC session
>transactions to ensure messages are properly consumed.[2] Unfortunately
>this has the side effect of spamming the Consumer advisory topics because
>consumers are only used after consuming a single message. Is there an
>easier way to get a better consumer distribution on connections without
>this side effect?
>
>
>Thanks,
>Josh
>
>
>
>1. PooledConnectionFactory config:
><bean id=3D"connectionFactory"
>class=3D"org.apache.activemq.pool.PooledConnectionFactory"
>init-method=3D"start" destroy-method=3D"stop">
>		<constructor-arg ref=3D"amqConnectionFactory" />
>		<property name=3D"maxConnections" value=3D"10" />
>		<property name=3D"idleTimeout" value=3D"0"/> (0 to deal with AMQ-4366)
>	</bean>
>
>
>
>2. Camel config:
>cacheLevelName=3DCACHE_NONE
>transacted=3Dtrue
>lazyCreateTransactionManager=3Dfalse
>replyToDeliveryPersistent=3Dfalse
>acknowledgementModeName=3DCLIENT_ACKNOWLEDGE
>
>
>