org.myrobotlab.document.connector

Class AbstractConnector

java.lang.Object

org.myrobotlab.framework.MessageService

org.myrobotlab.framework.Service

org.myrobotlab.document.connector.AbstractConnector

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable, Attachable, Invoker, LoggingSink, MessageSender, MessageSubscriber, NameProvider, NameTypeProvider, ServiceInterface, ServiceQueue, StateSaver, TypeProvider, DocumentConnector, DocumentPublisher, QueueReporter

Direct Known Subclasses:

CsvConnector, DatabaseConnector, FileConnector, ImapEmailConnector, RSSConnector, XMLConnector

public abstract class AbstractConnector
extends Service
implements DocumentPublisher, DocumentConnector

AbstractConnector - base class for implementing a new document connector service.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.myrobotlab.framework.Service

cfgDir, dnaPool, log, MESSAGE_RECORDING_FORMAT_BINARY, MESSAGE_RECORDING_FORMAT_XML

Constructor Summary

Constructors

Constructor and Description
AbstractConnector(java.lang.String name)

Method Summary

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)

Methods inherited from class org.myrobotlab.framework.Service

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.myrobotlab.service.interfaces.DocumentPublisher

getName

Methods inherited from interface org.myrobotlab.service.interfaces.DocumentConnector

startCrawling, stopCrawling

Constructor Detail

AbstractConnector

public AbstractConnector(java.lang.String name)

Method Detail

setConfig

public abstract void setConfig(ConnectorConfig config)

feed

public void feed(Document doc)

publishFlush

public void publishFlush()

flush

public void flush()

getState

public ConnectorState getState()

setState

public void setState(ConnectorState state)

publishDocument

public Document publishDocument(Document doc)

Specified by:

publishDocument in interface DocumentPublisher

publishDocuments

public java.util.List<Document> publishDocuments(java.util.List<Document> batch)

addDocumentListener

public void addDocumentListener(DocumentListener listener)

Specified by:

addDocumentListener in interface DocumentPublisher

getConnectorState

public ConnectorState getConnectorState()

Specified by:

getConnectorState in interface DocumentConnector

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getDocIdPrefix

public java.lang.String getDocIdPrefix()

setDocIdPrefix

public void setDocIdPrefix(java.lang.String docIdPrefix)