diff --git a/src/main/java/com/intel/distml/platform/MonitorActor.java b/src/main/java/com/intel/distml/platform/MonitorActor.java index 33c6438..98bfec4 100644 --- a/src/main/java/com/intel/distml/platform/MonitorActor.java +++ b/src/main/java/com/intel/distml/platform/MonitorActor.java @@ -284,13 +284,24 @@ public MonitorActor(Model model) { log("Monitor created, psCount:" + psCount); } + private static final class CreatorImplementation implements Creator { + public CreatorImplementation(final Model model) { + this.model = model; + } + private static final long serialVersionUID = 1L; + private Model model; + + public MonitorActor create() throws Exception { + // TODO Auto-generated method stub + return new MonitorActor(model); + } + } + public static Props props(final Model model) { - return Props.create(new Creator() { - private static final long serialVersionUID = 1L; - public MonitorActor create() throws Exception { - return new MonitorActor(model); - } - }); + + return Props.create(new CreatorImplementation(model)); + + } public void switchServer(int index, String addr, ActorRef actor) { @@ -500,4 +511,4 @@ private void debug(String msg) { private void log(String msg) { Logger.info(msg, "Monitor"); } -} \ No newline at end of file +}