@Test( expected = PeerException.class )
public void testSendRequestInternal() throws Exception
{

    remotePeer.sendRequestInternal( REQUEST, RECIPIENT, TIMEOUT, headers );
    verify( messenger ).sendMessage( any( Peer.class ), eq( message ), anyString(), eq( TIMEOUT ), eq( headers ) );
    doThrow( messageException ).when( messenger )
                               .sendMessage( any( Peer.class ), any( Message.class ), anyString(), anyInt(),
                                       anyMap() );
    remotePeer.sendRequestInternal( REQUEST, RECIPIENT, TIMEOUT, headers );
}