From dbb86148a7b53d729085b4ace612e211d7a876ed Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Tue, 28 Feb 2012 15:08:58 +0100
Subject: Add support for more than one listener to variables.

---
 same/src/main/java/com/orbekk/same/VariableFactory.java | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

(limited to 'same/src/main/java/com/orbekk/same/VariableFactory.java')

diff --git a/same/src/main/java/com/orbekk/same/VariableFactory.java b/same/src/main/java/com/orbekk/same/VariableFactory.java
index fa9eeeb..e04e36b 100644
--- a/same/src/main/java/com/orbekk/same/VariableFactory.java
+++ b/same/src/main/java/com/orbekk/same/VariableFactory.java
@@ -1,6 +1,7 @@
 package com.orbekk.same;
 
 import java.io.IOException;
+import java.util.ArrayList;
 
 import org.codehaus.jackson.JsonGenerationException;
 import org.codehaus.jackson.map.JsonMappingException;
@@ -25,7 +26,8 @@ public class VariableFactory {
         TypeReference<T> type;
         T value;
         long revision = 0;
-        OnChangeListener<T> listener = null;
+        ArrayList<OnChangeListener<T>> listeners =
+                new ArrayList<OnChangeListener<T>>();
 
         public VariableImpl(String identifier, TypeReference<T> type) {
             this.identifier = identifier;
@@ -66,14 +68,19 @@ public class VariableFactory {
         }
 
         @Override
-        public void setOnChangeListener(OnChangeListener<T> listener) {
-            this.listener = listener;
+        public synchronized void addOnChangeListener(OnChangeListener<T> listener) {
+            listeners.add(listener);
+        }
+        
+        @Override
+        public synchronized void removeOnChangeListener(OnChangeListener<T> listener) {
+            listeners.remove(listener);
         }
 
         @Override
-        public void stateChanged(Component component) {
+        public synchronized void stateChanged(Component component) {
             if (component.getName().equals(identifier)) {
-                if (listener != null) {
+                for (OnChangeListener<T> listener : listeners) {
                     listener.valueChanged(this);
                 }
             }
-- 
cgit v1.2.3