Class StreamAdmin

    • Constructor Summary

      Constructors 
      Constructor Description
      StreamAdmin​(com.rabbitmq.stream.Environment env, java.util.function.Consumer<com.rabbitmq.stream.StreamCreator> callback)
      Construct with the provided parameters.
    • Constructor Detail

      • StreamAdmin

        public StreamAdmin​(com.rabbitmq.stream.Environment env,
                           java.util.function.Consumer<com.rabbitmq.stream.StreamCreator> callback)
        Construct with the provided parameters.
        Parameters:
        env - the environment.
        callback - the callback to receive the StreamCreator.
    • Method Detail

      • 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()
        Specified by:
        start in interface Lifecycle
      • stop

        public void stop()
        Specified by:
        stop in interface Lifecycle