camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Qingyi Gu (JIRA)" <j...@apache.org>
Subject [jira] Commented: (CAMEL-2740) Using static queue as a reply queue in InOut pattern causes memory leak
Date Fri, 21 May 2010 21:01:51 GMT

    [ https://issues.apache.org/activemq/browse/CAMEL-2740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=59516#action_59516
] 

Qingyi Gu commented on CAMEL-2740:
----------------------------------

Here are some more details.

AMQ:  I have two activemq and there is one network connector between them.  See config below.

<networkConnector name="server1" uri="static://(https://localhost:61617?proxyHost=server1&proxyPort=80)"
duplex="true">
     <!-- limit store and forward to specific queues -->
     <dynamicallyIncludedDestinations>
         <queue physicalName="TO_SERVER1.>"/>
         <queue physicalName="TO_SCA.>"/>
     </dynamicallyIncludedDestinations>
     <staticallyIncludedDestinations>
		<queue physicalName="TO_SERVER1.SYNC_RESP"/>
		<queue physicalName="TO_SCA.SSO.SYNC_REQ"/>
     </staticallyIncludedDestinations>
  </networkConnector>

Camel Route on consumer side:
		from("jms:queue:TO_SCA.SSO.SYNC_REQ?concurrentConsumers=25")
			.choice()
				.when(header(JMS_HEADER_TYPE).isEqualTo("TYPE1"))
					.beanRef("service1")
				.when(header(JMS_HEADER_TYPE).isEqualTo("TYPE2"))
					.beanRef("service2")
				.otherwise()
					.beanRef("unknownService")
			.end();

On producer side:

	        HashMap<String, Object> reqHeaders = new HashMap<String, Object>();
	        reqHeaders.put("JMSType", "TYPE1");
			
			
		 // Options
	        StringBuffer options = new StringBuffer();
	        options.append("?");
	        options.append("replyTo");
	        options.append("=");
	        options.append("TO_EC.SERVER1.SYNC_RESP");

	        
	        // Send Message
	        String outMsg = (String)camelTemplate.sendBodyAndHeaders("jms:queue:TO_SCA.SSO.SYNC_REQ"+options.toString(),

	        														 ExchangePattern.InOut, 
	        														 inMsg, 
	        														 reqHeaders);			




> Using static queue as a reply queue in InOut pattern causes memory leak
> -----------------------------------------------------------------------
>
>                 Key: CAMEL-2740
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2740
>             Project: Apache Camel
>          Issue Type: Bug
>          Components: camel-jms
>    Affects Versions: 2.2.0
>         Environment: Windows 2003 server
>            Reporter: Qingyi Gu
>
> I am running JBoss, ActiveMQ and Camel for my application.   In the InOut pattern,  I
am using a predefined static queue as a reply queue.   After running for a while,  the memory
usage of JBoss keeps growing and growing until it hits outOfMemory error and app server is
totally hung.   I monitor the thread in jconsole,  I can see the jms connection/session keeps
growing and growing.   
> But once I switch to use temp queue for InOut pattern,  this problem goes away.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message