@Test
public void test_message_consumer()
    throws JMSException, IOException
{

    TrackerSideEffectDataBundle bundle = TrackerSideEffectDataBundle.builder().accessedBy( "test-user" ).build();
    when( textMessage.getText() ).thenReturn( "text" );
    when( objectFactory.getObject() ).thenReturn( trackerRuleEngineThread );
    doNothing().when( schedulingManager ).executeJob( any( Runnable.class ) );
    when( renderService.fromJson( anyString(), eq( TrackerSideEffectDataBundle.class ) ) ).thenReturn( null );
    trackerRuleEngineMessageManager.consume( textMessage );
    verify( schedulingManager, times( 0 ) ).executeJob( any( Runnable.class ) );
    doReturn( bundle ).when( renderService ).fromJson( anyString(), eq( TrackerSideEffectDataBundle.class ) );
    trackerRuleEngineMessageManager.consume( textMessage );
    Mockito.verify( schedulingManager ).executeJob( runnableArgumentCaptor.capture() );
    assertTrue( runnableArgumentCaptor.getValue() instanceof TrackerRuleEngineThread );
}