diff --git a/src/java/com/threerings/presents/server/PresentsAuthInvoker.java b/src/java/com/threerings/presents/server/PresentsAuthInvoker.java index 8ac30c720..35e8eed78 100644 --- a/src/java/com/threerings/presents/server/PresentsAuthInvoker.java +++ b/src/java/com/threerings/presents/server/PresentsAuthInvoker.java @@ -21,6 +21,8 @@ package com.threerings.presents.server; +import java.util.concurrent.Executor; + import com.google.inject.Inject; import com.google.inject.Singleton; @@ -34,7 +36,7 @@ public class PresentsAuthInvoker extends ReportingInvoker { @Inject public PresentsAuthInvoker (PresentsDObjectMgr omgr, ReportManager repmgr) { - super("presents.AuthInvoker", omgr, repmgr); + super("presents.AuthInvoker", (Executor)omgr, repmgr); setDaemon(true); } } diff --git a/src/java/com/threerings/presents/server/PresentsInvoker.java b/src/java/com/threerings/presents/server/PresentsInvoker.java index 0cec089df..6384bf711 100644 --- a/src/java/com/threerings/presents/server/PresentsInvoker.java +++ b/src/java/com/threerings/presents/server/PresentsInvoker.java @@ -22,6 +22,7 @@ package com.threerings.presents.server; import java.util.List; +import java.util.concurrent.Executor; import com.google.common.collect.Lists; import com.google.inject.Inject; @@ -43,7 +44,7 @@ public class PresentsInvoker extends ReportingInvoker { @Inject public PresentsInvoker (PresentsDObjectMgr omgr, Lifecycle cycle, ReportManager repmgr) { - super("presents.Invoker", omgr, repmgr); + super("presents.Invoker", (Executor)omgr, repmgr); cycle.addComponent(this); _omgr = omgr; } diff --git a/src/java/com/threerings/presents/server/ReportingInvoker.java b/src/java/com/threerings/presents/server/ReportingInvoker.java index ca496fadc..de6f9be68 100644 --- a/src/java/com/threerings/presents/server/ReportingInvoker.java +++ b/src/java/com/threerings/presents/server/ReportingInvoker.java @@ -21,6 +21,8 @@ package com.threerings.presents.server; +import java.util.concurrent.Executor; + import com.samskivert.util.Invoker; import com.samskivert.util.RunQueue; import com.samskivert.util.StringUtil; @@ -43,7 +45,16 @@ public class ReportingInvoker extends Invoker */ public ReportingInvoker (String name, RunQueue resultsQueue, ReportManager repmgr) { - super(name, resultsQueue); + this(name, new RunQueue.AsExecutor(resultsQueue), repmgr); + } + + /** + * Creates a new reporting invoker. The instance will be registered with the report manager + * if profiling is enabled ({@link Invoker#PERF_TRACK}). + */ + public ReportingInvoker (String name, Executor receiver, ReportManager repmgr) + { + super(name, receiver); if (PERF_TRACK) { repmgr.registerReporter(ReportManager.DEFAULT_TYPE, _defrep); repmgr.registerReporter(ReportManager.PROFILE_TYPE, _profrep);