public interface IIncomingBatchService
| 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) |
java.util.List<java.lang.String> getNodesInError()
int countIncomingBatchesInError()
int countIncomingBatchesInError(java.lang.String channelId)
IncomingBatch findIncomingBatch(long batchId, java.lang.String nodeId)
void refreshIncomingBatch(IncomingBatch batch)
java.util.List<IncomingBatch> findIncomingBatchErrors(int maxRows)
boolean acquireIncomingBatch(IncomingBatch batch)
void insertIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
IncomingBatch batch)
void insertIncomingBatch(IncomingBatch batch)
int updateIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
IncomingBatch batch)
int updateIncomingBatch(IncomingBatch batch)
int deleteIncomingBatch(IncomingBatch batch)
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)
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)
void markIncomingBatchesOk(java.lang.String nodeId)
void removingIncomingBatches(java.lang.String nodeId)
java.util.List<IncomingBatch> listIncomingBatchesInErrorFor(java.lang.String nodeId)
boolean isRecordOkBatchesEnabled()
java.util.Map<java.lang.String,BatchId> findMaxBatchIdsByChannel()
java.util.List<IncomingBatchSummary> findIncomingBatchSummaryByChannel(AbstractBatch.Status... statuses)
java.util.List<IncomingBatchSummary> findIncomingBatchSummary(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.List<BatchId> getAllBatches()