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, ROOT_LOGGER
Modifier | Constructor and Description |
---|---|
protected |
AbstractSink(java.lang.String pipelineName) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.log4j.Logger |
createLogger() |
protected org.apache.log4j.Logger |
getLogger() |
protected java.lang.String |
getLogName()
How this element will be represented in the log system.
|
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
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 org.apache.log4j.Logger getLogger()
protected final org.apache.log4j.Logger createLogger()
protected final java.lang.String getLogName()
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 void setFaulted(java.lang.String message, java.lang.Exception e)