@Test
public void testHandleHeartbeat() throws Exception
{

    commandProcessor.listeners = Sets.newHashSet( heartbeatListener );
    commandProcessor.handleHeartbeat( heartBeat );
    verify( notifierPool ).submit( isA( Runnable.class ) );
}