Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <23885103.post@talk.nabble.com>
Date: Fri, 5 Jun 2009 02:27:25 -0700 (PDT)
From: Eric Bouer <ericbouer@gmail.com>
To: users@camel.apache.org
Subject: Understanding MulticastDiscoveryAgentNotifier behavior.
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


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.