- Timestamp:
- 06/24/13 13:38:40 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/portals/PortalEndpoint.java
r84 r85 1 1 package com.framsticks.portals; 2 2 3 import com.framsticks.core.Instance; 3 4 import com.framsticks.core.Path; 4 5 import com.framsticks.observers.Endpoint; … … 7 8 import com.framsticks.util.Logging; 8 9 import org.apache.log4j.Logger; 10 import com.framsticks.util.dispatching.RunAt; 9 11 10 12 /** … … 18 20 } 19 21 20 21 22 23 22 @Override 23 public Portal getObserver() { 24 return (Portal) observer; 25 } 24 26 25 26 27 27 @Override 28 public void onRun(Exception e) { 29 assert Dispatching.isThreadSafe(); 28 30 29 31 super.onRun(e); 30 32 31 32 33 34 35 instance.invokeLater(new Runnable() {36 37 38 39 40 41 42 43 44 45 46 33 if (e != null) { 34 return; 35 } 36 final String path = "/simulator/genepools/groups/0/genotypes"; 37 instance.invokeLater(new RunAt<Instance>() { 38 @Override 39 public void run() { 40 PortalEndpoint.this.instance.resolve(path, new Future<Path>() { 41 @Override 42 public void result(Path result, Exception e) { 43 Logging.log(log, "resolve", path, e); 44 } 45 }); 46 } 47 }); 48 } 47 49 48 49 50 50 @Override 51 public void onStop(Exception e) { 52 } 51 53 52 54 53 54 55 56 57 58 59 60 61 62 63 55 /*@Override 56 public void onChange(final Path path) { 57 //if path.getTop().getParam(). 58 observer.invokeLater(new Runnable() { 59 @Override 60 public void run() { 61 log.debug("change at " + path); 62 } 63 }); 64 } 65 */ 64 66 65 67
Note: See TracChangeset
for help on using the changeset viewer.