Return-Path: 
 <dev-return-17747-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 95220 invoked from network); 19 Nov 2009 23:22:15 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3)
  by minotaur.apache.org with SMTP; 19 Nov 2009 23:22:15 -0000
Received: (qmail 75038 invoked by uid 500); 19 Nov 2009 23:22:15 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 74982 invoked by uid 500); 19 Nov 2009 23:22:15 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 74972 invoked by uid 99); 19 Nov 2009 23:22:15 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 19 Nov 2009 23:22:15 +0000
X-ASF-Spam-Status: No, hits=-10.5 required=5.0
	tests=AWL,BAYES_00,RCVD_IN_DNSWL_HI
X-Spam-Check-By: apache.org
Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 19 Nov 2009 23:22:12 +0000
Received: from brutus (localhost [127.0.0.1])
	by brutus.apache.org (Postfix) with ESMTP id C3AFB234C48C
	for <dev@activemq.apache.org>; Thu, 19 Nov 2009 15:21:52 -0800 (PST)
Message-ID: <2068339978.1258672912798.JavaMail.jira@brutus>
Date: Thu, 19 Nov 2009 15:21:52 -0800 (PST)
From: "Helena Edelson (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Issue Comment Edited: (AMQ-1718) broker don't delivery
 message to consumer
In-Reply-To: <1207977686.1210562983470.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c


    [ https://issues.apache.org/activemq/browse/AMQ-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=55610#action_55610 ] 

Helena Edelson edited comment on AMQ-1718 at 11/19/09 3:20 PM:
---------------------------------------------------------------

Hello Alan,
I am trying to narrow down the issue, please bear with me :) First, are you actually getting a NullPointerException thrown from the Queue after a message is received by the container or after several?
Can you add your full stack trace to this ticket with debug on spring jms, activemq and javax.jms?

1. One thing I notice in your above configuration is that you specify
<property name="concurrentConsumers" value="1"/>
<property name="maxConcurrentConsumers" value="1"/>

in your DefaultMessageListenerContainer. So you are not using dynamic scaling yet demarcating both concurrent and maxConcurrent as the same value. Since the default value for concurrentConsumers is 1 and you are not doing dynamic scaling, I think you can at least remove the maxConcurrentConsumers property, if not both.

Thanks. I have more thoughts on an alternate configuration above but wanted to see your trace first.

Cheers,  
Helena Edelson 

      was (Author: helena):
    Hello Alan,
I am trying to narrow down the issue, please bear with me :) First, are you actually getting a NullPointerException thrown from the Queue after a message is received by the container or after several?
Can you add your full stack trace to this ticket with debug on spring jms, activemq and javax.jms?

1. One thing I notice in your above configuration is that you specify
<property name="concurrentConsumers" value="1"/>
<property name="maxConcurrentConsumers" value="1"/>

in your DefaultMessageListenerContainer. So you are not using dynamic scaling yet demarcating both concurrent and maxConcurrent as the same value. Since the default value for concurrentConsumers is 1 and you are not doing dynamic scaling, 
I think you can at least remove the maxConcurrentConsumers property, if not both.

Thanks. I have more thoughts on an alternate configuration above but wanted to see your trace first.

Cheers,  
  
> broker don't delivery message to consumer
> -----------------------------------------
>
>                 Key: AMQ-1718
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1718
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.1.0
>         Environment: os:suse10
>            Reporter: alan xie
>             Fix For: 5.4.0
>
>
> I have a consumer that is a spring's DefaultMessageListenerContainer. after it consume some message, it  receive null  from the queue ,while there are a lot of message on the queue that the consumer receive from. the client and server consoles have  any error info. my configures are below:
> client:
> <bean id="jmsFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
>         <property name="targetConnectionFactory">
>           <bean class="org.apache.activemq.ActiveMQConnectionFactory">
> 	        <property name="brokerURL">
> 	          <value>tcp://localhost:61616</value>
> 	        </property>
> 	        <property name="userName" value="tester"></property>
>         	<property name="password" value="test"></property>
>         	<!-- 
>         	<property name="dispatchAsync" value="false"/>
>         	-->
>         	<property name="exclusiveConsumer" value="true"></property>
> 	      </bean>
>         </property>
>       </bean>
>     <bean id="messageListener" class="com.sitechasia.ebiz.peninsula.datasync.PeninsulaConsumer">
>   	</bean>
>   	<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer" lazy-init="false">
> 	  	<property name="connectionFactory" ref="jmsFactory"/>
> 	  	<property name="destinationName" value="peninsula.res2web"/>
> 	  	<property name="concurrentConsumers" value="1"/>
> 	  	<property name="maxConcurrentConsumers" value="1"/>
> 	  	<property name="messageListener" ref="messageListener"/>
>   	</bean>
> --------------------------------------------------------
> server:
>     it is a normal config.  

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