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, wait
getInfo, getLogName
acceptsData, isLicensedFor, storeData
protected boolean faulted
protected java.lang.Exception faultError
protected long faultTime
public java.lang.String getPipelineName()
DataSink
getPipelineName
in interface DataSink
protected LoggerEx getLogger()
protected final LoggerEx createLogger()
public QuarantineManager getQuarantineManager()
DataSink
getQuarantineManager
in interface DataSink
protected void initialize() throws java.lang.Exception
java.lang.Exception
protected void uninitialize()
protected boolean isStarted()
protected boolean isInitialized()
protected boolean tryToInit()
protected void setInitialized(boolean value)
public boolean isAccepting()
DataSink
isAccepting
in interface DataSink
public boolean isFaulted()
public java.lang.Exception getFaultReason()
public void setFaulted(java.lang.String message, java.lang.Exception e)