|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.support.LifecycleObjectSupport
org.springframework.yarn.integration.support.IntegrationObjectSupport
org.springframework.yarn.integration.IntegrationAppmasterService<MindRpcMessageHolder>
org.springframework.yarn.integration.ip.mind.MindAppmasterService
public abstract class MindAppmasterService
Implementation of AppmasterService which handles communication
via Spring Int tcp channels using mind protocol.
| Constructor Summary | |
|---|---|
MindAppmasterService()
|
|
| Method Summary | |
|---|---|
org.springframework.yarn.am.RpcMessage<MindRpcMessageHolder> |
handleMessageInternal(org.springframework.yarn.am.RpcMessage<MindRpcMessageHolder> message)
Implementor need to write this method to process incoming messages. |
protected abstract MindRpcMessageHolder |
handleMindMessageInternal(MindRpcMessageHolder message)
Internal message handling for MindRpcMessageHolder. |
| Methods inherited from class org.springframework.yarn.integration.IntegrationAppmasterService |
|---|
doStart, doStop, getHost, getPort, hasPort, setMessageChannel, setSocketSupport |
| Methods inherited from class org.springframework.yarn.integration.support.IntegrationObjectSupport |
|---|
getConversionService, setConversionService |
| Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport |
|---|
afterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public MindAppmasterService()
| Method Detail |
|---|
public org.springframework.yarn.am.RpcMessage<MindRpcMessageHolder> handleMessageInternal(org.springframework.yarn.am.RpcMessage<MindRpcMessageHolder> message)
IntegrationAppmasterService
handleMessageInternal in class IntegrationAppmasterService<MindRpcMessageHolder>message - the rpc message wrapping a protocol content
protected abstract MindRpcMessageHolder handleMindMessageInternal(MindRpcMessageHolder message)
MindRpcMessageHolder.
message - the MindRpcMessageHolder
MindRpcMessageHolder
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||