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 davidkarlsen@gmail.com
 designates 209.85.210.175 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAGB5yNkdcxTAdJPitphbshk2WM5207S7P5w5tW2ts4-vAq9s-A@mail.gmail.com>
References: <4E165B00.200@referentia.com>
	<CAGB5yNmwemea-RsazM9Rg2REZM=8Q9pHqQieAnYThgdgfZwtmQ@mail.gmail.com>
	<CAGO7Ob0YgFGVLr=TjEm-5KiHsxACCgQQW5YONak6VpDhUzrkpA@mail.gmail.com>
	<CAGB5yNkdcxTAdJPitphbshk2WM5207S7P5w5tW2ts4-vAq9s-A@mail.gmail.com>
Date: Mon, 15 Aug 2011 05:02:29 +0200
Message-ID: 
 <CAGO7Ob1S7d1kjxV1rtaDnU9w444aWXsomOo46T0zqPX_7OvVaQ@mail.gmail.com>
Subject: Re: slow reply for jms component when url contains replyTo
From: David Karlsen <davidkarlsen@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=90e6ba6e8bbe59929a04aa827ea2

--90e6ba6e8bbe59929a04aa827ea2
Content-Type: text/plain; charset=ISO-8859-1

Because each receiver listens for a distinct correclationid this is not a
problem.

2011/8/14 Claus Ibsen <claus.ibsen@gmail.com>

