public abstract class IntegrationAppmasterServiceClient<T> extends IntegrationObjectSupport implements org.springframework.yarn.client.AppmasterScOperations, org.springframework.yarn.am.AppmasterServiceClient
| Constructor and Description |
|---|
IntegrationAppmasterServiceClient() |
| Modifier and Type | Method and Description |
|---|---|
org.springframework.yarn.am.RpcMessage<?> |
get(org.springframework.yarn.am.RpcMessage<?> message) |
protected abstract T |
getPayload(org.springframework.yarn.am.RpcMessage<?> message)
This method is called from
get(RpcMessage) to
resolve the actual payload sent to Sprint Int Tcp channel. |
void |
setRequestChannel(MessageChannel requestChannel)
Set the request channel for outgoing messages.
|
void |
setResponseChannel(PollableChannel responseChannel)
Set the response channel for incoming messages.
|
getConversionService, setConversionServiceafterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stoppublic void setRequestChannel(MessageChannel requestChannel)
requestChannel - the request channelpublic void setResponseChannel(PollableChannel responseChannel)
responseChannel - the response channelpublic org.springframework.yarn.am.RpcMessage<?> get(org.springframework.yarn.am.RpcMessage<?> message)
get in interface org.springframework.yarn.client.AppmasterScOperationsprotected abstract T getPayload(org.springframework.yarn.am.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