com.attivio.sdk.test

Class MockIngestClient

java.lang.Object

com.attivio.sdk.test.MockIngestClient

All Implemented Interfaces:

DocumentOutputClient, SecurityFeeder

public class MockIngestClient
extends Object
implements DocumentOutputClient

Constructor Summary

Constructors

Constructor and Description
MockIngestClient()

Method Summary

Modifier and Type	Method and Description
void	bulkUpdate(BulkUpdate message) Send message to AIE.
void	clear()
boolean	containsDocumentWithId(String docId)
void	delete(Collection<String> ids) See DocumentOutputClient.delete(String...) for documentation.
void	delete(String... ids) Delete a series of documents from AIE by document id.
void	deleteByQuery(String queryWorkflows, Query query) Delete all documents that match the Query.
void	deletePrincipal(AttivioPrincipalKey key) Deletes a principal from the index.
void	endMessageGroup() Ends the current message group (if any).
void	feed(AttivioPrincipal principal) Ingests an AttivioPrincipal.
void	feed(IngestDocument... docs) Send docs to AIE.
void	feed(IngestDocument doc, AttivioAcl acl) Sends doc to the document receiver with the given ACL.
void	feed(Iterable<IngestDocument> docs) Send docs to AIE.
List<BulkUpdate>	getBulkList()
List<IngestDocument>	getDocumentList()
long	getDocumentsSent()
IngestDocument	getDocumentWithId(String docId)
boolean	isMessageGroupInProgress()
void	startMessageGroup() Starts a group of messages that will be processed together.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MockIngestClient

public MockIngestClient()

Method Detail

delete

public void delete(String... ids)
            throws AttivioException

Description copied from interface: DocumentOutputClient

Delete a series of documents from AIE by document id.

If batching is enabled, then these delete messages will be batched along with any fed documents.

If these deletes are meant to apply to uncommitted documents previously fed with this ContentFeeder, then those documents must be committed to the index before this delete is called. When ordered commits is enabled, this entails calling:

   contentFeeder.commit();
   contentFeeder.waitForCompletion();
   contentFeeder.delete("id1",...);
 

When ordered commits is disabled, it entails calling:

   contentFeeder.waitForCompletion();
   contentFeeder.commit();
   contentFeeder.waitForCompletion();
   contentFeeder.delete("id1",...);
 

Specified by:

delete in interface DocumentOutputClient

Parameters:

ids - The document IDs of the documents to delete.

Throws:

AttivioException - if sending of deletes fails.

delete

public void delete(Collection<String> ids)
            throws AttivioException

Description copied from interface: DocumentOutputClient

See DocumentOutputClient.delete(String...) for documentation.

Specified by:

delete in interface DocumentOutputClient

Throws:

AttivioException

deleteByQuery

public void deleteByQuery(String queryWorkflows,
                          Query query)
                   throws AttivioException

Description copied from interface: DocumentOutputClient

Delete all documents that match the Query.

If documents are currently batched up, then those documents will be sent along with this delete.

Use DocumentOutputClient.bulkUpdate(BulkUpdate) to feed more complicated delete queries.

If these deletes are meant to apply to uncommitted documents previously fed with this ContentFeeder, then those documents must be committed to the index before this delete is called. When ordered commits is enabled, this entails calling:

 contentFeeder.commit();
 contentFeeder.waitForCompletion();
 contentFeeder.delete("id1",...);
 

When ordered commits is disabled, it entails calling:

 contentFeeder.waitForCompletion();
 contentFeeder.commit();
 contentFeeder.waitForCompletion();
 contentFeeder.delete(...);
 

Specified by:

deleteByQuery in interface DocumentOutputClient

Parameters:

queryWorkflows - the query workflow or null if none needed

query - query to delete by

Throws:

AttivioException

bulkUpdate

public void bulkUpdate(BulkUpdate message)

Description copied from interface: DocumentOutputClient

Send message to AIE.

Specified by:

bulkUpdate in interface DocumentOutputClient

feed

public void feed(IngestDocument... docs)
          throws AttivioException

Description copied from interface: DocumentOutputClient

Send docs to AIE.

Specified by:

feed in interface DocumentOutputClient

Parameters:

docs - the documents to send.

Throws:

AttivioException

feed

public void feed(Iterable<IngestDocument> docs)
          throws AttivioException

Description copied from interface: DocumentOutputClient

Send docs to AIE.

Specified by:

feed in interface DocumentOutputClient

Parameters:

docs - the documents to send.

Throws:

AttivioException

getDocumentsSent

public long getDocumentsSent()

isMessageGroupInProgress

public boolean isMessageGroupInProgress()

Specified by:

isMessageGroupInProgress in interface DocumentOutputClient

Returns:

true if a message group has been started and not yet ended.

startMessageGroup

public void startMessageGroup()
                       throws AttivioException

Description copied from interface: DocumentOutputClient

Starts a group of messages that will be processed together. All documents and deletes in the group will be processed together and in the order created.

NOTE: failure to end a started message group will cause the last message of the group in progress to not be sent.

Specified by:

startMessageGroup in interface DocumentOutputClient

Throws:

AttivioException

endMessageGroup

public void endMessageGroup()
                     throws AttivioException

Description copied from interface: DocumentOutputClient

Ends the current message group (if any). The next feed or delete will not be part of any group unless DocumentOutputClient.startMessageGroup() is called again.

Specified by:

endMessageGroup in interface DocumentOutputClient

Throws:

AttivioException

feed

public void feed(IngestDocument doc,
                 AttivioAcl acl)
          throws AttivioException

Description copied from interface: SecurityFeeder

Sends doc to the document receiver with the given ACL.

Specified by:

feed in interface SecurityFeeder

Parameters:

doc - the document

acl - the ACL

Throws:

AttivioException

feed

public void feed(AttivioPrincipal principal)
          throws AttivioException

Description copied from interface: SecurityFeeder

Ingests an AttivioPrincipal. Any existing data for the principal and its associations will be deleted.

Specified by:

feed in interface SecurityFeeder

Parameters:

principal - the principal

Throws:

AttivioException

deletePrincipal

public void deletePrincipal(AttivioPrincipalKey key)
                     throws AttivioException

Description copied from interface: SecurityFeeder

Deletes a principal from the index.

Specified by:

deletePrincipal in interface SecurityFeeder

Parameters:

key - unique ID of the principal

Throws:

AttivioException

containsDocumentWithId

public boolean containsDocumentWithId(String docId)

getDocumentWithId

public IngestDocument getDocumentWithId(String docId)

getDocumentList

public List<IngestDocument> getDocumentList()

getBulkList

public List<BulkUpdate> getBulkList()

clear

public void clear()