Package org.jumpmind.symmetric.service

Interface IIncomingBatchService

All Known Implementing Classes:

IncomingBatchService

public interface IIncomingBatchService

This service provides an API to access to the incoming batch table.

Method Summary

Modifier and Type	Method	Description
boolean	acquireIncomingBatch(IncomingBatch batch)
int	countIncomingBatchesInError()
int	countIncomingBatchesInError(String channelId)
int	countIncomingBatchesWithLimit(List<FilterCriterion> filter)
int	deleteIncomingBatch(IncomingBatch batch)
IncomingBatch	findIncomingBatch(long batchId, String nodeId)
List<IncomingBatch>	findIncomingBatchErrors(int maxRows)
List<IncomingBatchSummary>	findIncomingBatchSummary(AbstractBatch.Status... statuses)
List<IncomingBatchSummary>	findIncomingBatchSummaryByChannel(AbstractBatch.Status... statuses)
List<IncomingBatchSummary>	findIncomingBatchSummaryByNode(String nodeId, Date sinceCreateTime, AbstractBatch.Status... statuses)
List<IncomingBatchSummary>	findIncomingBatchSummaryByNodeAndChannel(String nodeId, String channelId, Date sinceCreateTime, AbstractBatch.Status... statuses)
Map<String,Date>	findLastUpdatedByChannel()
Map<String,BatchId>	findMaxBatchIdsByChannel()
List<BatchId>	getAllBatches()
Date	getIncomingBatchesLatestUpdateSql()
List<String>	getNodesInError()
Collection<String>	getReadyQueues(String sourceNodeId)
void	insertIncomingBatch(ISqlTransaction transaction, IncomingBatch batch)
void	insertIncomingBatch(IncomingBatch batch)
boolean	isRecordOkBatchesEnabled()
List<IncomingBatch>	listIncomingBatches(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads, Date startAtCreateTime, Date startAtLastUpdateTime, int maxRowsToRetrieve, boolean ascending)
List<IncomingBatch>	listIncomingBatchesInErrorFor(String nodeId)
List<IncomingBatch>	listIncomingBatchesWithLimit(int offset, int limit, List<FilterCriterion> filter, String orderColumn, String orderDirection)
List<Date>	listIncomingBatchTimes(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads, boolean ascending)
void	markIncomingBatchesOk(String nodeId)
void	refreshIncomingBatch(IncomingBatch batch)
void	removingIncomingBatches(String nodeId)
void	setReadyQueues(String sourceNodeId, Collection<String> queues)
int	updateIncomingBatch(ISqlTransaction transaction, IncomingBatch batch)
int	updateIncomingBatch(IncomingBatch batch)

Method Details

getNodesInError

List<String> getNodesInError()

countIncomingBatchesInError

int countIncomingBatchesInError()

countIncomingBatchesInError

int countIncomingBatchesInError(String channelId)

getIncomingBatchesLatestUpdateSql

Date getIncomingBatchesLatestUpdateSql()

findIncomingBatch

IncomingBatch findIncomingBatch(long batchId,
 String nodeId)

refreshIncomingBatch

void refreshIncomingBatch(IncomingBatch batch)

findIncomingBatchErrors

List<IncomingBatch> findIncomingBatchErrors(int maxRows)

acquireIncomingBatch

boolean acquireIncomingBatch(IncomingBatch batch)

insertIncomingBatch

void insertIncomingBatch(ISqlTransaction transaction,
 IncomingBatch batch)

insertIncomingBatch

void insertIncomingBatch(IncomingBatch batch)

updateIncomingBatch

int updateIncomingBatch(ISqlTransaction transaction,
 IncomingBatch batch)

updateIncomingBatch

int updateIncomingBatch(IncomingBatch batch)

deleteIncomingBatch

int deleteIncomingBatch(IncomingBatch batch)

listIncomingBatchTimes

List<Date> listIncomingBatchTimes(List<String> nodeIds,
 List<String> channels,
 List<AbstractBatch.Status> statuses,
 List<Long> loads,
 boolean ascending)

listIncomingBatches

List<IncomingBatch> listIncomingBatches(List<String> nodeIds,
 List<String> channels,
 List<AbstractBatch.Status> statuses,
 List<Long> loads,
 Date startAtCreateTime,
 Date startAtLastUpdateTime,
 int maxRowsToRetrieve,
 boolean ascending)

listIncomingBatchesWithLimit

List<IncomingBatch> listIncomingBatchesWithLimit(int offset,
 int limit,
 List<FilterCriterion> filter,
 String orderColumn,
 String orderDirection)

countIncomingBatchesWithLimit

int countIncomingBatchesWithLimit(List<FilterCriterion> filter)

markIncomingBatchesOk

void markIncomingBatchesOk(String nodeId)

removingIncomingBatches

void removingIncomingBatches(String nodeId)

listIncomingBatchesInErrorFor

List<IncomingBatch> listIncomingBatchesInErrorFor(String nodeId)

isRecordOkBatchesEnabled

boolean isRecordOkBatchesEnabled()

findMaxBatchIdsByChannel

Map<String,BatchId> findMaxBatchIdsByChannel()

findIncomingBatchSummaryByChannel

List<IncomingBatchSummary> findIncomingBatchSummaryByChannel(AbstractBatch.Status... statuses)

findIncomingBatchSummary

List<IncomingBatchSummary> findIncomingBatchSummary(AbstractBatch.Status... statuses)

findIncomingBatchSummaryByNode

List<IncomingBatchSummary> findIncomingBatchSummaryByNode(String nodeId,
 Date sinceCreateTime,
 AbstractBatch.Status... statuses)

findIncomingBatchSummaryByNodeAndChannel

List<IncomingBatchSummary> findIncomingBatchSummaryByNodeAndChannel(String nodeId,
 String channelId,
 Date sinceCreateTime,
 AbstractBatch.Status... statuses)

findLastUpdatedByChannel

Map<String,Date> findLastUpdatedByChannel()

getAllBatches

List<BatchId> getAllBatches()

getReadyQueues

Collection<String> getReadyQueues(String sourceNodeId)

setReadyQueues

void setReadyQueues(String sourceNodeId,
 Collection<String> queues)