Return-Path: 
 <dev-return-24714-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 18168 invoked from network); 25 Jan 2011 14:48:08 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3)
  by minotaur.apache.org with SMTP; 25 Jan 2011 14:48:08 -0000
Received: (qmail 58740 invoked by uid 500); 25 Jan 2011 14:48:08 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 58603 invoked by uid 500); 25 Jan 2011 14:48:05 -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 58588 invoked by uid 99); 25 Jan 2011 14:48:04 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 25 Jan 2011 14:48:04 +0000
X-ASF-Spam-Status: No, hits=-2000.0 required=10.0
	tests=ALL_TRUSTED
X-Spam-Check-By: apache.org
Received: from [140.211.11.22] (HELO thor.apache.org) (140.211.11.22)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 25 Jan 2011 14:48:03 +0000
Received: from thor (localhost [127.0.0.1])
	by thor.apache.org (8.13.8+Sun/8.13.8) with ESMTP id p0PElhc3008052
	for <dev@activemq.apache.org>; Tue, 25 Jan 2011 14:47:43 GMT
Message-ID: <31490144.188081295966863269.JavaMail.jira@thor>
Date: Tue, 25 Jan 2011 09:47:43 -0500 (EST)
From: "Guy Hoshea (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Created: (AMQ-3156) Active MQ lose messages which were
 published on topic
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394

Active MQ lose messages which were published on topic
-----------------------------------------------------

                 Key: AMQ-3156
                 URL: https://issues.apache.org/jira/browse/AMQ-3156
             Project: ActiveMQ
          Issue Type: Bug
    Affects Versions: 5.2.0
            Reporter: Guy Hoshea


We use Spring framework with Active MQ. We publish messages to a topic.
We have one consumer. The publisher published message with attributes.
The consumer filters messages by selector on those attributes.
Once in a while a message does not reach the consumer. There are no errors in logs. No disconnection are seen in logs.

Spring configuration on publisher side:

	<bean id="connectionFactory" class="com.icap.dealfeed.common.jms.FailoverableCachingConnectionFactory">
		<!--  starting with empty impl, later the real impl will be injected -->
		<property name="targetConnectionFactory">
			<bean class="com.icap.dealfeed.common.jms.ConnectionFactoryEmptyImpl">
			</bean>
		</property>
		<property name="sessionCacheSize"      value="5"/>
	</bean>


Spring beans on consumer side:

	<bean id="rangeUpdateMessageListenerContainer"
                 class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory"     ref="connectionFactory" />
		<!-- Using the CACHE_NONE so Application Resilience will work -->
		<property name="cacheLevelName"      value="CACHE_NONE"/>
		<property name="destinationName"     value="${jmsRangeUpdateTopicName}"/>
		<property name="pubSubDomain"        value="true"/>
		<property name="messageListener"       ref="rangeUpdatesMessageListener"/>
		<property name="exceptionListener"     ref="rangeUpdatesMessageListener"/>
		<!-- Because its topic there should be no concurrentConsumers, so both following values are 1-->
		<property name="concurrentConsumers"    value="1"/>
		<property name="maxConcurrentConsumers" value="1"/>
		<!--  starting on purpose with dummy selector -->
		<property name="messageSelector"     value="dummy = 123"/>
		<property name="autoStartup"         value="false"/>
	</bean>


	<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">

		<property name="targetConnectionFactory" ref="emptyImplConnectionFactory"/>
		<property name="sessionCacheSize"      value="5"/>
	</bean>



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