org.springframework.yarn.integration.ip.mind
Class DefaultMindAppmasterServiceClient

java.lang.Object
  org.springframework.yarn.support.LifecycleObjectSupport
      org.springframework.yarn.integration.support.IntegrationObjectSupport
          org.springframework.yarn.integration.IntegrationAppmasterServiceClient<MindRpcMessageHolder>
              org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
                  org.springframework.yarn.integration.ip.mind.DefaultMindAppmasterServiceClient

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, AppmasterServiceClient, AppmasterScOperations, AppmasterMindScOperations

public class DefaultMindAppmasterServiceClient
extends MindAppmasterServiceClient

Default implementation of MindAppmasterServiceClient which handles the message serialization using type information in mind message headers.

Author:

Janne Valkealahti

Constructor Summary

DefaultMindAppmasterServiceClient()

Method Summary

protected BaseResponseObject

getBaseResponseObject(RpcMessage<?> rpcMessage) This method is called from MindAppmasterServiceClient.doMindRequest(BaseObject) to convert the response content back to mind BaseResponseObject.

Methods inherited from class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient

doMindRequest, getPayload

Methods inherited from class org.springframework.yarn.integration.IntegrationAppmasterServiceClient

get, setRequestChannel, setResponseChannel

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

Methods inherited from interface org.springframework.yarn.client.AppmasterScOperations

get

Constructor Detail

DefaultMindAppmasterServiceClient

public DefaultMindAppmasterServiceClient()

Method Detail

getBaseResponseObject

protected BaseResponseObject getBaseResponseObject(RpcMessage<?> rpcMessage)

Description copied from class: MindAppmasterServiceClient

This method is called from MindAppmasterServiceClient.doMindRequest(BaseObject) to convert the response content back to mind BaseResponseObject. This class itself can't have enough knowledge to do the conversion so process is left to implementor.

Specified by:

getBaseResponseObject in class MindAppmasterServiceClient

Parameters:

rpcMessage - the rpc message

Returns:

the BaseResponseObject build from a RpcMessage