@Test( expected = MessageException.class )
public void testSendMessage() throws Exception
{

    messenger.sendMessage( localPeer, message, RECIPIENT, TIME_TO_LIVE, HEADERS );
    verify( messengerDataService ).saveEnvelope( isA( Envelope.class ) );
    doThrow( new RuntimeException() ).when( messengerDataService ).saveEnvelope( any( Envelope.class ) );
    messenger.sendMessage( localPeer, message, RECIPIENT, TIME_TO_LIVE, HEADERS );
}