|
|||||||||
| 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<T>
public abstract class IntegrationAppmasterService<T>
Base implementation of AppmasterService using Spring Integration Ip
channels as a communication link.
| Constructor Summary | |
|---|---|
IntegrationAppmasterService()
|
|
| Method Summary | |
|---|---|
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. |
| 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 IntegrationAppmasterService()
| Method Detail |
|---|
protected 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 content
public void setMessageChannel(SubscribableChannel messageChannel)
messageChannel - the message channelpublic void setSocketSupport(PortExposingTcpSocketSupport socketSupport)
socketSupport - the socket support
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||