[FLUME-933] Default[Source|Sink|Channel]Factory implementation should do reference counting for create/unregistering instances.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Assignee: Unassigned
• Reporter: Arvind Prabhakar
• Created: 13/Jan/12 22:57
• Updated: 13/Jan/12 22:58
• Resolved: 13/Jan/12 22:58

Description

The current implementation of DefaultSourceFactory, DefaultSinkFactory and DefaultChannelFactory ensures that if a create() is called for the same name and type of object, it returns the previously created instance where available. However, on deregister it directly removes the created object from cache. This can lead to multiple instances of same name to exist within the VM which in turn can cause other problems.

Instead if the factory implementation does reference counting, it will be able to ensure that the purge of an object happens only when the number of unregister calls matches the create calls.