Mailing-List: contact dev-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@camel.apache.org
Message-ID: <152102906.14971265729736243.JavaMail.jira@brutus.apache.org>
Date: Tue, 9 Feb 2010 15:35:36 +0000 (UTC)
From: "Claus Ibsen (JIRA)" <jira@apache.org>
To: camel-dev@activemq.apache.org
Subject: [jira] Commented: (CAMEL-2360) recipientList retryUntil not working
In-Reply-To: <43964204.1401263464083528.JavaMail.jira@brutus.apache.org>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit


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

Claus Ibsen commented on CAMEL-2360:
------------------------------------

trunk: 908073.

> recipientList retryUntil not working
> ------------------------------------
>
>                 Key: CAMEL-2360
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2360
>             Project: Apache Camel
>          Issue Type: Bug
>          Components: camel-core
>    Affects Versions: 2.2.0
>            Reporter: Marco Crivellaro
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>         Attachments: Recipientlist-Retryuntil.zip
>
>
> summary:
> the bean gets intialized but it looks like the method retryUntil is never called, could it be an error of implementation? am I doing something wrong?
> using following route:
> {code}
> from("jms-test:queue:queue.delivery.notification.test") 
> .process(processor) 
> .onException(Exception.class).retryUntil(bean("myRetryBean")).end() 
> .recipientList(header("recipientListHeader").tokenize(",")) 
> .parallelProcessing().executorService(customThreadPoolExecutor) 
> .aggregationStrategy(new RecipientAggregationStrategy()) 
> .to("direct:chunk.completed"); 
> {code}
> bean is registered in such way: 
> {code}
> JndiRegistry jndi = new JndiRegistry(new JndiContext()); 
> jndi.bind("myRetryBean", new RetryBean()); 
> {code}
> bean class is: 
> {code}
> public class RetryBean { 
>         private int _invoked; 
>         private Logger _logger; 
>         
>     public RetryBean() { 
>     this._logger = Logger.getLogger(RetryBean.class); 
>     this._invoked = 0; 
>     _logger.debug("BEAN INITIALIZED " + _invoked); 
>     } 
>         
>     // using bean binding we can bind the information from the exchange to the types we have in our method signature 
>     public boolean retryUntil(@Header(Exchange.REDELIVERY_COUNTER) Integer counter, @Body String body, @ExchangeException Exception causedBy) { 
>         // NOTE: counter is the redelivery attempt, will start from 1 
>     _invoked++; 
>     
>     
>     _logger.debug("invoked" + _invoked); 
>     _logger.debug("counter" + counter); 
>     _logger.debug("result" + (counter < 2)); 
>     
>         // we can of course do what ever we want to determine the result but this is a unit test so we end after 3 attempts 
>         return counter < 7; 
>     } 
> {code}

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