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, setConversionService
afterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
protected void doStart()
LifecycleObjectSupport
LifecycleObjectSupport.lifecycleLock
を保持している間に呼び出されます。LifecycleObjectSupport
の doStart
protected void doStop()
LifecycleObjectSupport
LifecycleObjectSupport.lifecycleLock
を保持している間に呼び出されます。LifecycleObjectSupport
の doStop
public int getPort()
AppmasterService
AppmasterService
の getPort
public java.lang.String getHost()
AppmasterService
AppmasterService
の getHost
public boolean hasPort()
AppmasterService
AppmasterService.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
- ソケットサポート