You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Sam Starling (JIRA)" <ji...@apache.org> on 2010/09/27 18:02:40 UTC

[jira] Commented: (AMQ-2911) Option to make all consumers retroactive

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

Sam Starling commented on AMQ-2911:
-----------------------------------

Hello - thanks for your patch, Pete. It'd be great to see this incorporated into the 5.5 release, for those of us who are new to compiling and running ActiveMQ from source, with patches.

> Option to make all consumers retroactive
> ----------------------------------------
>
>                 Key: AMQ-2911
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2911
>             Project: ActiveMQ
>          Issue Type: Improvement
>          Components: Broker
>            Reporter: Pete Redhead
>            Priority: Minor
>         Attachments: amq-alwaysretroactive.patch
>
>
> Our organisation uses ActiveMQ as part of our RadioVIS implementation. One feature we found that we found was missing was the ability to treat all consumers as if they were setting consumer.retroactive=true. i.e. when they connect to a topic, they are instantly sent the topic's last message. 
> (We found it necessary to implement server side, as the clients come from a variety of third-party providers, which do not implement the retroactive header).
> Included is a patch that allows this to be configured on a per-topic basis from the configuration file, for example:
> {code:xml}
> <policyEntry topic=">" producerFlowControl="true" alwaysRetroactive="true" memoryLimit="1mb">
>   <subscriptionRecoveryPolicy>
>      <lastImageSubscriptionRecoveryPolicy />
>   </subscriptionRecoveryPolicy>
> </policyEntry>
> {code}

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