public abstract class IntegrationAppmasterServiceClient<T> extends IntegrationObjectSupport implements AppmasterScOperations, AppmasterServiceClient
コンストラクターと説明 |
---|
IntegrationAppmasterServiceClient() |
修飾子と型 | メソッドと説明 |
---|---|
RpcMessage<?> | get(RpcMessage<?> message) RpcMessage でラップされたリクエストを送信し、同様に RpcMessage でラップされたレスポンスを受信します。 |
protected abstract T | getPayload(RpcMessage<?> message) このメソッドは、Sprint Int Tcp チャネルに送信された実際のペイロードを解決するために get(RpcMessage) から呼び出されます。 |
void | setRequestChannel(org.springframework.messaging.MessageChannel requestChannel) 送信メッセージのリクエストチャネルを設定します。 |
void | setResponseChannel(org.springframework.messaging.PollableChannel responseChannel) 受信メッセージのレスポンスチャネルを設定します。 |
getConversionService, setConversionService
afterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
public void setRequestChannel(org.springframework.messaging.MessageChannel requestChannel)
requestChannel
- リクエストチャンネル public void setResponseChannel(org.springframework.messaging.PollableChannel responseChannel)
responseChannel
- レスポンスチャネル public RpcMessage<?> get(RpcMessage<?> message)
AppmasterScOperations
RpcMessage
でラップされたリクエストを送信し、同様に RpcMessage
でラップされたレスポンスを受信します。AppmasterScOperations
の get
message
- RpcMessage
リクエスト RpcMessage
レスポンス protected abstract T getPayload(RpcMessage<?> message)
get(RpcMessage)
から呼び出されます。このクラスでは、ペイロードの内容は重要ではないため、実装者がそれを定義する責任があります。message
- RPC メッセージ