T- the message type
public final class Pull2Push<T> extends Object implements Runnable, AutoCloseable
The class pulls from a set of event sources, and pushes to a single EventHandler. If the downstream event handler blocks, this will block, providing a simple rate limiting scheme.
The EventSources are managed in a basic Queue.
public void register(EventSource<T> source)
source- The source that will be added to the queue of this Pull2Push
Copyright © 2017 The Apache Software Foundation. All rights reserved.