X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fnet%2Fpterodactylus%2Ffcp%2Fhighlevel%2FHighLevelClient.java;h=f1b35986e6e64cbb6d2b291b7d3ac81bd0f8eb6e;hb=7c448b92a24145ed2b179f4395698c459c48b1ca;hp=d5252add3dbca752784bbb9a0dae428e0d99d930;hpb=2f02ab2738b81ca887fcdd2fa88db8eb07cc58b7;p=jFCPlib.git

diff --git a/src/net/pterodactylus/fcp/highlevel/HighLevelClient.java b/src/net/pterodactylus/fcp/highlevel/HighLevelClient.java
index d5252ad..f1b3598 100644
--- a/src/net/pterodactylus/fcp/highlevel/HighLevelClient.java
+++ b/src/net/pterodactylus/fcp/highlevel/HighLevelClient.java
@@ -27,8 +27,10 @@ import java.io.IOException;
 import java.net.InetAddress;
 import java.net.URL;
 import java.net.UnknownHostException;
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.logging.Logger;
@@ -109,6 +111,9 @@ public class HighLevelClient {
 	/** The FCP connection to the node. */
 	private FcpConnection fcpConnection;
 
+	/** Listeners for high-level client events. */
+	private List<HighLevelClientListener> highLevelClientListeners = Collections.synchronizedList(new ArrayList<HighLevelClientListener>());
+
 	/** The listener for the connection. */
 	private HighLevelClientFcpListener highLevelClientFcpListener = new HighLevelClientFcpListener();
 
@@ -193,6 +198,48 @@ public class HighLevelClient {
 	}
 
 	//
+	// EVENT MANAGEMENT
+	//
+
+	/**
+	 * Adds the given high-level client listener to list of listeners.
+	 *
+	 * @param highLevelClientListener
+	 *            The listener to add
+	 */
+	public void addHighLevelClientListener(HighLevelClientListener highLevelClientListener) {
+		highLevelClientListeners.add(highLevelClientListener);
+	}
+
+	/**
+	 * Removes the given high-level client listener from the list of listeners.
+	 *
+	 * @param highLevelClientListener
+	 *            The listener to remove
+	 */
+	public void removeHighLevelClientListener(HighLevelClientListener highLevelClientListener) {
+		highLevelClientListeners.remove(highLevelClientListener);
+	}
+
+	/**
+	 * Notifies all listeners that a client has connected.
+	 */
+	private void fireClientConnected() {
+		for (HighLevelClientListener highLevelClientListener: highLevelClientListeners) {
+			highLevelClientListener.clientConnected(this);
+		}
+	}
+
+	/**
+	 * Notifies all listeners that a client has disconnected.
+	 */
+	private void fireClientDisconnected() {
+		for (HighLevelClientListener highLevelClientListener: highLevelClientListeners) {
+			highLevelClientListener.clientDisconnected(this);
+		}
+	}
+
+	//
 	// ACCESSORS
 	//
 
@@ -232,6 +279,7 @@ public class HighLevelClient {
 	 */
 	public void disconnect() {
 		fcpConnection.close();
+		fireClientDisconnected();
 	}
 
 	/**
@@ -701,6 +749,7 @@ public class HighLevelClient {
 				connectCallback.setDone();
 				connectCallback = null;
 			}
+			fireClientConnected();
 		}
 
 		/**