public abstract class IntegrationAppmasterService<T> extends IntegrationObjectSupport implements AppmasterService
AppmasterService の基本実装。| コンストラクターと説明 |
|---|
IntegrationAppmasterService() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | doStart() サブクラスは、開始動作でこのメソッドを実装できます。 |
protected void | doStop() サブクラスは、停止動作でこのメソッドを実装できます。 |
java.lang.String | getHost() サービスが実行されているホスト名を取得します。 |
int | getPort() サービスが実行されているポートを取得します。 |
abstract RpcMessage<T> | handleMessageInternal(RpcMessage<T> message) 実装者は、受信メッセージを処理するためにこのメソッドを記述する必要があります。 |
boolean | hasPort() サービスが最終的にポートにバインドされる場合、このメソッドは true を返す必要があります。 |
void | setMessageChannel(org.springframework.messaging.SubscribableChannel messageChannel) メッセージが送信されるメッセージチャネルを設定します。 |
void | setSocketSupport(PortExposingTcpSocketSupport socketSupport) このサービスのソケットサポートを設定します。 |
getConversionService, setConversionServiceafterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stopprotected void doStart()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。LifecycleObjectSupport の doStart protected void doStop()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。LifecycleObjectSupport の doStop public int getPort()
AppmasterServiceAppmasterService の getPort public java.lang.String getHost()
AppmasterServiceAppmasterService の getHost public boolean hasPort()
AppmasterServiceAppmasterService.getPort() が実際のポート番号を返すのを待つ間、スリープ状態になります。AppmasterService の hasPort public abstract RpcMessage<T> handleMessageInternal(RpcMessage<T> message)
message - プロトコルコンテンツをラップする RPC メッセージ public void setMessageChannel(org.springframework.messaging.SubscribableChannel messageChannel)
messageChannel - メッセージチャンネル public void setSocketSupport(PortExposingTcpSocketSupport socketSupport)
socketSupport - ソケットサポート