Github user harshach commented on the pull request:
https://github.com/apache/storm/pull/780#issuecomment-161484457
@kleinsch re-thinking a bit not sure if we need this Factory construct
given that this is single class will only be created once in when the spout
initializes. Why not try the following
1. add configure method to FailedMsgRetryManager
public interface FailedMsgRetryManager {
public void configure(Map<String,Object> config) or public void
configure(SpoutConfig config);
}
2. accept fully qualified class name as pluggable instance ( example look
for authorizer config in storm-core)
3. by default create instance of ExponentialBackoffMsgRetryManager . You
can use
https://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/utils/Utils.java#L96
4. call configure method with spoutconfig so that it gets all the available
options
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
