Class LocalMessageDispatcher
- java.lang.Object
-
- org.apache.nemo.runtime.common.message.local.LocalMessageDispatcher
-
public final class LocalMessageDispatcher extends java.lang.Object
Dispatch messages on a single machine.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.reef.tang.Injector
forkInjector(org.apache.reef.tang.Injector baseInjector)
static org.apache.reef.tang.Injector
getInjector()
-
-
-
Method Detail
-
getInjector
public static org.apache.reef.tang.Injector getInjector() throws org.apache.reef.tang.exceptions.InjectionException
- Returns:
- an
Injector
which hasLocalMessageDispatcher
for testing. - Throws:
org.apache.reef.tang.exceptions.InjectionException
- when failed to injectLocalMessageDispatcher
-
forkInjector
public static org.apache.reef.tang.Injector forkInjector(org.apache.reef.tang.Injector baseInjector) throws org.apache.reef.tang.exceptions.InjectionException
- Parameters:
baseInjector
- baseInjector
to extend upon- Returns:
- an
Injector
which hasLocalMessageDispatcher
for testing. - Throws:
org.apache.reef.tang.exceptions.InjectionException
- when failed to injectLocalMessageDispatcher
-
-