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

Constructors

Constructor and Description
DefaultMindAppmasterServiceClient()

Method Summary

Methods

Modifier and Type	Method and Description
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