forwarderThread = new Thread(forwardingRunnable);
}
public void start() {
forwarderThread.start();
}
<BUG>public ThresholdBundleHandle addToNextBundle(T item) {
</BUG>
bundleReceiver.validateItem(item);
<BUG>return bundler.add(item);
}</BUG>
@Override

forwarderThread = new Thread(forwardingRunnable);
}
public void start() {
forwarderThread.start();
}
public void addToNextBundle(T item) {
bundleReceiver.validateItem(item);
bundler.add(item);
}
@Override
