Package com.inductiveautomation.ignition.gateway.history.sf.sinks

Class AbstractSink

java.lang.Object
com.inductiveautomation.ignition.gateway.history.sf.sinks.AbstractSink
All Implemented Interfaces:
DataSink, HistoryStorer
Direct Known Subclasses:
AbstractDatasourceSink
public abstract class AbstractSink extends Object implements DataSink

  • Field Details

    • faulted

      protected boolean faulted

    • faultError

      protected Exception faultError

    • faultTime

      protected long faultTime

  • Constructor Details

    • AbstractSink

      protected AbstractSink(String pipelineName)

  • Method Details

    • startup

      public void startup()
      Specified by:
      startup in interface DataSink

    • shutdown

      public void shutdown()
      Specified by:
      shutdown in interface DataSink

    • getPipelineName

      public String getPipelineName()
      Description copied from interface: DataSink
      Returns the name of the store and forward pipeline that this sink belongs to.
      Specified by:
      getPipelineName in interface DataSink

    • getLogger

      protected LoggerEx getLogger()

    • createLogger

      protected final LoggerEx createLogger()

    • getQuarantineManager

      public QuarantineManager getQuarantineManager()
      Description copied from interface: DataSink
      Returns the quarantine interface for the sink. If the sink doesn't support quarantined data, can return null.
      Specified by:
      getQuarantineManager in interface DataSink

    • initialize

      protected void initialize() throws Exception
      Throws:
      Exception

    • uninitialize

      protected void uninitialize()

    • isStarted

      protected boolean isStarted()

    • isInitialized

      protected boolean isInitialized()

    • tryToInit

      protected boolean tryToInit()

    • setInitialized

      protected void setInitialized(boolean value)

    • isAccepting

      public boolean isAccepting()
      Description copied from interface: DataSink
      Returns whether the data store is accepting data.
      Specified by:
      isAccepting in interface DataSink

    • isFaulted

      public boolean isFaulted()

    • getFaultReason

      public Exception getFaultReason()

    • setFaulted

      public void setFaulted(String message, Exception e)