加入者の変更を追跡するためのより良い方法はありますか？

Question

Clientクラスには、メッセージをサーバーキューに送信するメソッドがあります。またキューに登録され、それが登録されているクライアントのいずれかから新しいメッセージを受信したときに、サーバがすべてのクライアントに戻って通知が送信されます：私は私のクライアントをinstansiateしたい別のクラスで

public class Client { 
    public void sendMessage(String message) { 
     // Method to send messages to server 
    } 

    public void messageDelivered(String receivedMessage) { 
     // This is a method subscribed successfull message delivering 
    } 
} 

、メッセージを送信し、それはsuccessfuly送信されたことを確認します

public class ParentClass { 
    protected boolean checkConnection() { 
     Client client = new Client(); // Lets skip all configuration and connection details 
     String testMessage = "Test message"; 
     client.sendMessage(testMessage); 

     // Check that messageDelivered() was called in client with testMessage parameter 

     return result; 
    } 
} 

messageDelivered()がasynchroniously親checkConnection()メソッド内で呼ばれたことを確認するための最良の方法は何ですか？

クライアントクラスでフラグを作成し、メッセージが配信されたときにフラグを更新し、親クラスの時間によって制限されるループでこのフラグのラップチェックを行うという簡単な解決策があります。しかし、このオプションは私のために非常に汚く見えます。たぶん、Java SDKには、より良い習慣やウォッチャーがありますか？

Answer 1

多分それは何か？

public class Client { 
    private Runnable runnable; 

    public void sendMessage(String message, Runnable runnable) { 
     // Method to send messages to server 
     this.runnable = runnable; 
    } 

    public void messageDelivered(String receivedMessage) { 
     // This is a method subscribed successfull message delivering 
     this.runnable.run(); 
    } 
} 

は、その後、あなたのParentClassでRunnableを作成し、それをクライアントに渡します。

public class ParentClass { 

    protected boolean checkConnection() { 
     Client client = new Client(); // Lets skip all configuration and connection details 
     String testMessage = "Test message"; 
     // Check that messageDelivered() was called in client with testMessage parameter 
     MyRunnable runnable = new MyRunnable(); 
     client.sendMessage(testMessage, runnable); 

     try { 
     runnable.wait(10000); // Wait for 10 seconds 
     } catch(InterruptedException e) { 
     e.printStackTrace(); 
     } 

     return runnable.getResult(); 
    } 
} 

のRunnableクラス：

public class MyRunnable implements Runnable { 

    private boolean result; 

    public MyRunnable() { 
     this.result = false; 
    } 

    @Override 
    public void run() { 
     this.result = true; 
     this.notifyAll(); 
    } 

    public boolean getResult() { 
     return this.result; 
    } 

}