You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by "Claus Ibsen (JIRA)" <ji...@apache.org> on 2010/03/24 07:47:51 UTC

[jira] Created: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
----------------------------------------------------------------------------------------------------------------------------

                 Key: CAMEL-2568
                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
             Project: Apache Camel
          Issue Type: New Feature
            Reporter: Claus Ibsen
            Assignee: Claus Ibsen
             Fix For: 2.3.0


The persisted {{AggregatedRepository}} using camel-hawtdb should support:
- additional completed state in hawtdb to keep exchanges persisted
- and have it work as in UoW when aggregated exchanges is processed
- this enabled transacted behavior
- add recovery on startup to emit previously failed completed exchanges

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


[jira] Resolved: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Claus Ibsen resolved CAMEL-2568.
--------------------------------

    Resolution: Fixed

Updated wiki documentation

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58658#action_58658 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

trunk: 930692.

Prepared for adding redelivery policy or the likes.

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58655#action_58655 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

If we add variable delay between redeliveries we can use a {{java.util.concurrent.DelayQueue}} to hold the exchanges in a queue and let them fire when they should. This prevents them from blocking a thread for a longer period.

We could most likely add the DelayQueue as a kind of generic DSL as well. For example the current Delayer DSL is blocking in current thread. We could add option to let it be non blocking as well, and reuse it in this situation.

The trick is to keep AggregateProcessor updated with in flight as it should be regarded as in flight when put on the delay queue.

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58656#action_58656 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

trunk: 930663.

Added headers with REDELIVERED and REDELIVERY_COUNTER to recovered Exchanges so end users can know how many times it has been redelivered.

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58769#action_58769 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

TODO: Update wiki documentation about max redelivery attempts and dead letter channel

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58654#action_58654 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

Got the pieces together. What would be good is to have it support a DLC like feature so it can discard poison messages just as you would do with JMS brokers.

This means the {{org.apache.camel.processor.RedeliveryPolicy}} should be supported. But it has many options which means it may be a bit work to support them all.


> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Work started: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Work on CAMEL-2568 started by Claus Ibsen.

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58657#action_58657 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

Add support for a deadLetterUri so poison messages can be moved somewhere else.

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58410#action_58410 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

trunk: 926977.

Work in progress

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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


[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58768#action_58768 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

trunk: 932757.

Added max redeliveries and dead letter uri

> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

[jira] Commented: (CAMEL-2568) camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges

Posted by "Claus Ibsen (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/CAMEL-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=58645#action_58645 ] 

Claus Ibsen commented on CAMEL-2568:
------------------------------------

trunk: 930316.

Adding {{RecoverableAggregationRepositry}}.

work in progress: The API and method names are subject to change.



> camel-hawtdb - Add support for additional completed state to support transaction and recovery of failed aggregated exchanges
> ----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2568
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2568
>             Project: Apache Camel
>          Issue Type: New Feature
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>             Fix For: 2.3.0
>
>
> The persisted {{AggregatedRepository}} using camel-hawtdb should support:
> - additional completed state in hawtdb to keep exchanges persisted
> - and have it work as in UoW when aggregated exchanges is processed
> - this enabled transacted behavior
> - add recovery on startup to emit previously failed completed exchanges

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