What about using a DelegateProcessor, into which you can insert a MulticastProcessor at runtime? If the collection of consumers changes, you create a new MulticastProcessor with the revised collection and use DelegateProcessor.setProcessor().
Don
What about using a DelegateProcessor, into which you can insert a MulticastProcessor at runtime? If the collection of consumers changes, you create a new MulticastProcessor with the revised collection and use DelegateProcessor.setProcessor().
Don