Gibt es eine bessere Möglichkeit, Abonnentenänderungen nachzuverfolgen?

Question

Sagen wir, wir haben eine Client Klasse mit Methode zum Senden von Nachrichten an die Serverwarteschlange. Es wird auch abonniert Warteschlange und Server eine Benachrichtigung zurück an alle Clients senden, wenn es eine neue Nachricht von einem der registrierten Kunden erhält:

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 
    } 
} 

In einer anderen Klasse würde Ich mag meinen Client instansiate, eine Nachricht senden und prüfen, ob sie erfolgreich gesendet wurde:

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; 
    } 
} 

Was ist der beste Weg, um zu überprüfen, ob messageDelivered() asynchroniously innerhalb Mutter checkConnection() Methode aufgerufen wurde?

Ich sehe die einfache Lösung, die eine Fahne in Client-Klasse zu erstellen, aktualisieren, wenn die Nachricht geliefert wird, und wickeln Überprüfung dieser Flagge in einigen von der Zeit in Elternklasse beschränkt Schleife. Aber diese Option sieht sehr schmutzig für mich aus. Vielleicht gibt es im Java SDK einige bessere Methoden oder "Watcher"?

Answer 1

Vielleicht so etwas?

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(); 
    } 
} 

Dann ein Runnable in Ihrem ParentClass erstellen und an den Client übergeben.

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-Klasse:

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; 
    } 

}