1 21 22 package org.jacorb.notification.engine; 23 24 import org.jacorb.notification.interfaces.CallbackingDisposable; 25 import org.jacorb.notification.interfaces.Disposable; 26 import org.jacorb.notification.util.DisposableManager; 27 28 public class PooledPushTaskExecutorFactory implements PushTaskExecutorFactory, 29 CallbackingDisposable 30 { 31 private final PushTaskExecutor executor_; 32 33 private final DisposableManager disposableManager_ = new DisposableManager(); 34 35 public PooledPushTaskExecutorFactory(PushTaskExecutorFactory delegate) 36 { 37 super(); 38 39 executor_ = delegate.newExecutor(this); 40 } 41 42 public PushTaskExecutor newExecutor(CallbackingDisposable callbackingDisposable) 43 { 44 return executor_; 45 } 46 47 public void dispose() 48 { 49 disposableManager_.dispose(); 50 } 51 52 public void addDisposeHook(Disposable d) 53 { 54 disposableManager_.addDisposable(d); 55 } 56 } 57 | Popular Tags |