org.nuxeo.elasticsearch.commands

Class IndexingCommand

java.lang.Object

org.nuxeo.elasticsearch.commands.IndexingCommand

All Implemented Interfaces:

Serializable

public class IndexingCommand
extends Object
implements Serializable

Holds information about what type of indexing operation must be processed. IndexingCommands are create "on the fly" via a Synchronous event listener and at commit time the system will merge the commands and generate events for the sync commands.

Author:

Tiry

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELETE
static String	INSERT
static String	PREFIX
static String	UNKOWN_DOCUMENT_ID
static String	UPDATE
static String	UPDATE_SECURITY

Constructor Summary

Constructors

Constructor and Description
IndexingCommand(DocumentModel targetDocument, boolean sync, boolean recurse)
IndexingCommand(DocumentModel targetDocument, String command, boolean sync, boolean recurse)

Method Summary

Methods

Modifier and Type	Method and Description
void	addSchemas(String schema)
Event	asIndexingEvent()
boolean	canBeMerged(IndexingCommand other)
IndexingCommand	clone(DocumentModel newDoc)
void	computeIndexingEvent()
void	disconnect()
static IndexingCommand	fromJSON(CoreSession session, org.codehaus.jackson.JsonParser jp)
static IndexingCommand	fromJSON(CoreSession session, String json)
String	getDocId()
String	getId()
String	getName()
String	getRepository()
String[]	getSchemas()
DocumentModel	getTargetDocument()
boolean	isRecurse()
boolean	isSync()
void	makeSync() Try to make the command synchronous.
void	merge(boolean sync, boolean recurse)
void	merge(IndexingCommand other)
void	refresh(CoreSession session)
String	toJSON()
void	toJSON(org.codehaus.jackson.JsonGenerator jsonGen)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

INSERT

public static final String INSERT

See Also:

Constant Field Values

UPDATE

public static final String UPDATE

See Also:

Constant Field Values

UPDATE_SECURITY

public static final String UPDATE_SECURITY

See Also:

Constant Field Values

DELETE

public static final String DELETE

See Also:

Constant Field Values

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

UNKOWN_DOCUMENT_ID

public static final String UNKOWN_DOCUMENT_ID

See Also:

Constant Field Values

Constructor Detail

IndexingCommand

public IndexingCommand(DocumentModel targetDocument,
               String command,
               boolean sync,
               boolean recurse)

IndexingCommand

public IndexingCommand(DocumentModel targetDocument,
               boolean sync,
               boolean recurse)

Method Detail

refresh

public void refresh(CoreSession session)
             throws ClientException

Throws:

ClientException

getRepository

public String getRepository()

merge

public void merge(IndexingCommand other)

merge

public void merge(boolean sync,
         boolean recurse)

canBeMerged

public boolean canBeMerged(IndexingCommand other)

isSync

public boolean isSync()

isRecurse

public boolean isRecurse()

getName

public String getName()

getTargetDocument

public DocumentModel getTargetDocument()

toJSON

public String toJSON()
              throws IOException

Throws:

IOException

toJSON

public void toJSON(org.codehaus.jackson.JsonGenerator jsonGen)
            throws IOException

Throws:

IOException

fromJSON

public static IndexingCommand fromJSON(CoreSession session,
                       String json)
                                throws ClientException

Throws:

ClientException

fromJSON

public static IndexingCommand fromJSON(CoreSession session,
                       org.codehaus.jackson.JsonParser jp)
                                throws Exception

Throws:

Exception

getId

public String getId()

getDocId

public String getDocId()

clone

public IndexingCommand clone(DocumentModel newDoc)

getSchemas

public String[] getSchemas()

addSchemas

public void addSchemas(String schema)

toString

public String toString()

Overrides:

toString in class Object

computeIndexingEvent

public void computeIndexingEvent()

asIndexingEvent

public Event asIndexingEvent()
                      throws IOException

Throws:

IOException

makeSync

public void makeSync()

Try to make the command synchronous. Recurse command will stay in async for update.

disconnect

public void disconnect()