> On Sat, Aug 13, 2011 at 8:06 PM, David Karlsen <davidkarlsen@gmail.com>
> wrote:
> > Hi - I would be very interested in this (and willing to test).
> > We had to back out from using camel for our req/res jms (we now use
> > jmstemplate directly) - especially because the persistentrelyqueuemanager
> > (or something like that) seemed to use the same connection - so
> eventually
> > the fw closed that connection during hours with little traffic.
> >
> > Another positive effect of switching to using jmstemplate directly is
> that
> > the same thread is handling the response and the request - and we have a
> > thread scoped state object attached to it.
> >
> > We are running in a cluster - but because we use correlationid this is
> not a
> > problem as you say.
> >
>
> btw since you run in a clustered environment. Do you use the same
> persistent reply queues for all nodes in the cluster?
> If so how is your strategy to ensure the reply messages get consumed
> by the right node?
>
>
> > The underlying MOM is WebSphere MQ.
> >
> > BTW: "vinning" in my rely was supposted to spell "common" - I blame my
> phone
> > for that ;-)
> >
> > 2011/8/13 Claus Ibsen <claus.ibsen@gmail.com>
> >
> >> Hi Jim, others
> >>
> >> I got some code for supporting exclusive replyTo queues. I just want
> >> to know if you run in a clustered environment.
> >> As the replyTo queue would be exclusive to each CamelContext (eg each
> >> node). So if you have 2 nodes running with Camel then each node would
> >> have to use an unique replyTo queue.
> >>
> >> If you run in a single instance of CamelContext then there is of
> >> course no problem.
> >>
> >> Alternative you can always use shared queues in a cluster, as each
> >> CamelContext (each node) will only pickup intended reply message for
> >> it (using a JMS selector), which is also the case why its slower. You
> >> can tweak the performance with the receiveTimeout. That is default 1
> >> sec. If you set it lower, then it will potential react faster to new
> >> replies coming back.
> >>
> >>
> >>
> >> On Fri, Jul 8, 2011 at 3:18 AM, Jim Newsham <jnewsham@referentia.com>
> >> wrote:
> >> >
> >> > I'm using Camel 2.7.1 on top of ActiveMQ 5.5.0.  For some reason, when
> I
> >> > specify a custom replyTo destination on the endpoint url, the time it
> >> takes
> >> > for the producer to receive a reply increases drastically.  The
> curious
> >> > thing is that the time to receive a reply is almost exactly 1 second.
> >>  When
> >> > I remove the replyTo from the url, everything's fast again.
> >> >
> >> > I created a very simple, stand-alone test to demonstrate what I'm
> seeing.
> >> >  There is a server class [4] which runs an embedded instance of
> ActiveMQ
> >> and
> >> > simply replies to messages as they arrive; and a client [3] class
> which
> >> > simply sends messages to the server, and prints the elapsed time.  The
> >> > USE_REPLY_TO symbolic constant in the client determines whether a
> replyTo
> >> > value is added to the url or not.
> >> >
> >> > The client output when USE_REPLY_TO is false is shown as [1].  The
> client
> >> > output when USE_REPLY_TO is true is shown as [2].  The code is pretty
> >> > trivial.  Am I doing something wrong, or is this a Camel and/or
> ActiveMQ
> >> > issue?
> >> >
> >> > Thanks!
> >> > Jim
> >> >
> >> >
> >> > [1] USE_REPLY_TO = false
> >> >
> >> > received reply in: 0.476 s
> >> > received reply in: 0.006 s
> >> > received reply in: 0.006 s
> >> > received reply in: 0.006 s
> >> > received reply in: 0.006 s
> >> > ...
> >> >
> >> >
> >> > [2] USE_REPLY_TO = true
> >> >
> >> > received reply in: 1.524 s
> >> > received reply in: 1.002 s
> >> > received reply in: 1.003 s
> >> > received reply in: 1.003 s
> >> > received reply in: 1.002 s
> >> > ...
> >> >
> >> >
> >> > [3] TestReplyToClient.java
> >> >
> >> > package test;
> >> >
> >> > import org.apache.activemq.ActiveMQConnectionFactory;
> >> > import org.apache.activemq.camel.component.ActiveMQComponent;
> >> > import org.apache.camel.CamelContext;
> >> > import org.apache.camel.ProducerTemplate;
> >> > import org.apache.camel.impl.DefaultCamelContext;
> >> >
> >> > public class TestReplyToClient {
> >> >
> >> >  private static final boolean USE_REPLY_TO = false;
> >> >
> >> >  public static void main(String... args) throws Exception {
> >> >    // create camel context; configure activemq component for
> >> > tcp://localhost:7001
> >> >    CamelContext context = new DefaultCamelContext();
> >> >    ActiveMQComponent activemqComponent =
> >> > ActiveMQComponent.activeMQComponent();
> >> >    activemqComponent.setConnectionFactory(new
> ActiveMQConnectionFactory(
> >> >      null, null, "tcp://localhost:7001"));
> >> >    context.addComponent("activemq", activemqComponent);
> >> >    context.start();
> >> >
> >> >    // define url to send requests to
> >> >    String sendUrl = "activemq:queue:dest";
> >> >    if (USE_REPLY_TO) {
> >> >      sendUrl += "?replyTo=replyQueue";
> >> >    }
> >> >    System.err.println("sending to url: " + sendUrl);
> >> >
> >> >    // repeatedly send requests; measure elapsed time
> >> >    ProducerTemplate template = context.createProducerTemplate();
> >> >    while (true) {
> >> >      long startNanos = System.nanoTime();
> >> >      template.requestBody(sendUrl, "abc");
> >> >      long elapsedNanos = System.nanoTime() - startNanos;
> >> >      System.err.println(String.format("received reply in: %.3f s",
> >> > elapsedNanos / 1000000000.0));
> >> >    }
> >> >  }
> >> >
> >> > }
> >> >
> >> >
> >> > [4] TestReplyToServer.java
> >> >
> >> > package test;
> >> >
> >> > import org.apache.activemq.broker.BrokerService;
> >> > import org.apache.activemq.camel.component.ActiveMQComponent;
> >> > import org.apache.camel.CamelContext;
> >> > import org.apache.camel.Exchange;
> >> > import org.apache.camel.Processor;
> >> > import org.apache.camel.builder.RouteBuilder;
> >> > import org.apache.camel.impl.DefaultCamelContext;
> >> >
> >> > public class TestReplyToServer {
> >> >
> >> >  private static final String BROKER_NAME = "thebroker";
> >> >
> >> >  public static void main(String... args) throws Exception {
> >> >    startBroker();
> >> >    startCamel();
> >> >    Thread.sleep(Long.MAX_VALUE);
> >> >  }
> >> >
> >> >  private static void startBroker() throws Exception {
> >> >    BrokerService brokerService = new BrokerService();
> >> >    brokerService.setBrokerName(BROKER_NAME);
> >> >    brokerService.setSchedulerSupport(false);
> >> >    brokerService.setPersistent(false);
> >> >    brokerService.addConnector("tcp://0.0.0.0:7001");
> >> >    brokerService.start();
> >> >    brokerService.waitUntilStarted();
> >> >  }
> >> >
> >> >
> >> >  private static void startCamel() throws Exception {
> >> >    CamelContext context = new DefaultCamelContext();
> >> >
> >> >    ActiveMQComponent activemqComponent =
> >> > ActiveMQComponent.activeMQComponent();
> >> >
>  activemqComponent.setBrokerURL(String.format("vm://%s?create=false",
> >> > BROKER_NAME));
> >> >    context.addComponent("activemq", activemqComponent);
> >> >
> >> >    final String receiveUrl = "activemq:queue:dest";
> >> >    context.addRoutes(new RouteBuilder() {
> >> >      @Override
> >> >      public void configure() throws Exception {
> >> >        from(receiveUrl).process(new Processor() {
> >> >          @Override
> >> >          public void process(Exchange exchange) throws Exception {
> >> >            System.err.println("received request");
> >> >            exchange.getOut().setBody("reply");
> >> >          }
> >> >        });
> >> >      }
> >> >    });
> >> >
> >> >    context.start();
> >> >    System.err.println("listening on url: " + receiveUrl);
> >> >  }
> >> >
> >> > }
> >> >
> >> >
> >> >
> >> >
> >> >
> >>
> >>
> >>
> >> --
> >> Claus Ibsen
> >> -----------------
> >> FuseSource
> >> Email: cibsen@fusesource.com
> >> Web: http://fusesource.com
> >> Twitter: davsclaus, fusenews
> >> Blog: http://davsclaus.blogspot.com/
> >> Author of Camel in Action: http://www.manning.com/ibsen/
> >>
> >
> >
> >
> > --
> > --
> > David J. M. Karlsen - http://www.linkedin.com/in/davidkarlsen
> >
>
>
>
> --
> Claus Ibsen
> -----------------
> FuseSource
> Email: cibsen@fusesource.com
> Web: http://fusesource.com
> Twitter: davsclaus, fusenews
> Blog: http://davsclaus.blogspot.com/
> Author of Camel in Action: http://www.manning.com/ibsen/
>


-- 
--
David J. M. Karlsen - http://www.linkedin.com/in/davidkarlsen

--90e6ba6e8bbe59929a04aa827ea2--