public abstract class IntegrationAppmasterService<T> extends IntegrationObjectSupport implements org.springframework.yarn.am.AppmasterService
AppmasterService using Spring Integration Ip
channels as a communication link.| Constructor and Description |
|---|
IntegrationAppmasterService() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop() |
String |
getHost() |
int |
getPort() |
abstract org.springframework.yarn.am.RpcMessage<T> |
handleMessageInternal(org.springframework.yarn.am.RpcMessage<T> message)
Implementor need to write this method to process
incoming messages.
|
boolean |
hasPort() |
void |
setMessageChannel(SubscribableChannel messageChannel)
Sets the message channel where messages are dispatched.
|
void |
setSocketSupport(PortExposingTcpSocketSupport socketSupport)
Sets the socket support for this service.
|
getConversionService, setConversionServiceafterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stopprotected void doStart()
doStart in class org.springframework.yarn.support.LifecycleObjectSupportprotected void doStop()
doStop in class org.springframework.yarn.support.LifecycleObjectSupportpublic int getPort()
getPort in interface org.springframework.yarn.am.AppmasterServicepublic String getHost()
getHost in interface org.springframework.yarn.am.AppmasterServicepublic boolean hasPort()
hasPort in interface org.springframework.yarn.am.AppmasterServicepublic abstract org.springframework.yarn.am.RpcMessage<T> handleMessageInternal(org.springframework.yarn.am.RpcMessage<T> message)
message - the rpc message wrapping a protocol contentpublic void setMessageChannel(SubscribableChannel messageChannel)
messageChannel - the message channelpublic void setSocketSupport(PortExposingTcpSocketSupport socketSupport)
socketSupport - the socket support