}
/**
+ * Notifies all listeners that a node was added to the core.
+ *
+ * @param node
+ * The node that was added
+ */
+ private void fireNodeAdded(Node node) {
+ for (CoreListener coreListener: coreListeners) {
+ coreListener.nodeAdded(node);
+ }
+ }
+
+ /**
+ * Notifies all listeners that a node was removed from the core.
+ *
+ * @param node
+ * The node that was removed
+ */
+ private void fireNodeRemoved(Node node) {
+ for (CoreListener coreListener: coreListeners) {
+ coreListener.nodeRemoved(node);
+ }
+ }
+
+ /**
* Notifies all listeners that a connection to the given node is now being
* established.
*
/**
* {@inheritDoc}
*/
+ public void addNode(Node node) {
+ nodeManager.addNode(node);
+ fireNodeAdded(node);
+ }
+
+ /**
+ * {@inheritDoc}
+ */
+ public void removeNode(Node node) {
+ nodeManager.removeNode(node);
+ fireNodeRemoved(node);
+ }
+
+ /**
+ * {@inheritDoc}
+ */
public void connectToNode(Node node) {
fireNodeConnecting(node);
nodeManager.addNode(node);
/**
* {@inheritDoc}
*/
+ public void nodeAdded(Node node) {
+ fireNodeAdded(node);
+ }
+
+ /**
+ * {@inheritDoc}
+ */
+ public void nodeRemoved(Node node) {
+ fireNodeRemoved(node);
+ }
+
+ /**
+ * {@inheritDoc}
+ */
public void nodeConnected(Node node) {
fireNodeConnected(node);
}