Changeset 88 for java/main/src/main/java/com/framsticks/portals/Portal.java
- Timestamp:
- 06/30/13 12:48:20 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/portals/Portal.java
r86 r88 1 1 package com.framsticks.portals; 2 2 3 import com.framsticks.observers.Observer; 3 4 import com.framsticks.core.AbstractInstanceListener; 5 import com.framsticks.core.Instance; 6 import com.framsticks.core.Path; 4 7 import com.framsticks.params.annotations.FramsClassAnnotation; 5 8 import com.framsticks.params.annotations.ParamAnnotation; 6 import com.framsticks.util.PeriodicTask; 9 import com.framsticks.util.Logging; 10 import com.framsticks.util.dispatching.Dispatching; 11 import com.framsticks.util.dispatching.Future; 12 import com.framsticks.util.dispatching.JoinableCollection; 13 import com.framsticks.util.dispatching.RunAt; 14 7 15 import org.apache.log4j.Logger; 8 16 … … 12 20 */ 13 21 @FramsClassAnnotation 14 public class Portal extends Observer{22 public class Portal extends JoinableCollection<Instance> { 15 23 16 24 private final static Logger log = Logger.getLogger(Portal.class.getName()); … … 22 30 } 23 31 24 @Override25 public void run() {26 super.run();27 new PeriodicTask<Portal>(this, 1000) {32 // @Override 33 // public void run() { 34 // super.run(); 35 // new PeriodicTask<Portal>(this, 1000) { 28 36 29 @Override30 public void run() {31 ++counter;32 log.debug("counter is now: " + counter);33 again();34 }35 };36 }37 // @Override 38 // public void run() { 39 // ++counter; 40 // log.debug("counter is now: " + counter); 41 // again(); 42 // } 43 // }; 44 // } 37 45 38 46 @Override 39 protected PortalEndpoint createEndpoint() { 40 return new PortalEndpoint(); 47 public void add(final Instance instance) { 48 super.add(instance); 49 instance.addListener(new AbstractInstanceListener() { 50 @Override 51 public void onRun(Exception e) { 52 assert Dispatching.isThreadSafe(); 53 54 super.onRun(e); 55 56 if (e != null) { 57 return; 58 } 59 final String path = "/simulator/genepools/groups/0/genotypes"; 60 instance.invokeLater(new RunAt<Instance>() { 61 @Override 62 public void run() { 63 instance.resolve(path, new Future<Path>() { 64 @Override 65 public void result(Path result, Exception e) { 66 Logging.log(log, "resolve", path, e); 67 } 68 }); 69 } 70 }); 71 } 72 }); 41 73 } 42 74
Note: See TracChangeset
for help on using the changeset viewer.