@Test
public void testRunWithException() throws Exception
{

    Exception exception = mock( RuntimeException.class );
    doThrow( exception ).when( listener ).onMessage( message );
    messageNotifier.run();
    verify( exception ).printStackTrace( any( PrintStream.class ) );
}