package com.atlassian.sal.core.executor;
   
   import com.atlassian.sal.api.executor.ThreadLocalContextManager;
   import com.google.common.base.Throwables;
   import junit.framework.TestCase;
   
   import java.util.concurrent.Callable;
   
   public class TestThreadLocalDelegateCallable extends TestCase {
      public void testRun() throws InterruptedException {
          final ThreadLocalContextManager<Object> manager = new StubThreadLocalContextManager();
          Callable<Void> delegate = new Callable<Void>() {
              public Void call() {
                  assertNotNull(manager.getThreadLocalContext());
                  return null;
              }
          };
  
          manager.setThreadLocalContext(new Object());
          final Callable callable = new ThreadLocalDelegateCallable<Object, Void>(manager, delegate);
          Thread t = new Thread(new Runnable() {
  
              public void run() {
                  try {
                      callable.call();
                  } catch (Exception e) {
                      throw Throwables.propagate(e);
                  }
              }
          });
          t.start();
          t.join(10000);
          assertNotNull(manager.getThreadLocalContext());
      }
  }