Package org.apache.storm.nimbus

Interface ITopologyActionNotifierPlugin

public interface ITopologyActionNotifierPlugin
A plugin interface that gets invoked any time there is an action for a topology.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cleanup()
    Called during shutdown.
    void
    notify(String topologyName, String action)
    When a new actions is executed for a topology, this method will be called.
    void
    prepare(Map<String,Object> stormConf)
    Called once during nimbus initialization.

  • Method Details

    • prepare

      void prepare(Map<String,Object> stormConf)
      Called once during nimbus initialization.

    • notify

      void notify(String topologyName, String action)
      When a new actions is executed for a topology, this method will be called.

    • cleanup

      void cleanup()
      Called during shutdown.