public abstract class AbstractConnector extends Service implements DocumentPublisher, DocumentConnector
cfgDir, dnaPool, log, MESSAGE_RECORDING_FORMAT_BINARY, MESSAGE_RECORDING_FORMAT_XML
Constructor and Description |
---|
AbstractConnector(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
addDocumentListener(DocumentListener listener) |
void |
feed(Document doc) |
void |
flush() |
int |
getBatchSize() |
ConnectorState |
getConnectorState() |
java.lang.String |
getDocIdPrefix() |
ConnectorState |
getState() |
Document |
publishDocument(Document doc) |
java.util.List<Document> |
publishDocuments(java.util.List<Document> batch) |
void |
publishFlush() |
void |
setBatchSize(int batchSize) |
abstract void |
setConfig(ConnectorConfig config) |
void |
setDocIdPrefix(java.lang.String docIdPrefix) |
void |
setState(ConnectorState state) |
addListener, addListener, addTask, addTask, addTask, addTaskOneShot, allowDisplay, allowDisplay, attach, attach, broadcastState, buildDna, buildDna, buildDnaKeys, buildDnaNames, clearLastError, close, containsTask, copyShallowFrom, createPeer, createPeer, createRootReserved, detach, detach, detach, echoHeartbeat, error, error, error, getAttached, getCfgDir, getComm, getDeclaredMethodNames, getDeclaredMethods, getDescription, getDna, getDnaString, getHostName, getInbox, getInstanceId, getIntanceName, getInterfaceSet, getLastError, getMessageSet, getMetaData, getMethodMap, getMethodNames, getMethods, getMethodToolTip, getMsg, getName, getNotifyList, getNotifyListKeySet, getOutbox, getPeerKey, getPeerName, getServiceResourceFile, getSimpleName, getTasks, getThisThread, getType, hasError, hasPeers, help, help, in, info, info, invoke, invoke, invoke, invokeOn, isAttached, isAttached, isLocal, isReady, isRunning, isRuntime, isVirtual, load, load, logTimeEnable, mergeDna, mergeDna, mergePeerDna, movePeerDna, out, out, preProcessHook, preRoutingHook, publishError, publishQueueStats, publishState, publishStats, publishStatus, purgeTask, purgeTasks, releasePeers, releaseService, removeAllListeners, removeListener, requiresSecurity, reserve, reserve, reserveRoot, reserveRoot, reserveRootAs, run, save, save, save, send, send, send, send, sendBlocking, sendBlocking, sendBlocking, sendBlocking, sendPeer, setInstanceId, setName, setPeer, setSecurityProvider, setState, setThisThread, setVirtual, sleep, stackToString, startHeartbeat, startPeer, startPeer, startRecording, startService, stopHeartbeat, stopMsgRecording, stopService, subscribe, subscribe, subscribe, toString, unsubscribe, unsubscribe, unsubscribe, updateStats, warn, warn
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName
startCrawling, stopCrawling
public abstract void setConfig(ConnectorConfig config)
public void feed(Document doc)
public void publishFlush()
public void flush()
public ConnectorState getState()
public void setState(ConnectorState state)
public Document publishDocument(Document doc)
publishDocument
in interface DocumentPublisher
public void addDocumentListener(DocumentListener listener)
addDocumentListener
in interface DocumentPublisher
public ConnectorState getConnectorState()
getConnectorState
in interface DocumentConnector
public int getBatchSize()
public void setBatchSize(int batchSize)
public java.lang.String getDocIdPrefix()
public void setDocIdPrefix(java.lang.String docIdPrefix)