[
https://issues.apache.org/activemq/browse/AMQ-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Tully resolved AMQ-2283.
-----------------------------
Resolution: Fixed
Fix Version/s: 5.3.0
fixed in r792127
> 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 Bouer
> Assignee: Gary Tully
> Fix For: 5.3.0
>
>
> 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.
