Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.217.173 as permitted sender)
MIME-Version: 1.0
In-Reply-To: <1348497635707-5719861.post@n5.nabble.com>
References: <1348480755030-5719841.post@n5.nabble.com>
 <CAGB5yNk3ks4TgcDiafN7gTrcRmXxrnP18HJV5XQ0JFJ=VFyJLA@mail.gmail.com>
 <1348485094079-5719848.post@n5.nabble.com>
 <CAGB5yN=sJwbpzj6yA5wbmx_C1YoQaQKBhb1d5fuitRDEuGtk2g@mail.gmail.com>
 <1348492787912-5719857.post@n5.nabble.com>
 <CAGB5yNmk=q9Jh96kMVB8gYpC+bt6fknxedjXfFHtzcsbUkpgTw@mail.gmail.com>
 <1348497635707-5719861.post@n5.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Mon, 24 Sep 2012 17:20:49 +0200
Message-ID: 
 <CAGB5yNnpGpuBkKEtqsDJcR+x7yeY9W-XNeO_HCLMn_+hAK7-zg@mail.gmail.com>
Subject: Re: Using a custom based load balancer.
To: users@camel.apache.org
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hi

In your hashmap, the session id should be the key. And the chosen
processor should be the value.

eg the type should be
Map<String, Processor> map =3D new ...


On Mon, Sep 24, 2012 at 4:40 PM, balkishore <balkishore.pandey@gmail.com> w=
rote:
> Hi claus,
>
> Thanks a lot for replying.
>
> I implemented the idea directed by you(I really appreciate that )
> But due to some reason my requests are not being forwarded, camel is
> continuously retrying.
>
> Here is my code for custom load balancer:
>
> public class MyCustomLoadBalancer extends SimpleLoadBalancerSupport
>
> {
> private final HashMap hm =3D new HashMap();
>
> public void process(Exchange exchange) throws Exception {
> Processor target =3D chooseProcessor(exchange);
> XPathBuilder sessionID =3D
> XPathBuilder.xpath("substring(string(/*[local-name()=3D'Envelope']/*[loca=
l-name()=3D'Header']/*[local-name()=3D'ReplyTo']/*[local-name()=3D'Referenc=
eParameters']/*[local-name()=3D'ServiceGroupId']/text()),
> 10)", String.class);
> String session =3D sessionID.evaluate(exchange, String.class);
>
> hm.put(getProcessors(),session);
> target.process(exchange);
> }
>
> protected Processor chooseProcessor (Exchange exchange) throws Exception
> {
>         Namespaces env =3D new Namespaces("soapenv",
> "http://schemas.xmlsoap.org/soap/envelope/");
>         env.add("wsa", "http://www.w3.org/2005/08/addressing");
>         env.add("axis2", "http://ws.apache.org/namespaces/axis2");
>
>         Object expression =3D exchange.getIn().getHeader("test",
> env.xpath("substring(string(/soapenv:Envelope/soapenv:Header/wsa:ReplyTo/=
wsa:ReferenceParameters/axis2:Serv=E2=80=8C
> iceGroupId/text()), 10)", String.class));
>
>         if (expression.equals(hm.get(getProcessors())))
>         {
>                 return getProcessors().get(0);
>                 } else {
>                 return getProcessors().get(1);
>                 }
> }
> }
>
> And my main is something like this :
>
> from(uri).loadBalance(new MyCustomLoadBalancer()).to(BE1,BE2);
>
> where URI, BE1 and BE2 are the URLs.
>
> Am I doing something wrong in my custom load balancer method?
> I would be glad if you could help me or point out the mistake, I have don=
e.
> I have been struggling on this project for a while now.
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Using-a-c=
ustom-based-load-balancer-tp5719841p5719861.html
> Sent from the Camel - Users mailing list archive at Nabble.com.


--=20
Claus Ibsen
-----------------
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen