public abstract class MindAppmasterServiceClient extends IntegrationAppmasterServiceClient<MindRpcMessageHolder> implements AppmasterMindScOperations
IntegrationAppmasterServiceClient
を継承した Appmaster サービスクライアントの実装。コンストラクターと説明 |
---|
MindAppmasterServiceClient() |
修飾子と型 | メソッドと説明 |
---|---|
BaseResponseObject | doMindRequest(BaseObject request) |
protected abstract BaseResponseObject | getBaseResponseObject(RpcMessage<?> rpcMessage) このメソッドは、 doMindRequest(BaseObject) から呼び出され、レスポンスコンテンツを BaseResponseObject に戻します。 |
MindRpcMessageHolder | getPayload(RpcMessage<?> message) このメソッドは、Sprint Int Tcp チャネルに送信された実際のペイロードを解決するために IntegrationAppmasterServiceClient.get(RpcMessage) から呼び出されます。 |
get, setRequestChannel, setResponseChannel
getConversionService, setConversionService
afterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get
public BaseResponseObject doMindRequest(BaseObject request)
AppmasterMindScOperations
の doMindRequest
protected abstract BaseResponseObject getBaseResponseObject(RpcMessage<?> rpcMessage)
BaseResponseObject
に戻すために doMindRequest(BaseObject)
から呼び出されます。このクラス自体は変換を行うのに十分な知識を持たないため、プロセスは実装者に任されます。rpcMessage
- RPC メッセージ RpcMessage
から BaseResponseObject
を構築 public MindRpcMessageHolder getPayload(RpcMessage<?> message)
IntegrationAppmasterServiceClient
IntegrationAppmasterServiceClient.get(RpcMessage)
から呼び出されます。このクラスでは、ペイロードの内容は重要ではないため、実装者がそれを定義する責任があります。IntegrationAppmasterServiceClient<MindRpcMessageHolder>
の getPayload
message
- RPC メッセージ