org.jumpmind.symmetric.service

Interface IOutgoingBatchService

All Known Implementing Classes:

OutgoingBatchService

public interface IOutgoingBatchService

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

Method Summary

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)

Method Detail

getNodesInError

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

markAllAsSentForNode

void markAllAsSentForNode(java.lang.String nodeId,
                          boolean includeConfigChannel)

markAllConfigAsSentForNode

void markAllConfigAsSentForNode(java.lang.String nodeId)

updateAbandonedRoutingBatches

void updateAbandonedRoutingBatches()

findOutgoingBatch

OutgoingBatch findOutgoingBatch(long batchId,
                                java.lang.String nodeId)

getOutgoingBatches

OutgoingBatches getOutgoingBatches(java.lang.String nodeId,
                                   boolean includeDisabledChannels)

getOutgoingBatches

OutgoingBatches getOutgoingBatches(java.lang.String nodeId,
                                   java.lang.String channelId,
                                   boolean includeDisabledChannels)

getOutgoingBatches

OutgoingBatches getOutgoingBatches(java.lang.String nodeId,
                                   java.lang.String channelThread,
                                   NodeGroupLinkAction eventAction,
                                   NodeGroupLinkAction defaultEventAction,
                                   boolean includeDisabledChannels)

getOutgoingBatchRange

OutgoingBatches getOutgoingBatchRange(long startBatchId,
                                      long endBatchId)

getOutgoingBatchByLoad

OutgoingBatches getOutgoingBatchByLoad(long loadI)

getOutgoingBatchByLoadRangeAndTable

OutgoingBatches getOutgoingBatchByLoadRangeAndTable(long loadId,
                                                    long startBatchId,
                                                    long endBatchId,
                                                    java.lang.String tableName)

cancelLoadBatches

int cancelLoadBatches(long loadId)

getOutgoingBatchRange

OutgoingBatches getOutgoingBatchRange(java.lang.String nodeId,
                                      java.util.Date startDate,
                                      java.util.Date endDate,
                                      java.lang.String... channels)

getOutgoingBatchErrors

OutgoingBatches getOutgoingBatchErrors(int maxRows)

isInitialLoadComplete

boolean isInitialLoadComplete(java.lang.String nodeId)

areAllLoadBatchesComplete

boolean areAllLoadBatchesComplete(java.lang.String nodeId)

isUnsentDataOnChannelForNode

boolean isUnsentDataOnChannelForNode(java.lang.String channelId,
                                     java.lang.String nodeId)

updateOutgoingBatch

void updateOutgoingBatch(OutgoingBatch batch)

updateOutgoingBatchStatus

void updateOutgoingBatchStatus(org.jumpmind.db.sql.ISqlTransaction transaction,
                               AbstractBatch.Status status,
                               java.lang.String nodeId,
                               long startBatchId,
                               long endBatchId)

updateCommonBatchExtractStatistics

void updateCommonBatchExtractStatistics(OutgoingBatch batch)

updateOutgoingBatch

void updateOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                         OutgoingBatch outgoingBatch)

updateOutgoingBatches

void updateOutgoingBatches(java.util.List<OutgoingBatch> batches)

updateOutgoingBatches

void updateOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
                           java.util.List<OutgoingBatch> batches,
                           int flushSize)

insertOutgoingBatch

void insertOutgoingBatch(OutgoingBatch outgoingBatch)

insertOutgoingBatch

void insertOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                         OutgoingBatch outgoingBatch)

insertOutgoingBatches

void insertOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
                           java.util.List<OutgoingBatch> batches,
                           int flushSize,
                           boolean isCommon)

countOutgoingBatchesInError

int countOutgoingBatchesInError()

countOutgoingBatchesUnsent

int countOutgoingBatchesUnsent()

countOutgoingBatchesInError

int countOutgoingBatchesInError(java.lang.String channelId)

countOutgoingBatchesUnsent

int countOutgoingBatchesUnsent(java.lang.String channelId)

countOutgoingBatchesUnsentHeartbeat

int countOutgoingBatchesUnsentHeartbeat()

countOutgoingBatchesPendingByChannel

java.util.Map<java.lang.String,java.lang.Integer> countOutgoingBatchesPendingByChannel(java.lang.String nodeId)

countUnsentRowsByTargetNode

long countUnsentRowsByTargetNode(java.lang.String nodeId)

countUnsentBatchesByTargetNode

int countUnsentBatchesByTargetNode(java.lang.String nodeId)

findOutgoingBatchSummary

java.util.List<OutgoingBatchSummary> findOutgoingBatchSummary(AbstractBatch.Status... statuses)

findOutgoingBatchSummaryByChannel

java.util.List<OutgoingBatchSummary> findOutgoingBatchSummaryByChannel(AbstractBatch.Status... statuses)

findOutgoingBatchSummaryByNode

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

countOutgoingBatches

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)

listOutgoingBatches

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)

copyOutgoingBatches

void copyOutgoingBatches(java.lang.String channelId,
                         long startBatchId,
                         java.lang.String fromNodeId,
                         java.lang.String toNodeId)

getAllBatches

java.util.List<java.lang.Long> getAllBatches()