org.ikasan.spec.exclusion

Interface ExclusionEventDao<IDENTIFIER,EVENT>

public interface ExclusionEventDao<IDENTIFIER,EVENT>

Exclusion Event Data Access Contract.

Author:

Ikasan Development Team

Method Summary

Modifier and Type	Method and Description
void	delete(String errorUri) Remove the event
void	delete(String moduleName, String flowName, IDENTIFIER identifier) Remove the event
void	deleteAllExpired() Delete all e
org.ikasan.spec.search.PagedSearchResult<EVENT>	find(int pageNo, int pageSize, String orderBy, boolean orderAscending, String moduleName, String flowName, String componentName, IDENTIFIER identifier, Date fromDate, Date untilDate) Perform a paged search for ExclusionEvents
List<EVENT>	find(List<String> moduleName, List<String> flowName, Date starteDate, Date endDate, IDENTIFIER identifier, int size) Find a list of event entities based on criteria.
EVENT	find(String errorUri) Find the event based on it's URI
EVENT	find(String moduleName, String flowName, IDENTIFIER identifier) Find a specific excluded event
List<EVENT>	findAll() Find all excluded events
List<EVENT>	getHarvestableRecords(int housekeepingBatchSize) Get (housekeepingBatchSize) harvestable records.
Long	rowCount(List<String> moduleName, List<String> flowName, Date startDate, Date endDate, String identifier) Get the row count for the given criteria.
void	save(EVENT event) Save the event
void	save(List<EVENT> events) Save a list of events
void	updateAsHarvested(List<EVENT> events) Update entity as being harvested.

Method Detail

save

void save(EVENT event)

Save the event

Parameters:

event -

save

void save(List<EVENT> events)

Save a list of events

Parameters:

events -

delete

void delete(String moduleName,
            String flowName,
            IDENTIFIER identifier)

Remove the event

Parameters:

moduleName -

flowName -

identifier -

delete

void delete(String errorUri)

Remove the event

Parameters:

errorUri -

find

EVENT find(String moduleName,
           String flowName,
           IDENTIFIER identifier)

Find a specific excluded event

Parameters:

moduleName -

flowName -

identifier -

Returns:

rowCount

Long rowCount(List<String> moduleName,
              List<String> flowName,
              Date startDate,
              Date endDate,
              String identifier)

Get the row count for the given criteria.

Parameters:

moduleName -

flowName -

startDate -

endDate -

identifier -

Returns:

findAll

List<EVENT> findAll()

Find all excluded events

Returns:

find

org.ikasan.spec.search.PagedSearchResult<EVENT> find(int pageNo,
                                                     int pageSize,
                                                     String orderBy,
                                                     boolean orderAscending,
                                                     String moduleName,
                                                     String flowName,
                                                     String componentName,
                                                     IDENTIFIER identifier,
                                                     Date fromDate,
                                                     Date untilDate)

Perform a paged search for ExclusionEvents

Parameters:

pageNo - - The page number to retrieve

pageSize - - The size of the page

orderBy - - order by field

orderAscending - - ascending flag

moduleName - - The module name

flowName - - The name of Flow internal to the Module

componentName - - The component name

fromDate - - The from date

untilDate - - The to date

Returns:

PagedSearchResult

find

List<EVENT> find(List<String> moduleName,
                 List<String> flowName,
                 Date starteDate,
                 Date endDate,
                 IDENTIFIER identifier,
                 int size)

Find a list of event entities based on criteria.

Parameters:

moduleName -

flowName -

starteDate -

endDate -

identifier -

size -

Returns:

find

EVENT find(String errorUri)

Find the event based on it's URI

Parameters:

errorUri -

Returns:

getHarvestableRecords

List<EVENT> getHarvestableRecords(int housekeepingBatchSize)

Get (housekeepingBatchSize) harvestable records.

Parameters:

housekeepingBatchSize -

Returns:

deleteAllExpired

void deleteAllExpired()

Delete all e

updateAsHarvested

void updateAsHarvested(List<EVENT> events)

Update entity as being harvested.

Parameters:

events -