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

java.lang.Object
  org.springframework.yarn.support.LifecycleObjectSupport
      org.springframework.yarn.integration.support.IntegrationObjectSupport
          org.springframework.yarn.integration.IntegrationAppmasterService<MindRpcMessageHolder>
              org.springframework.yarn.integration.ip.mind.MindAppmasterService

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, AppmasterService

Direct Known Subclasses:

BatchAppmasterService

public abstract class MindAppmasterService
extends IntegrationAppmasterService<MindRpcMessageHolder>

Implementation of AppmasterService which handles communication via Spring Int tcp channels using mind protocol.

Author:

Janne Valkealahti

Constructor Summary

MindAppmasterService()

Method Summary

RpcMessage<MindRpcMessageHolder>	handleMessageInternal(RpcMessage<MindRpcMessageHolder> message) Implementor need to write this method to process incoming messages.
protected abstract MindRpcMessageHolder	handleMindMessageInternal(MindRpcMessageHolder message) Internal message handling for MindRpcMessageHolder.

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

doStart, doStop, getHost, getPort, hasPort, setMessageChannel, setSocketSupport

Methods inherited from class org.springframework.yarn.integration.support.IntegrationObjectSupport

getConversionService, setConversionService

Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport

afterPropertiesSet, 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

MindAppmasterService

public MindAppmasterService()

Method Detail

handleMessageInternal

public RpcMessage<MindRpcMessageHolder> handleMessageInternal(RpcMessage<MindRpcMessageHolder> message)

Description copied from class: IntegrationAppmasterService

Implementor need to write this method to process incoming messages.

Specified by:

handleMessageInternal in class IntegrationAppmasterService<MindRpcMessageHolder>

Parameters:

message - the rpc message wrapping a protocol content

Returns:

a reply rpc message

handleMindMessageInternal

protected abstract MindRpcMessageHolder handleMindMessageInternal(MindRpcMessageHolder message)

Internal message handling for MindRpcMessageHolder.

Parameters:

message - the MindRpcMessageHolder

Returns:

response as MindRpcMessageHolder