camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Understanding MulticastDiscoveryAgentNotifier behavior.
Date Fri, 05 Jun 2009 10:20:30 GMT
Hi

You should also ask at the AMQ forums as its really AMQ specific.


On Fri, Jun 5, 2009 at 11:27 AM, Eric Bouer<ericbouer@gmail.com> wrote:
>
> Hello list.
> I'm trying the following code to test multicast capabilities of
> camel+activeMQ.
> I found out that a new thread is started for each new message I send, but
> the thread is staying alive for the whole program lifetime.
> The number of live "multicast discovery agent notifier" threads scales up
> linearly.
> Is it a bug or something wrong with the code ?
> Thanks.
> Eric.
> =============
> package com.mycompany.CamelExample;
> import javax.jms.ConnectionFactory;
> import org.apache.activemq.ActiveMQConnectionFactory;
> import org.apache.camel.CamelContext;
> import org.apache.camel.ProducerTemplate;
> import org.apache.camel.builder.RouteBuilder;
> import org.apache.camel.component.jms.JmsComponent;
> import org.apache.camel.impl.DefaultCamelContext;
> import org.apache.log4j.Logger;
> public final class App {
>   private static Logger log = Logger.getLogger("CamelTestApp");
>   public static void main(String args[]) throws Exception {
>        CamelContext context = new DefaultCamelContext();
>        ConnectionFactory connectionFactory =
>                    new
> ActiveMQConnectionFactory("failover:(discovery:(multicast://224.1.2.3:6255?group=default),tcp://localhost:61616)");
>        final String JMSTOPID = "test-jms";
>        final String DEST_TOPIC = "test-jms:topic:TCommandRequest";
>        final String SRC_TOPIC = "test-jms:topic:TCommandRequest";
>        context.addComponent("test-jms",
> JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
>        context.addRoutes(new RouteBuilder() {
>            public void configure() {from(SRC_TOPIC).to("mock:test");}});
>        ProducerTemplate template = context.createProducerTemplate();
>        context.start();
>           while (true) {
>                template.sendBody(DEST_TOPIC, "TEST_TEXT");
>               Thread.sleep(5000);
>            }
>    }
> }
> ======================
> My log shows:
>
> 12:02:06,212  INFO DefaultCamelContext:729 - Apache Camel 2.0-M1
> (CamelContext:camel-1) is starting
> 12:02:06,582  WARN ObjectHelper:523 - Cannot find class:
> org.apache.xalan.xsltc.trax.DOM2SAX
> 12:02:07,137  INFO DiscoveryTransport:73 - Adding new broker connection URL:
> tcp://192.168.0.1:61616
> 12:02:07,220  INFO FailoverTransport:714 - Successfully connected to
> tcp://192.168.0.1:61616
> 12:02:07,222  INFO FailoverTransport:714 - Successfully connected to
> discovery:(multicast://224.1.2.3:6255?group=default)
> 12:02:07,247  INFO DefaultCamelContext:771 - Apache Camel 2.0-M1
> (CamelContext:camel-1) started
> 12:02:07,640  INFO DiscoveryTransport:73 - Adding new broker connection URL:
> tcp://192.168.0.1:61616
> 12:02:07,715  INFO FailoverTransport:714 - Successfully connected to
> tcp://192.168.0.1:61616
> 12:02:07,716  INFO FailoverTransport:714 - Successfully connected to
> discovery:(multicast://224.1.2.3:6255?group=default)
> 12:02:13,181  INFO DiscoveryTransport:73 - Adding new broker connection URL:
> tcp://192.168.64.1:61616
> 12:02:13,220  INFO FailoverTransport:714 - Successfully connected to
> tcp://192.168.0.1:61616
> 12:02:13,222  INFO FailoverTransport:714 - Successfully connected to
> discovery:(multicast://224.1.2.3:6255?group=default)
> 12:02:18,731  INFO DiscoveryTransport:73 - Adding new broker connection URL:
> tcp://192.168.0.1:61616
> 12:02:18,961  INFO FailoverTransport:714 - Successfully connected to
> tcp://192.168.0.1:61616
> 12:02:18,963  INFO FailoverTransport:714 - Successfully connected to
> discovery:(multicast://224.1.2.3:6255?group=default)
> .
> .
> .
> .
> http://www.nabble.com/file/p23885103/multicastdiscoveryagentnotifier.png
> --
> View this message in context: http://www.nabble.com/Understanding-MulticastDiscoveryAgentNotifier-behavior.-tp23885103p23885103.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>



-- 
Claus Ibsen
Apache Camel Committer

Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

Mime
View raw message