New Multicast discovery agent thread is created for each message ----------------------------------------------------------------
Key: AMQ-2283 URL: https://issues.apache.org/activemq/browse/AMQ-2283 Project: ActiveMQ Issue Type: Bug Components: Broker Affects Versions: 5.2.0 Environment: Linux, jdk6u13, jdk6u14 Reporter: eric I found out that a new thread is started for each message I send, but that thread is staying alive for the whole program lifetime. The number of live "multicast discovery agent notifier" threads scales up linearly. Eventually I ended up with 10000 threads of the above type running It doesn't seems to be a camel issue since when I try with tcp://localhost:61616 everything works fine. I'm suspecting a bug. and I wanted to share it with you before I open a ticket. 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) . . . -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.