import com.google.common.collect.ForwardingObject;
import com.google.common.util.concurrent.ListenableFuture;
import java.util.concurrent.TimeUnit;
import com.google.common.collect.ForwardingObject;
import com.google.common.util.concurrent.ListenableFuture;
import java.util.concurrent.TimeUnit;
/**
* Utility implementations of {@link DOMNotificationPublishService} which forwards
* all requests to a delegate instance.
*/
/**
* Utility implementations of {@link DOMNotificationPublishService} which forwards
* all requests to a delegate instance.
*/
- public ListenableFuture<? extends Object> offerNotification(final DOMNotification notification, final long timeout,
+ public ListenableFuture<? extends Object> offerNotification(
+ final DOMNotification notification, final long timeout,
final TimeUnit unit) throws InterruptedException {
return delegate().offerNotification(notification, timeout, unit);
}
final TimeUnit unit) throws InterruptedException {
return delegate().offerNotification(notification, timeout, unit);
}