public abstract class AbstractSink extends java.lang.Object implements DataSink
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
faulted |
protected java.lang.Exception |
faultError |
protected long |
faultTime |
LOG_NAME_TEMPLATE| Modifier | Constructor and Description |
|---|---|
protected |
AbstractSink(java.lang.String pipelineName) |
| Modifier and Type | Method and Description |
|---|---|
protected LoggerEx |
createLogger() |
java.lang.Exception |
getFaultReason() |
protected LoggerEx |
getLogger() |
java.lang.String |
getPipelineName()
Returns the name of the store and forward pipeline that this sink belongs to.
|
QuarantineManager |
getQuarantineManager()
Returns the quarantine interface for the sink.
|
protected void |
initialize() |
boolean |
isAccepting()
Returns whether the data store is accepting data.
|
boolean |
isFaulted() |
protected boolean |
isInitialized() |
protected boolean |
isStarted() |
void |
setFaulted(java.lang.String message,
java.lang.Exception e) |
protected void |
setInitialized(boolean value) |
void |
shutdown() |
void |
startup() |
protected boolean |
tryToInit() |
protected void |
uninitialize() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetInfo, getLogNameacceptsData, isLicensedFor, storeDataprotected boolean faulted
protected java.lang.Exception faultError
protected long faultTime
public java.lang.String getPipelineName()
DataSinkgetPipelineName in interface DataSinkprotected LoggerEx getLogger()
protected final LoggerEx createLogger()
public QuarantineManager getQuarantineManager()
DataSinkgetQuarantineManager in interface DataSinkprotected void initialize()
throws java.lang.Exception
java.lang.Exceptionprotected void uninitialize()
protected boolean isStarted()
protected boolean isInitialized()
protected boolean tryToInit()
protected void setInitialized(boolean value)
public boolean isAccepting()
DataSinkisAccepting in interface DataSinkpublic boolean isFaulted()
public java.lang.Exception getFaultReason()
public void setFaulted(java.lang.String message,
java.lang.Exception e)