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

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

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

Direct Known Subclasses:

DefaultMindAppmasterServiceClient

public abstract class MindAppmasterServiceClient
extends IntegrationAppmasterServiceClient<MindRpcMessageHolder>
implements AppmasterMindScOperations

Implementation of Appmaster service client extending IntegrationAppmasterServiceClient.

Author:

Janne Valkealahti

Constructor Summary

MindAppmasterServiceClient()

Method Summary

BaseResponseObject	doMindRequest(BaseObject request)
protected abstract BaseResponseObject	getBaseResponseObject(RpcMessage<?> rpcMessage) This method is called from doMindRequest(BaseObject) to convert the response content back to mind BaseResponseObject.
MindRpcMessageHolder	getPayload(RpcMessage<?> message) This method is called from IntegrationAppmasterServiceClient.get(RpcMessage) to resolve the actual payload sent to Sprint Int Tcp channel.

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

MindAppmasterServiceClient

public MindAppmasterServiceClient()

Method Detail

doMindRequest

public BaseResponseObject doMindRequest(BaseObject request)

Specified by:

doMindRequest in interface AppmasterMindScOperations

getBaseResponseObject

protected abstract BaseResponseObject getBaseResponseObject(RpcMessage<?> rpcMessage)

This method is called from 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.

Parameters:

rpcMessage - the rpc message

Returns:

the BaseResponseObject build from a RpcMessage

getPayload

public MindRpcMessageHolder getPayload(RpcMessage<?> message)

Description copied from class: IntegrationAppmasterServiceClient

This method is called from IntegrationAppmasterServiceClient.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.

Specified by:

getPayload in class IntegrationAppmasterServiceClient<MindRpcMessageHolder>

Parameters:

message - the rpc message

Returns:

the payload