Class StreamAdmin
java.lang.Object
org.springframework.rabbit.stream.support.StreamAdmin
- All Implemented Interfaces:
Lifecycle
,Phased
,SmartLifecycle
Used to provision streams.
- Since:
- 2.4.13
- Author:
- Gary Russell
-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
ConstructorDescriptionStreamAdmin
(com.rabbitmq.stream.Environment env, Consumer<com.rabbitmq.stream.StreamCreator> callback) Construct with the provided parameters. -
Method Summary
Modifier and TypeMethodDescriptionint
getPhase()
boolean
boolean
void
setAutoStartup
(boolean autoStartup) Set to false to prevent automatic startup.void
setPhase
(int phase) Set the phase; default is 0.void
start()
void
stop()
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
stop
-
Constructor Details
-
StreamAdmin
public StreamAdmin(com.rabbitmq.stream.Environment env, Consumer<com.rabbitmq.stream.StreamCreator> callback) Construct with the provided parameters.- Parameters:
env
- the environment.callback
- the callback to receive theStreamCreator
.
-
-
Method Details
-
getPhase
public int getPhase()- Specified by:
getPhase
in interfacePhased
- Specified by:
getPhase
in interfaceSmartLifecycle
-
setPhase
public void setPhase(int phase) Set the phase; default is 0.- Parameters:
phase
- the phase.
-
setAutoStartup
public void setAutoStartup(boolean autoStartup) Set to false to prevent automatic startup.- Parameters:
autoStartup
- the autoStartup.
-
start
public void start() -
stop
public void stop() -
isRunning
public boolean isRunning() -
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartup
in interfaceSmartLifecycle
-