未完成のNetty ChannelFutureをシミュレートする方法

Question

Nettyを使用して、UDPメッセージをサーバーに送信するクライアントアプリケーションを作成しています。要するに私は、チャネルにストリームを書き込むために、コードのこの部分を使用しています：

ChannelFuture future = channel.write(request, remoteInetSocketAddress); 
future.awaitUninterruptibly(timeout); 
if(!future.isDone()){ 
    //abort logic 
} 

すべてが正常に動作しますが、一つのこと：私は、私は、書き込みが失敗することはできませんようアボートロジックをテストすることができませんよ - つまり、サーバーがダウンしても未来は正常に完了します。書き込み操作は通常約1ミリ秒かかるので、タイムアウトを少しでも設定するとあまり役に立ちません。

私は、await（）呼び出しの代わりに非同期モデルを使用するのが望ましいと知っていますが、私のシナリオでは同期が必要で、ある時点でfinnishedになる必要があります。

未完成の未来をどのようにシミュレートできますか？

事前に感謝します。 MM

Answer 1

コードの書き方によっては、mockitoなどの模擬フレームワークを使用できます。これが不可能な場合は、ローカルアドレスにバインドされたデータグラムソケットなどの「接続された」UDPソケットを使用することもできます。あなたが偽のサーバに送った場合、あなたはPortunreachableExceptionかそれに類するものを得るべきです。

Answer 2

ネッティーあなたは、たとえば次のように模擬テストを使用してクラスをモックすることができ、この目的のために使用することができるクラスFailedFutureを持って

：

ChannelFuture future; 
if(ALWAYS_FAIL) { 
    future = channel.newFailedFuture(new Exception("I failed")); 
else 
    future = channel.write(request, remoteInetSocketAddress);