@Test
public void testOnMessage() throws Exception
{

    listener.onMessage( message );
    verify( responses ).put( any( UUID.class ), eq( messageResponse ), anyLong() );
    verify( semaphoreMap ).remove( any( UUID.class ) );
    verify( semaphore ).release();
}