public interface IOutgoingBatchService
| Modifier and Type | Method and Description |
|---|---|
boolean |
areAllLoadBatchesComplete(java.lang.String nodeId) |
int |
cancelLoadBatches(long loadId) |
void |
copyOutgoingBatches(java.lang.String channelId,
long startBatchId,
java.lang.String fromNodeId,
java.lang.String toNodeId) |
int |
countOutgoingBatches(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) |
int |
countOutgoingBatchesInError() |
int |
countOutgoingBatchesInError(java.lang.String channelId) |
java.util.Map<java.lang.String,java.lang.Integer> |
countOutgoingBatchesPendingByChannel(java.lang.String nodeId) |
int |
countOutgoingBatchesUnsent() |
int |
countOutgoingBatchesUnsent(java.lang.String channelId) |
int |
countOutgoingBatchesUnsentHeartbeat() |
int |
countUnsentBatchesByTargetNode(java.lang.String nodeId) |
long |
countUnsentRowsByTargetNode(java.lang.String nodeId) |
OutgoingBatch |
findOutgoingBatch(long batchId,
java.lang.String nodeId) |
java.util.List<OutgoingBatchSummary> |
findOutgoingBatchSummary(AbstractBatch.Status... statuses) |
java.util.List<OutgoingBatchSummary> |
findOutgoingBatchSummaryByChannel(AbstractBatch.Status... statuses) |
java.util.List<OutgoingBatchSummary> |
findOutgoingBatchSummaryByNode(java.lang.String nodeId,
java.util.Date sinceCreateTime,
AbstractBatch.Status... statuses) |
java.util.List<java.lang.Long> |
getAllBatches() |
java.util.List<java.lang.String> |
getNodesInError() |
OutgoingBatches |
getOutgoingBatchByLoad(long loadI) |
OutgoingBatches |
getOutgoingBatchByLoadRangeAndTable(long loadId,
long startBatchId,
long endBatchId,
java.lang.String tableName) |
OutgoingBatches |
getOutgoingBatchErrors(int maxRows) |
OutgoingBatches |
getOutgoingBatches(java.lang.String nodeId,
boolean includeDisabledChannels) |
OutgoingBatches |
getOutgoingBatches(java.lang.String nodeId,
java.lang.String channelId,
boolean includeDisabledChannels) |
OutgoingBatches |
getOutgoingBatches(java.lang.String nodeId,
java.lang.String channelThread,
NodeGroupLinkAction eventAction,
NodeGroupLinkAction defaultEventAction,
boolean includeDisabledChannels) |
OutgoingBatches |
getOutgoingBatchRange(long startBatchId,
long endBatchId) |
OutgoingBatches |
getOutgoingBatchRange(java.lang.String nodeId,
java.util.Date startDate,
java.util.Date endDate,
java.lang.String... channels) |
void |
insertOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
OutgoingBatch outgoingBatch) |
void |
insertOutgoingBatch(OutgoingBatch outgoingBatch) |
void |
insertOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
java.util.List<OutgoingBatch> batches,
int flushSize,
boolean isCommon) |
boolean |
isInitialLoadComplete(java.lang.String nodeId) |
boolean |
isUnsentDataOnChannelForNode(java.lang.String channelId,
java.lang.String nodeId) |
java.util.List<OutgoingBatch> |
listOutgoingBatches(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,
long startAtBatchId,
int rowsExpected,
boolean ascending) |
void |
markAllAsSentForNode(java.lang.String nodeId,
boolean includeConfigChannel) |
void |
markAllConfigAsSentForNode(java.lang.String nodeId) |
void |
updateAbandonedRoutingBatches() |
void |
updateCommonBatchExtractStatistics(OutgoingBatch batch) |
void |
updateOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
OutgoingBatch outgoingBatch) |
void |
updateOutgoingBatch(OutgoingBatch batch) |
void |
updateOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
java.util.List<OutgoingBatch> batches,
int flushSize) |
void |
updateOutgoingBatches(java.util.List<OutgoingBatch> batches) |
void |
updateOutgoingBatchStatus(org.jumpmind.db.sql.ISqlTransaction transaction,
AbstractBatch.Status status,
java.lang.String nodeId,
long startBatchId,
long endBatchId) |
java.util.List<java.lang.String> getNodesInError()
void markAllAsSentForNode(java.lang.String nodeId,
boolean includeConfigChannel)
void markAllConfigAsSentForNode(java.lang.String nodeId)
void updateAbandonedRoutingBatches()
OutgoingBatch findOutgoingBatch(long batchId, java.lang.String nodeId)
OutgoingBatches getOutgoingBatches(java.lang.String nodeId, boolean includeDisabledChannels)
OutgoingBatches getOutgoingBatches(java.lang.String nodeId, java.lang.String channelId, boolean includeDisabledChannels)
OutgoingBatches getOutgoingBatches(java.lang.String nodeId, java.lang.String channelThread, NodeGroupLinkAction eventAction, NodeGroupLinkAction defaultEventAction, boolean includeDisabledChannels)
OutgoingBatches getOutgoingBatchRange(long startBatchId, long endBatchId)
OutgoingBatches getOutgoingBatchByLoad(long loadI)
OutgoingBatches getOutgoingBatchByLoadRangeAndTable(long loadId, long startBatchId, long endBatchId, java.lang.String tableName)
int cancelLoadBatches(long loadId)
OutgoingBatches getOutgoingBatchRange(java.lang.String nodeId, java.util.Date startDate, java.util.Date endDate, java.lang.String... channels)
OutgoingBatches getOutgoingBatchErrors(int maxRows)
boolean isInitialLoadComplete(java.lang.String nodeId)
boolean areAllLoadBatchesComplete(java.lang.String nodeId)
boolean isUnsentDataOnChannelForNode(java.lang.String channelId,
java.lang.String nodeId)
void updateOutgoingBatch(OutgoingBatch batch)
void updateOutgoingBatchStatus(org.jumpmind.db.sql.ISqlTransaction transaction,
AbstractBatch.Status status,
java.lang.String nodeId,
long startBatchId,
long endBatchId)
void updateCommonBatchExtractStatistics(OutgoingBatch batch)
void updateOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
OutgoingBatch outgoingBatch)
void updateOutgoingBatches(java.util.List<OutgoingBatch> batches)
void updateOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
java.util.List<OutgoingBatch> batches,
int flushSize)
void insertOutgoingBatch(OutgoingBatch outgoingBatch)
void insertOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
OutgoingBatch outgoingBatch)
void insertOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
java.util.List<OutgoingBatch> batches,
int flushSize,
boolean isCommon)
int countOutgoingBatchesInError()
int countOutgoingBatchesUnsent()
int countOutgoingBatchesInError(java.lang.String channelId)
int countOutgoingBatchesUnsent(java.lang.String channelId)
int countOutgoingBatchesUnsentHeartbeat()
java.util.Map<java.lang.String,java.lang.Integer> countOutgoingBatchesPendingByChannel(java.lang.String nodeId)
long countUnsentRowsByTargetNode(java.lang.String nodeId)
int countUnsentBatchesByTargetNode(java.lang.String nodeId)
java.util.List<OutgoingBatchSummary> findOutgoingBatchSummary(AbstractBatch.Status... statuses)
java.util.List<OutgoingBatchSummary> findOutgoingBatchSummaryByChannel(AbstractBatch.Status... statuses)
java.util.List<OutgoingBatchSummary> findOutgoingBatchSummaryByNode(java.lang.String nodeId, java.util.Date sinceCreateTime, AbstractBatch.Status... statuses)
int countOutgoingBatches(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.List<OutgoingBatch> listOutgoingBatches(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, long startAtBatchId, int rowsExpected, boolean ascending)
void copyOutgoingBatches(java.lang.String channelId,
long startBatchId,
java.lang.String fromNodeId,
java.lang.String toNodeId)
java.util.List<java.lang.Long> getAllBatches()