- Timestamp:
- 06/22/13 21:51:33 (11 years ago)
- Location:
- java/main
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main
-
Property
svn:ignore
set to
target
-
Property
svn:ignore
set to
-
java/main/src/main/java/com/framsticks/observers/Endpoint.java
r77 r84 5 5 import com.framsticks.core.Path; 6 6 import com.framsticks.params.FramsClass; 7 import com.framsticks.portals.PortalEndpoint;8 7 import com.framsticks.core.ListChange; 9 import com.framsticks.util. Dispatcher;8 import com.framsticks.util.dispatching.Dispatcher; 10 9 import org.apache.log4j.Logger; 11 10 … … 14 13 */ 15 14 public class Endpoint implements Dispatcher, InstanceListener { 16 private final static Logger LOGGER = Logger.getLogger(PortalEndpoint.class.getName());15 private final static Logger log = Logger.getLogger(Endpoint.class.getName()); 17 16 18 19 20 17 protected Instance instance; 18 protected Observer observer; 19 protected String name; 21 20 22 23 21 public Endpoint() { 22 } 24 23 25 public final void configurePublic(Observer observer, Instance instance, String name) { 26 assert instance != null; 27 this.name = name; 28 this.observer = observer; 29 this.instance = instance; 30 instance.addListener(this); 31 configure(); 32 } 24 public final void configurePublic(Observer observer, Instance instance, String name) { 25 assert instance != null; 26 this.name = name; 27 this.observer = observer; 28 this.instance = instance; 29 instance.addListener(this); 30 } 33 31 34 protected void configure() { 32 public void start() { 33 instance.start(); 34 } 35 35 36 } 36 @Override 37 public void onListChange(Path path, ListChange change) { 38 log.info("change " + change + " in " + path); 39 } 37 40 38 @Override 39 public void onListChange(Path path, ListChange change) { 40 LOGGER.info("change " + change + " in " + path); 41 } 41 @Override 42 public void onRun(Exception e) { 43 } 42 44 43 44 public void onRun(Exception e) {45 45 @Override 46 public void onStop(Exception e) { 47 } 46 48 47 @Override 48 public void onStop(Exception e) { 49 } 49 @Override 50 public void onFetch(Path path) { 51 log.trace("fetched " + path); 52 } 50 53 51 52 53 54 54 @Override 55 public String toString() { 56 return instance.toString(); 57 } 55 58 56 57 58 59 public final Instance getInstance() { 60 return instance; 61 } 59 62 60 61 62 63 63 @Override 64 public final boolean isActive() { 65 return instance.isActive(); 66 } 64 67 65 66 67 68 68 @Override 69 public final void invokeLater(Runnable runnable) { 70 instance.invokeLater(runnable); 71 } 69 72 70 71 72 73 public Observer getObserver() { 74 return observer; 75 } 73 76 74 75 76 77 public final String getName() { 78 return name; 79 } 77 80 78 public static void constructFramsClass(FramsClass.Constructor constructor) { 79 constructor.method("getName").method("getInstance"); 80 } 81 public static void constructFramsClass(FramsClass.Constructor constructor) { 82 constructor.method("getName").method("getInstance"); 83 } 84 81 85 }
Note: See TracChangeset
for help on using the changeset viewer.