|
Spring for Apache Hadoop | ||||||||
| 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()
Subclasses may implement this method with the start behavior. |
protected void |
doStop()
Subclasses may implement this method with the stop behavior. |
java.lang.String |
getHost()
Get a hostname where service is running. |
int |
getPort()
Get a port where service is running. |
abstract RpcMessage<T> |
handleMessageInternal(RpcMessage<T> message)
Implementor need to write this method to process incoming messages. |
boolean |
hasPort()
This method should return true if a service will eventually bind to a port. |
void |
setMessageChannel(org.springframework.messaging.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()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock.
doStart in class LifecycleObjectSupportprotected void doStop()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock.
doStop in class LifecycleObjectSupportpublic int getPort()
AppmasterService
getPort in interface AppmasterServicepublic java.lang.String getHost()
AppmasterService
getHost in interface AppmasterServicepublic boolean hasPort()
AppmasterServiceAppmasterService.getPort() to
return the actual port number.
hasPort in interface AppmasterServicepublic abstract RpcMessage<T> handleMessageInternal(RpcMessage<T> message)
message - the rpc message wrapping a protocol content
public void setMessageChannel(org.springframework.messaging.SubscribableChannel messageChannel)
messageChannel - the message channelpublic void setSocketSupport(PortExposingTcpSocketSupport socketSupport)
socketSupport - the socket support
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||