Return-Path: 
 <users-return-24070-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 97714 invoked from network); 16 Jun 2010 14:07:51 -0000
Received: from unknown (HELO mail.apache.org) (140.211.11.3)
  by 140.211.11.9 with SMTP; 16 Jun 2010 14:07:51 -0000
Received: (qmail 89991 invoked by uid 500); 16 Jun 2010 14:07:50 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 89592 invoked by uid 500); 16 Jun 2010 14:07:49 -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
Received: (qmail 89424 invoked by uid 99); 16 Jun 2010 14:07:49 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 16 Jun 2010 14:07:49 +0000
X-ASF-Spam-Status: No, hits=0.0 required=10.0
	tests=FREEMAIL_FROM,SPF_HELO_PASS,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 16 Jun 2010 14:07:43 +0000
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1OOtH0-0003mG-Mm
	for users@activemq.apache.org; Wed, 16 Jun 2010 07:07:22 -0700
Message-ID: <28903266.post@talk.nabble.com>
Date: Wed, 16 Jun 2010 07:07:22 -0700 (PDT)
From: Luis Matos <lufe66@gmail.com>
To: users@activemq.apache.org
Subject: Re: Does a timeout exist for Consumers?
In-Reply-To: <AANLkTindfA6Sxql217pik_WdnVU1tPNKq-Q2fU090rsx@mail.gmail.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: lufe66@gmail.com
References: <28891212.post@talk.nabble.com>
 <AANLkTindfA6Sxql217pik_WdnVU1tPNKq-Q2fU090rsx@mail.gmail.com>
X-Virus-Checked: Checked by ClamAV on apache.org


Hi Gary,

First of all, thanks for the answer. In the meantime, I've tried to use the
5.4-SNAPSHOT using the maven plugin and pointing to apache.snapshots or to
codehaus snapshots like this:



---------------------------------------------------------------------------------------------------
 <pluginRepositories>
     <pluginRepository>
      <id>Codehaus Snapshots</id>
      <url>http://snapshots.repository.codehaus.org/</url>
      <snapshots>
        <enabled>true</enabled>
      </snapshots>
      <releases>
        <enabled>false</enabled>
      </releases>
    </pluginRepository>
     <pluginRepository>
      <id>apache.snapshots</id>
      <url>http://repository.apache.org/snapshots/</url>
      <releases>
        <updatePolicy>daily</updatePolicy>
      </releases>
      <snapshots>
        <updatePolicy>daily</updatePolicy>
      </snapshots>
    </pluginRepository>
 </pluginRepositories>
---------------------------------------------------------------------------------------------------


I can actually run 5.4-SNAPSHOT, but not when adding the policy. When I add
the police to the activemq.xml, like this:


--------------------------------------------------------------------------------------------------

		<destinationPolicy>
		      <policyMap>
		        <policyEntries>
				<policyEntry queue="incoming-messages">
			            <dispatchPolicy>
			              <AbortSlowConsumerStrategy />
			            </dispatchPolicy>
				</policyEntry>
		        </policyEntries>
		      </policyMap>
		</destinationPolicy>


--------------------------------------------------------------------------------------------------

I get this error:



+ Error stacktraces are turned on.
[INFO] Scanning for projects...
[INFO]
------------------------------------------------------------------------
[INFO] Building iNuc-activemq
[INFO]    task-segment:
[org.apache.activemq.tooling:maven-activemq-plugin:5.4-SNAPSHOT:run]
[INFO]
------------------------------------------------------------------------
[INFO] snapshot org.apache.activemq:activemq-core:5.4-SNAPSHOT: checking for
updates from logicblaze.repo
[WARNING] repository metadata for: 'snapshot
org.apache.activemq:activemq-core:5.4-SNAPSHOT' could not be retrieved from
repository: logicblaze.repo due to an error: Error transfer
ring file: Connection reset
[INFO] Repository 'logicblaze.repo' will be blacklisted
[INFO] [activemq:run {execution: default-cli}]
[INFO] Loading broker configUri:
xbean:file:./src/main/resources/activemq.xml
Jun 16, 2010 3:54:19 PM
org.springframework.context.support.AbstractApplicationContext
prepareRefresh
INFO: Refreshing
org.apache.xbean.spring.context.ResourceXmlApplicationContext@970c0e:
display name
[org.apache.xbean.spring.context.ResourceXmlApplicationContext@970c0e];
startup
date [Wed Jun 16 15:54:19 CEST 2010]; root of context hierarchy
Jun 16, 2010 3:54:19 PM
org.springframework.beans.factory.xml.XmlBeanDefinitionReader
loadBeanDefinitions
INFO: Loading XML bean definitions from URL
[file:./src/main/resources/activemq.xml]
[INFO]
------------------------------------------------------------------------
[ERROR] BUILD ERROR
[INFO]
------------------------------------------------------------------------
[INFO] Failed to start ActiveMQ Broker

Embedded error: Unrecognized xbean element mapping:
AbortSlowConsumerStrategy in namespace
http://activemq.apache.org/schema/core

------------------------------------------------------------------------------------------------------

The question is, what am I doing wrong? Is there anywhere else I should be
looking for the 5.4-SNAPSHOT ?



Gary Tully wrote:
> 
> reducing the prefetch can ensure that a minimum of messages are locked in
> this way.
> There is a new AbortSlowConsumerStrategy destination policy on trunk(for
> 5.4) that does what you want, check out
> https://issues.apache.org/activemq/browse/AMQ-378
> you will need to use the latest 5.4-SNAPSHOT to access it.
> 
> Find the test case @
> http://fisheye6.atlassian.com/browse/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumerTest.java?r=HEAD
> 
> 
-- 
View this message in context: http://old.nabble.com/Does-a-timeout-exist-for-Consumers--tp28891212p28903266.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.