Package com.alibaba.spring.boot.rsocket.upstream

Class SmartLifecycleUpstreamManagerImpl

java.lang.Object

com.alibaba.rsocket.upstream.UpstreamManagerImpl

com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

All Implemented Interfaces:

Initializable, UpstreamManager, Closeable, AutoCloseable, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class SmartLifecycleUpstreamManagerImpl
extends UpstreamManagerImpl
implements org.springframework.context.SmartLifecycle

SmartLifecycle UpstreamManager implementation with graceful shutdown support

Author:

leijuan

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
SmartLifecycleUpstreamManagerImpl(RSocketRequesterSupport rsocketRequesterSupport)

Method Summary

Modifier and Type	Method	Description
void	init()
boolean	isRunning()
void	start()
void	stop()
void	stop(@NotNull Runnable callback)

Methods inherited from class com.alibaba.rsocket.upstream.UpstreamManagerImpl

add, addP2pService, close, findAllClusters, findBroker, findBrokerDiscoveryService, findClusterByServiceId, getP2pServices, getRSocket, monitorClusters, refresh, remove, requesterSupport, setP2pServices

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isAutoStartup

Constructor Details

SmartLifecycleUpstreamManagerImpl

public SmartLifecycleUpstreamManagerImpl(RSocketRequesterSupport rsocketRequesterSupport)

Method Details

init

public void init()
          throws Exception

Specified by:

init in interface Initializable

Specified by:

init in interface UpstreamManager

Overrides:

init in class UpstreamManagerImpl

Throws:

Exception

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

stop

public void stop(@NotNull
 @NotNull Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle