com.attivio.sdk.service

Class MockIngestApi

java.lang.Object

com.attivio.sdk.service.MockIngestApi

All Implemented Interfaces:

com.attivio.service.IngestApi

public class MockIngestApi
extends Object
implements com.attivio.service.IngestApi

A mock implementation of IngestApi that keeps a list of all messages sent to it. Messages may be retrieved with getMessage(Class) and the list may be reset with reset(). If a MockIngestApi is in use via a standard ContentFeeder, you can get the mock api in use via ServiceFactory.getService(MockIngestApi.class).

The public member msgs can also be accessed directly. Any test which is using msgs to check test conditions should call reset() at the beginning of the test as the instance retrieved by the test may have side-effects from previous tests.

This class simulates the processing of messages by posting CREATED and COMPLETED audit records for each documents. This allows it to be used by a ContentFeeder. The getCompletionDelay() field controls the number of milliseconds to delay the posting of the COMPLETED audit record after the CREATED is posted. The completion delay is set to 0 whenever the reset() method is called.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MockIngestApi.MockAuditDetail

Field Summary

Fields

Modifier and Type	Field and Description
ArrayList<PlatformMessage>	msgs

Fields inherited from interface com.attivio.service.IngestApi

ENDPOINT

Constructor Summary

Constructors

Constructor and Description
MockIngestApi()

Method Summary

Modifier and Type	Method and Description
void	feed(PlatformMessage msg)
long	getCompletionDelay()
<T> T	getMessage(Class<T> clazz) Get the first message of the type clazz
List<PlatformMessage>	getMessages()
void	reset()
void	setCompletionDelay(long completionDelay) Sets the new delay.

Methods inherited from class java.lang.Object

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

Field Detail

msgs

public ArrayList<PlatformMessage> msgs

Constructor Detail

MockIngestApi

public MockIngestApi()
              throws AttivioException

Throws:

AttivioException

Method Detail

feed

public void feed(PlatformMessage msg)
          throws AttivioException

Specified by:

feed in interface com.attivio.service.IngestApi

Throws:

AttivioException

getMessage

public <T> T getMessage(Class<T> clazz)

Get the first message of the type clazz

Parameters:

clazz -

Returns:

getMessages

public List<PlatformMessage> getMessages()

reset

public void reset()

getCompletionDelay

public long getCompletionDelay()

Returns:

the number of milliseconds before messages are COMPLETED.

setCompletionDelay

public void setCompletionDelay(long completionDelay)

Sets the new delay. Note, the delay is reset to 0 whenever reset() is called.

Parameters:

completionDelay -