Class AbstractSink

    • Field Detail

      • faulted

        protected boolean faulted
      • faultError

        protected java.lang.Exception faultError
      • faultTime

        protected long faultTime
    • Constructor Detail

      • AbstractSink

        protected AbstractSink​(java.lang.String pipelineName)
    • Method Detail

      • startup

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

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

        public java.lang.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 java.lang.Exception
        Throws:
        java.lang.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 java.lang.Exception getFaultReason()
      • setFaulted

        public void setFaulted​(java.lang.String message,
                               java.lang.Exception e)