public class RequestBundler extends Object
Modifier and Type | Field and Description |
---|---|
boolean |
isRunning |
protected long |
lastPut |
Constructor and Description |
---|
RequestBundler(BroadWorksServer broadWorksServer)
Creates a new RequestBundler for the given BroadWorksServer
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
fire() |
void |
put(Request<?> request,
Consumer<Response> consumer) |
void |
waitForEmptyQueue()
Method to Block for up to the AsyncLoadTimeout for the request queue and outstanding map to clear.
|
public RequestBundler(BroadWorksServer broadWorksServer)
broadWorksServer
- public void close()
public void fire()
public void put(Request<?> request, Consumer<Response> consumer) throws RequestException
RequestException
public void waitForEmptyQueue()
Copyright © 2016 ECG. All rights reserved.