Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 27924 invoked from network); 4 Aug 2009 08:18:00 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 4 Aug 2009 08:18:00 -0000 Received: (qmail 39316 invoked by uid 500); 4 Aug 2009 08:18:05 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 39255 invoked by uid 500); 4 Aug 2009 08:18:05 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 39245 invoked by uid 99); 4 Aug 2009 08:18:05 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 04 Aug 2009 08:18:05 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of willem.jiang@gmail.com designates 209.85.222.190 as permitted sender) Received: from [209.85.222.190] (HELO mail-pz0-f190.google.com) (209.85.222.190) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 04 Aug 2009 08:17:54 +0000 Received: by pzk28 with SMTP id 28so3017374pzk.11 for ; Tue, 04 Aug 2009 01:17:34 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:date:from :user-agent:mime-version:to:subject:references:in-reply-to :content-type:content-transfer-encoding; bh=pe9vw3u118neo8L1anPRdfXxhavWObspmxQ9srEIsH8=; b=cuh5xwYFLAk+OFCKUKWhHqpxlIL0kFAC3ZLQG9RtQjV+r/Ztn8IVluIrNPRxdQIKVK BiuyfgCkW96eaSd/18MYzRSviFZZTzlOfP6ohdB49NNA36l1sWav+I913rvV7uQGiFqZ zLZPfhwapHTcQ1hb4GUgJ4Zs3092USudyEVQE= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:date:from:user-agent:mime-version:to:subject:references :in-reply-to:content-type:content-transfer-encoding; b=Vx86PymSMOcKAaZU5a6xq3+G4JDMzIVsKB97FxFK6pt11hI9o8ylHppQ6ubpN6JtMr 37I7oGMQ+fWVvV7ET5Huqht9qMbhpE/HwD8+NT8A7la4Mo9XLiaauWFMeiIgk1Ur85hT b8S0ennf6hJ/NCznXWZxWLKW4s5R480SKTqwc= Received: by 10.140.203.18 with SMTP id a18mr4927203rvg.217.1249373854140; Tue, 04 Aug 2009 01:17:34 -0700 (PDT) Received: from ?192.168.0.158? ([123.113.122.160]) by mx.google.com with ESMTPS id k41sm215721rvb.17.2009.08.04.01.17.32 (version=TLSv1/SSLv3 cipher=RC4-MD5); Tue, 04 Aug 2009 01:17:33 -0700 (PDT) Message-ID: <4A77EE99.6030005@gmail.com> Date: Tue, 04 Aug 2009 16:17:29 +0800 From: Willem Jiang User-Agent: Thunderbird 2.0.0.22 (Macintosh/20090605) MIME-Version: 1.0 To: users@camel.apache.org Subject: Re: Questions On JMX And Load Balancing References: <3fee29160908040034p34b2d001saa4b8c573da8839a@mail.gmail.com> In-Reply-To: <3fee29160908040034p34b2d001saa4b8c573da8839a@mail.gmail.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Hi Camel 1.x doesn't support the change the route dynamically. Camel 2.0 supports to modify the route dynamically. But for your requirement, I don't think current Camel 2.0 snapshot supports this found , since we don't export the load balancer's processor to the JMX. We have plan to do some enhancements[1][2] of the JMX support after Camel 2.0 release, please feel free to add your requirements. [1] http://issues.apache.org/activemq/browse/CAMEL-1266 [2] http://issues.apache.org/activemq/browse/CAMEL-1484 Willem Carlo Camerino wrote: > Hi, > > I have this route which is load balanced to three activemq queueues. At > runtime, i wish to disable for example the round robin load balancer from > sending to > activemq:c. Can I do this via JMX? I tried on killing routes but I get an > exception saying that it's not supported..... > > Here is an example of a route that I use. Thanks A Lot > > from("activemq:financials").loadBalance().roundRobin().to("activemq:a", > "activemq:b", "activemq:c");//process(jposProcessor); > from("activemq:a").process(new Processor() { > > public void process(Exchange arg0) throws Exception { > logger.info("A"); > > } > }); > from("activemq:b").process(new Processor() { > > public void process(Exchange arg0) throws Exception { > // TODO Auto-generated method stub > logger.info("B"); > } > }); > from("activemq:c").process(new Processor() { > > public void process(Exchange arg0) throws Exception { > // TODO Auto-generated method stub > logger.info("C"); > } > }); > > } >