Return-Path: <users-return-45318-archive-asf-public=cust-asf.ponee.io@activemq.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 50615200B27
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Wed, 22 Jun 2016 16:15:39 +0200 (CEST)
Received: by cust-asf.ponee.io (Postfix)
	id 4ED3C160A36; Wed, 22 Jun 2016 14:15:39 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 99B19160A24
	for <archive-asf-public@cust-asf.ponee.io>; Wed, 22 Jun 2016 16:15:38 +0200 (CEST)
Received: (qmail 43125 invoked by uid 500); 22 Jun 2016 14:15:37 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Delivered-To: moderator for users@activemq.apache.org
Received: (qmail 79823 invoked by uid 99); 22 Jun 2016 10:01:00 -0000
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 4.252
X-Spam-Level: ****
X-Spam-Status: No, score=4.252 tagged_above=-999 required=6.31
	tests=[DKIM_ADSP_CUSTOM_MED=0.001, FORGED_YAHOO_RCVD=1.022,
	NML_ADSP_CUSTOM_MED=1.2, RCVD_IN_DNSWL_NONE=-0.0001,
	SPF_NEUTRAL=0.652, URI_HEX=1.313, URI_TRY_3LD=0.064]
	autolearn=disabled
Date: Wed, 22 Jun 2016 02:20:50 -0700 (PDT)
From: kuntalc-techid <kuntalc-techid@yahoo.com>
To: users@activemq.apache.org
Message-ID: <1466587250001-4713239.post@n4.nabble.com>
Subject: Message consumption stuck from activemq using camel jms component
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
archived-at: Wed, 22 Jun 2016 14:15:39 -0000



I have an application with two camel routes:

    Route 1 (Consumer Route)

Reads a text file having no. of records (line separated), split them based
on each line and sends each split record to another queue ('intermediate'
queue)

    Route 2 (Producer Route)

Reads each record from intermediate queue, transform them and sends them to
an out queue.

I am using ActiveMQ with camel JmsComponent (concurrentConsumers=7,
maxConcurrentConsumers=10). I guess camel uses Spring DMLC underneath to
read from the queue.

Configurations:

activemq.broker.uri =
tcp://0.0.0.0:61616?jms.useAsyncSend=true&jms.prefetchPolicy.queuePrefetch=1

<bean id="cachingConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="jmsmqConnectionFactory" />
    <property name="reconnectOnException" value="true" />
    <property name="sessionCacheSize" value="7" />
</bean>

<bean id="jmsComponent" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="cachingConnectionFactory" />
    <property name="cacheLevelName" value="CACHE_CONSUMER" />
    <property name="transacted" value="true" />
    <property name="transactionManager" ref="transactionManager" />
</bean>

jmsComponent:queue:INTERMEDIATE?concurrentConsumers=7&maxConcurrentConsumers=10

Now, the problem is, if the no. of records in the file is very less (10 or
less), the split records are getting stuck in the intermediate queue. The
Producer Route is running but no message consumption. There is no exception
found in any of the logs and the Consumer Route is also up and running.

However, by setting prefetch limit to 0, this problem is gone but leading to
another issue - The camel routes could not be forcibly stopped by ctrl+C
with cacheLevel as CACHE_CONSUMER. Though CACHE_AUTO works fine, performance
degrades.

Now is there any known issue with prefetch > 0 and SpringDMLC or am I
missing something?




--
View this message in context: http://activemq.2283324.n4.nabble.com/Message-consumption-stuck-from-activemq-using-camel-jms-component-tp4713239.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.