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
-
-
Constructor Summary
Constructors Constructor Description SmartLifecycleUpstreamManagerImpl(RSocketRequesterSupport rsocketRequesterSupport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidinit()booleanisRunning()voidstart()voidstop()voidstop(@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
-
-
-
-
Constructor Detail
-
SmartLifecycleUpstreamManagerImpl
public SmartLifecycleUpstreamManagerImpl(RSocketRequesterSupport rsocketRequesterSupport)
-
-
Method Detail
-
init
public void init() throws Exception- Specified by:
initin interfaceInitializable- Specified by:
initin interfaceUpstreamManager- Overrides:
initin classUpstreamManagerImpl- Throws:
Exception
-
start
public void start()
- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop()
- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop(@NotNull @NotNull Runnable callback)- Specified by:
stopin interfaceorg.springframework.context.SmartLifecycle
-
isRunning
public boolean isRunning()
- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-
-