Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 56960 invoked from network); 21 May 2007 15:31:16 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 21 May 2007 15:31:16 -0000 Received: (qmail 75922 invoked by uid 500); 21 May 2007 15:31:21 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 75904 invoked by uid 500); 21 May 2007 15:31:21 -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 75895 invoked by uid 99); 21 May 2007 15:31:21 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 21 May 2007 08:31:21 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (herse.apache.org: domain of lists@nabble.com designates 216.139.236.158 as permitted sender) Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 21 May 2007 08:31:13 -0700 Received: from isper.nabble.com ([192.168.236.156]) by kuber.nabble.com with esmtp (Exim 4.63) (envelope-from ) id 1Hq9qW-0003Zr-7t for users@activemq.apache.org; Mon, 21 May 2007 08:30:52 -0700 Message-ID: <10721096.post@talk.nabble.com> Date: Mon, 21 May 2007 08:30:52 -0700 (PDT) From: Pravin Kundal To: users@activemq.apache.org Subject: RE: Implementation of multithreading model on CMS ActiveMQ In-Reply-To: <7743F17344E95A4CA78A3E53A7AF496B0103A513@corpatsmail1.corp.sensis.com> MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-From: pravin_kundal@persistent.co.in References: <10718189.post@talk.nabble.com> <7743F17344E95A4CA78A3E53A7AF496B0103A511@corpatsmail1.corp.sensis.com> <10720173.post@talk.nabble.com> <7743F17344E95A4CA78A3E53A7AF496B0103A513@corpatsmail1.corp.sensis.com> X-Virus-Checked: Checked by ClamAV on apache.org I couldn't access the link below. Is it the same example that Apache-ActiveMQ ship with the CMS library? Thanks a lot. Mittler, Nathan wrote: > > >> >> In the case I will need to implement the concurrency control >> over the session, so that only one thread can use the >> session, as sessions are implemented for serial use? Rght? > > Yes, you should add your own concurrency control for the session. > >> >> I tried the first case in which i implemented the >> multithreading, each thread running its own session and each >> session having one producer. But the results were not even >> close to our requriment (result in msges/sec). >> > > Were you using openwire or stomp as the protocol? We have seen cases > where small messages with openwire cause extra delay due to the naggle > algorithm and that message footprints are smaller than their stomp > counterpart. If you're using openwire, I suggest you switch over to > stomp and see if you have different results. If that does the trick, > our next release will allow a user-specified TCP-NODELAY socket option > that should fix the problem for openwire (for small messages). > >> Do you think the other case can give us the better results >> (i.e. "The ActiveMQ-CPP implementation, however, will allow >> you to share a session across threads.") >> > > Without understanding your particular usage of the client, I would guess > that a different usage wouldn't help much. Just to make sure, however, > you could slightly modify our example application > https://svn.apache.org/repos/asf/activemq/activemq-cpp/trunk/src/example > s/main.cpp and see if you can get it to meet your requirements. > > > Regards, > Nate > > -- View this message in context: http://www.nabble.com/Implementation-of-multithreading-model-on-CMS-ActiveMQ-tf3790047s2354.html#a10721096 Sent from the ActiveMQ - User mailing list archive at Nabble.com.