failing unit test fest exceptions in background thread

Author: yigit

jobqueue/AndroidManifest.xml

@@ -2,7 +2,7 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
           package="com.path.android.jobqueue"
           android:versionCode="2"
-          android:versionName="1.1.1">
+          android:versionName="1.1.2-SNAPSHOT">
     <application android:label="">
     </application>
 </manifest>

jobqueue/test/com/path/android/jobqueue/test/jobmanager/InjectorTest.java

@@ -6,13 +6,16 @@
 import com.path.android.jobqueue.Params;
 import com.path.android.jobqueue.config.Configuration;
 import com.path.android.jobqueue.di.DependencyInjector;
+import com.path.android.jobqueue.log.CustomLogger;
 import com.path.android.jobqueue.test.jobs.DummyJob;
 import static org.hamcrest.CoreMatchers.*;
 import org.hamcrest.*;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.robolectric.*;
 
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 
 @RunWith(RobolectricTestRunner.class)
@@ -42,6 +45,55 @@ public void inject(BaseJob job) {
         holder = getNextJobMethod(jobManager).invoke();
         MatcherAssert.assertThat("injection should be called for persistent job", holder.getBaseJob(), equalTo(injectedJobReference.getObject()));
         MatcherAssert.assertThat("injection should be called two times for persistent job", injectionCallCount.get(), equalTo(3));
+    }
+
+    @Test
+    public void testInjectorCrash() throws Exception {
+        final String EXCEPTION_MESSAGE = "could not inject for whatever reason :)";
+        DependencyInjector dummyDependencyInjector = new DependencyInjector() {
+            @Override
+            public void inject(BaseJob baseJob) {
+                throw new RuntimeException(EXCEPTION_MESSAGE);
+            }
+        };
+
+        final ObjectReference objectReference = new ObjectReference();
+        final CountDownLatch exceptionLatch = new CountDownLatch(1);
+        CustomLogger customLogger = new CustomLogger() {
+            @Override
+            public boolean isDebugEnabled() {
+                return false;
+            }
+
+            @Override
+            public void d(String s, Object... objects) {
+
+            }
+
+            @Override
+            public void e(Throwable throwable, String s, Object... objects) {
+                objectReference.setObject(throwable);
+                exceptionLatch.countDown();
+            }
+
+            @Override
+            public void e(String s, Object... objects) {
+                //
+            }
+        };
+        JobManager jobManager = createJobManager(new Configuration.Builder(Robolectric.application).injector(dummyDependencyInjector));
+        Throwable addException = null;
+        try {
+            jobManager.addJob(new DummyJob(new Params(0)));
+        } catch (Throwable t) {
+            addException = t;
+        }
+        MatcherAssert.assertThat("addJob should throw exception if dependency injector throws exception", addException, notNullValue());
+        jobManager.addJobInBackground(new DummyJob(new Params(0)));
+        exceptionLatch.await(2, TimeUnit.SECONDS);
+        MatcherAssert.assertThat("there should be a received exception", objectReference.getObject(), notNullValue());
+        MatcherAssert.assertThat("logged exception should be a runtime exception", objectReference.getObject(), instanceOf(RuntimeException.class));
+        MatcherAssert.assertThat("logged exception should have expected message", ((Throwable)objectReference.getObject()).getMessage(), is(EXCEPTION_MESSAGE));
 
     }
 }