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 and Description
boolean	acquireIncomingBatch(IncomingBatch batch)
int	countIncomingBatchesInError()
int	countIncomingBatchesInError(java.lang.String channelId)
int	deleteIncomingBatch(IncomingBatch batch)
IncomingBatch	findIncomingBatch(long batchId, java.lang.String nodeId)
java.util.List<IncomingBatch>	findIncomingBatchErrors(int maxRows)
java.util.List<IncomingBatchSummary>	findIncomingBatchSummary(AbstractBatch.Status... statuses)
java.util.List<IncomingBatchSummary>	findIncomingBatchSummaryByChannel(AbstractBatch.Status... statuses)
java.util.List<IncomingBatchSummary>	findIncomingBatchSummaryByNode(java.lang.String nodeId, java.util.Date sinceCreateTime, AbstractBatch.Status... statuses)
java.util.List<IncomingBatchSummary>	findIncomingBatchSummaryByNodeAndChannel(java.lang.String nodeId, java.lang.String channelId, java.util.Date sinceCreateTime, AbstractBatch.Status... statuses)
java.util.Map<java.lang.String,java.util.Date>	findLastUpdatedByChannel()
java.util.Map<java.lang.String,BatchId>	findMaxBatchIdsByChannel()
java.util.List<BatchId>	getAllBatches()
java.util.List<java.lang.String>	getNodesInError()
void	insertIncomingBatch(IncomingBatch batch)
void	insertIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, IncomingBatch batch)
boolean	isRecordOkBatchesEnabled()
java.util.List<IncomingBatch>	listIncomingBatches(java.util.List<java.lang.String> nodeIds, java.util.List<java.lang.String> channels, java.util.List<AbstractBatch.Status> statuses, java.util.List<java.lang.Long> loads, java.util.Date startAtCreateTime, int maxRowsToRetrieve, boolean ascending)
java.util.List<IncomingBatch>	listIncomingBatchesInErrorFor(java.lang.String nodeId)
java.util.List<java.util.Date>	listIncomingBatchTimes(java.util.List<java.lang.String> nodeIds, java.util.List<java.lang.String> channels, java.util.List<AbstractBatch.Status> statuses, java.util.List<java.lang.Long> loads, boolean ascending)
void	markIncomingBatchesOk(java.lang.String nodeId)
void	refreshIncomingBatch(IncomingBatch batch)
void	removingIncomingBatches(java.lang.String nodeId)
int	updateIncomingBatch(IncomingBatch batch)
int	updateIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, IncomingBatch batch)

Method Detail

getNodesInError

java.util.List<java.lang.String> getNodesInError()

countIncomingBatchesInError

int countIncomingBatchesInError()

countIncomingBatchesInError

int countIncomingBatchesInError(java.lang.String channelId)

findIncomingBatch

IncomingBatch findIncomingBatch(long batchId,
                                java.lang.String nodeId)

refreshIncomingBatch

void refreshIncomingBatch(IncomingBatch batch)

findIncomingBatchErrors

java.util.List<IncomingBatch> findIncomingBatchErrors(int maxRows)

acquireIncomingBatch

boolean acquireIncomingBatch(IncomingBatch batch)

insertIncomingBatch

void insertIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                         IncomingBatch batch)

insertIncomingBatch

void insertIncomingBatch(IncomingBatch batch)

updateIncomingBatch

int updateIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                        IncomingBatch batch)

updateIncomingBatch

int updateIncomingBatch(IncomingBatch batch)

deleteIncomingBatch

int deleteIncomingBatch(IncomingBatch batch)

listIncomingBatchTimes

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

listIncomingBatches

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

markIncomingBatchesOk

void markIncomingBatchesOk(java.lang.String nodeId)

removingIncomingBatches

void removingIncomingBatches(java.lang.String nodeId)

listIncomingBatchesInErrorFor

java.util.List<IncomingBatch> listIncomingBatchesInErrorFor(java.lang.String nodeId)

isRecordOkBatchesEnabled

boolean isRecordOkBatchesEnabled()

findMaxBatchIdsByChannel

java.util.Map<java.lang.String,BatchId> findMaxBatchIdsByChannel()

findIncomingBatchSummaryByChannel

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

findIncomingBatchSummary

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

findIncomingBatchSummaryByNode

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

findIncomingBatchSummaryByNodeAndChannel

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

findLastUpdatedByChannel

java.util.Map<java.lang.String,java.util.Date> findLastUpdatedByChannel()

getAllBatches

java.util.List<BatchId> getAllBatches()