|
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.IntegrationAppmasterServiceClient<T>
public abstract class IntegrationAppmasterServiceClient<T>
Implementation of Appmaster service client working on top of Spring Int tcp channels.
| Constructor Summary | |
|---|---|
IntegrationAppmasterServiceClient()
|
|
| Method Summary | |
|---|---|
RpcMessage<?> |
get(RpcMessage<?> message)
Sends request wrapped in RpcMessage and
receives response similarly wrapped in RpcMessage. |
protected abstract T |
getPayload(RpcMessage<?> message)
This method is called from get(RpcMessage) to
resolve the actual payload sent to Sprint Int Tcp channel. |
void |
setRequestChannel(org.springframework.messaging.MessageChannel requestChannel)
Set the request channel for outgoing messages. |
void |
setResponseChannel(org.springframework.messaging.PollableChannel responseChannel)
Set the response channel for incoming messages. |
| Methods inherited from class org.springframework.yarn.integration.support.IntegrationObjectSupport |
|---|
getConversionService, setConversionService |
| Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport |
|---|
afterPropertiesSet, doStart, doStop, 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 IntegrationAppmasterServiceClient()
| Method Detail |
|---|
public void setRequestChannel(org.springframework.messaging.MessageChannel requestChannel)
requestChannel - the request channelpublic void setResponseChannel(org.springframework.messaging.PollableChannel responseChannel)
responseChannel - the response channelpublic RpcMessage<?> get(RpcMessage<?> message)
AppmasterScOperationsRpcMessage and
receives response similarly wrapped in RpcMessage.
get in interface AppmasterScOperationsmessage - the RpcMessage request
RpcMessage responseprotected abstract T getPayload(RpcMessage<?> message)
get(RpcMessage) to
resolve the actual payload sent to Sprint Int Tcp channel.
In this class we don't care what the payload content is, thus
implementor is responsible to define it.
message - the rpc message
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||