Package org.jumpmind.symmetric.service.impl

Class OutgoingBatchService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.OutgoingBatchService

All Implemented Interfaces:

IOutgoingBatchService, IService

public class OutgoingBatchService
extends AbstractService
implements IOutgoingBatchService

See Also:

• IOutgoingBatchService

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
OutgoingBatchService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
boolean	areAllLoadBatchesComplete(String nodeId)
protected StringBuilder	buildStatusList(Object[] args, AbstractBatch.Status... statuses)
int	cancelLoadBatches(long loadId)
protected boolean	containsOnlyStatus(AbstractBatch.Status status, List<AbstractBatch.Status> statuses)
void	copyOutgoingBatches(String channelId, long startBatchId, String fromNodeId, String toNodeId)
int	countOutgoingBatches(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads)
int	countOutgoingBatchesInError()
int	countOutgoingBatchesInError(String channelId)
Map<String,Integer>	countOutgoingBatchesPendingByChannel(String nodeId)
int	countOutgoingBatchesUnsent()
int	countOutgoingBatchesUnsent(String channelId)
int	countOutgoingBatchesUnsentHeartbeat()
int	countOutgoingBatchesWithLimit(List<FilterCriterion> filter)
int[]	countOutgoingNonSystemBatchesRowsUnsent()
int	countUnsentBatchesByTargetNode(String nodeId, boolean includeHeartbeats)
long	countUnsentRowsByTargetNode(String nodeId)
OutgoingBatch	findOutgoingBatch(long batchId, String nodeId)
List<OutgoingBatchSummary>	findOutgoingBatchSummary(AbstractBatch.Status... statuses)
List<OutgoingBatchSummary>	findOutgoingBatchSummaryByChannel(AbstractBatch.Status... statuses)
List<OutgoingBatchSummary>	findOutgoingBatchSummaryByNode(String nodeId, Date sinceCreateTime, AbstractBatch.Status... statuses)
List<Long>	getAllBatches()
List<OutgoingBatch>	getBatchesForChannelWindows(OutgoingBatches batches, String targetNodeId, NodeChannel channel, List<NodeGroupChannelWindow> windows)
List<OutgoingBatch>	getBatchesInProgress()
List<OutgoingBatch>	getNextOutgoingBatchForEachNode()
List<String>	getNodesInError()
OutgoingBatches	getOutgoingBatchByLoad(long loadId)
OutgoingBatches	getOutgoingBatchByLoadRangeAndTable(long loadId, long startBatchId, long endBatchId, String tableName)
OutgoingBatches	getOutgoingBatchErrors(int maxRows)
OutgoingBatches	getOutgoingBatches(String nodeId, boolean includeDisabledChannels)	Select batches to process.
OutgoingBatches	getOutgoingBatches(String nodeId, String channelThread, boolean includeDisabledChannels)
OutgoingBatches	getOutgoingBatches(String nodeId, String channelThread, NodeGroupLinkAction eventAction, NodeGroupLinkAction defaultEventAction, boolean includeDisabledChannels)
Date	getOutgoingBatchesLatestUpdateSql()
OutgoingBatches	getOutgoingBatchRange(long startBatchId, long endBatchId)
OutgoingBatches	getOutgoingBatchRange(String nodeId, Date startDate, Date endDate, String... channels)
Map<String,ReadyChannels>	getReadyChannelsFromDb()
Map<String,Collection<String>>	getReadyQueues(boolean refreshCache)
Collection<String>	getReadyQueues(String nodeId, boolean refreshCache)
void	insertOutgoingBatch(ISqlTransaction transaction, OutgoingBatch outgoingBatch)
void	insertOutgoingBatch(OutgoingBatch outgoingBatch)
void	insertOutgoingBatches(ISqlTransaction transaction, List<OutgoingBatch> batches, int flushSize, boolean isCommon)
boolean	inTimeWindow(List<NodeGroupChannelWindow> windows, String targetNodeId)	If NodeGroupChannelWindows are defined for this channel, then check to see if the time (according to the offset passed in) is within on of the configured windows.
boolean	isInitialLoadComplete(String nodeId)
boolean	isUnsentDataOnChannelForNode(String channelId, String nodeId)
List<OutgoingBatch>	listOutgoingBatches(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads, long startAtBatchId, Date startAtLastUpdateTime, int maxRowsToRetrieve, boolean ascending)
List<OutgoingBatch>	listOutgoingBatchesWithLimit(int offset, int limit, List<FilterCriterion> filter, String orderColumn, String orderDirection)
void	markAllAsSentForNode(String nodeId, boolean includeConfigChannel)
void	markAllConfigAsSentForNode(String nodeId)
protected List<String>	toStringList(List<AbstractBatch.Status> statuses)
void	updateAbandonedRoutingBatches()
void	updateCommonBatchExtractStatistics(OutgoingBatch outgoingBatch)
void	updateOutgoingBatch(ISqlTransaction transaction, OutgoingBatch outgoingBatch)
void	updateOutgoingBatch(OutgoingBatch outgoingBatch)
void	updateOutgoingBatches(List<OutgoingBatch> outgoingBatches)
void	updateOutgoingBatches(ISqlTransaction transaction, List<OutgoingBatch> batches, int flushSize)
void	updateOutgoingBatchStatus(ISqlTransaction transaction, AbstractBatch.Status status, String nodeId, long startBatchId, long endBatchId)
void	updateOutgoingError(long batchId, String nodeId)
void	updateOutgoingFinalizeBatchStatusByStatus(ISqlTransaction transaction, String targetNodeId, long loadId, long minBatchId, String fromStatus, String toStatus)
void	updateOutgoingLoadBatchStatusByStatus(ISqlTransaction transaction, String targetNodeId, long loadId, long startDataBatchId, long endDataBatchId, String fromStatus, String toStatus)
void	updateOutgoingSetupBatchStatusByStatus(ISqlTransaction transaction, String targetNodeId, long loadId, long maxBatchId, String fromStatus, String toStatus)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OutgoingBatchService

public OutgoingBatchService(ISymmetricEngine engine)

Method Details

updateOutgoingError

public void updateOutgoingError(long batchId,
 String nodeId)

Specified by:

updateOutgoingError in interface IOutgoingBatchService

cancelLoadBatches

public int cancelLoadBatches(long loadId)

Specified by:

cancelLoadBatches in interface IOutgoingBatchService

markAllAsSentForNode

public void markAllAsSentForNode(String nodeId,
 boolean includeConfigChannel)

Specified by:

markAllAsSentForNode in interface IOutgoingBatchService

markAllConfigAsSentForNode

public void markAllConfigAsSentForNode(String nodeId)

Specified by:

markAllConfigAsSentForNode in interface IOutgoingBatchService

copyOutgoingBatches

public void copyOutgoingBatches(String channelId,
 long startBatchId,
 String fromNodeId,
 String toNodeId)

Specified by:

copyOutgoingBatches in interface IOutgoingBatchService

updateAbandonedRoutingBatches

public void updateAbandonedRoutingBatches()

Specified by:

updateAbandonedRoutingBatches in interface IOutgoingBatchService

updateOutgoingBatches

public void updateOutgoingBatches(List<OutgoingBatch> outgoingBatches)

Specified by:

updateOutgoingBatches in interface IOutgoingBatchService

updateOutgoingBatch

public void updateOutgoingBatch(OutgoingBatch outgoingBatch)

Specified by:

updateOutgoingBatch in interface IOutgoingBatchService

updateCommonBatchExtractStatistics

public void updateCommonBatchExtractStatistics(OutgoingBatch outgoingBatch)

Specified by:

updateCommonBatchExtractStatistics in interface IOutgoingBatchService

updateOutgoingBatch

public void updateOutgoingBatch(ISqlTransaction transaction,
 OutgoingBatch outgoingBatch)

Specified by:

updateOutgoingBatch in interface IOutgoingBatchService

updateOutgoingBatches

public void updateOutgoingBatches(ISqlTransaction transaction,
 List<OutgoingBatch> batches,
 int flushSize)

Specified by:

updateOutgoingBatches in interface IOutgoingBatchService

updateOutgoingBatchStatus

public void updateOutgoingBatchStatus(ISqlTransaction transaction,
 AbstractBatch.Status status,
 String nodeId,
 long startBatchId,
 long endBatchId)

Specified by:

updateOutgoingBatchStatus in interface IOutgoingBatchService

updateOutgoingSetupBatchStatusByStatus

public void updateOutgoingSetupBatchStatusByStatus(ISqlTransaction transaction,
 String targetNodeId,
 long loadId,
 long maxBatchId,
 String fromStatus,
 String toStatus)

Specified by:

updateOutgoingSetupBatchStatusByStatus in interface IOutgoingBatchService

updateOutgoingLoadBatchStatusByStatus

public void updateOutgoingLoadBatchStatusByStatus(ISqlTransaction transaction,
 String targetNodeId,
 long loadId,
 long startDataBatchId,
 long endDataBatchId,
 String fromStatus,
 String toStatus)

Specified by:

updateOutgoingLoadBatchStatusByStatus in interface IOutgoingBatchService

updateOutgoingFinalizeBatchStatusByStatus

public void updateOutgoingFinalizeBatchStatusByStatus(ISqlTransaction transaction,
 String targetNodeId,
 long loadId,
 long minBatchId,
 String fromStatus,
 String toStatus)

Specified by:

updateOutgoingFinalizeBatchStatusByStatus in interface IOutgoingBatchService

insertOutgoingBatch

public void insertOutgoingBatch(OutgoingBatch outgoingBatch)

Specified by:

insertOutgoingBatch in interface IOutgoingBatchService

insertOutgoingBatch

public void insertOutgoingBatch(ISqlTransaction transaction,
 OutgoingBatch outgoingBatch)

Specified by:

insertOutgoingBatch in interface IOutgoingBatchService

insertOutgoingBatches

public void insertOutgoingBatches(ISqlTransaction transaction,
 List<OutgoingBatch> batches,
 int flushSize,
 boolean isCommon)

Specified by:

insertOutgoingBatches in interface IOutgoingBatchService

findOutgoingBatch

public OutgoingBatch findOutgoingBatch(long batchId,
 String nodeId)

Specified by:

findOutgoingBatch in interface IOutgoingBatchService

countOutgoingBatchesInError

public int countOutgoingBatchesInError()

Specified by:

countOutgoingBatchesInError in interface IOutgoingBatchService

countOutgoingBatchesInError

public int countOutgoingBatchesInError(String channelId)

Specified by:

countOutgoingBatchesInError in interface IOutgoingBatchService

getOutgoingBatchesLatestUpdateSql

public Date getOutgoingBatchesLatestUpdateSql()

Specified by:

getOutgoingBatchesLatestUpdateSql in interface IOutgoingBatchService

countOutgoingBatchesUnsent

public int countOutgoingBatchesUnsent()

Specified by:

countOutgoingBatchesUnsent in interface IOutgoingBatchService

countOutgoingNonSystemBatchesRowsUnsent

public int[] countOutgoingNonSystemBatchesRowsUnsent()

Specified by:

countOutgoingNonSystemBatchesRowsUnsent in interface IOutgoingBatchService

countOutgoingBatchesUnsent

public int countOutgoingBatchesUnsent(String channelId)

Specified by:

countOutgoingBatchesUnsent in interface IOutgoingBatchService

countOutgoingBatchesUnsentHeartbeat

public int countOutgoingBatchesUnsentHeartbeat()

Specified by:

countOutgoingBatchesUnsentHeartbeat in interface IOutgoingBatchService

countOutgoingBatchesPendingByChannel

public Map<String,Integer> countOutgoingBatchesPendingByChannel(String nodeId)

Specified by:

countOutgoingBatchesPendingByChannel in interface IOutgoingBatchService

countUnsentBatchesByTargetNode

public int countUnsentBatchesByTargetNode(String nodeId,
 boolean includeHeartbeats)

Specified by:

countUnsentBatchesByTargetNode in interface IOutgoingBatchService

countUnsentRowsByTargetNode

public long countUnsentRowsByTargetNode(String nodeId)

Specified by:

countUnsentRowsByTargetNode in interface IOutgoingBatchService

countOutgoingBatches

public int countOutgoingBatches(List<String> nodeIds,
 List<String> channels,
 List<AbstractBatch.Status> statuses,
 List<Long> loads)

Specified by:

countOutgoingBatches in interface IOutgoingBatchService

listOutgoingBatches

public List<OutgoingBatch> listOutgoingBatches(List<String> nodeIds,
 List<String> channels,
 List<AbstractBatch.Status> statuses,
 List<Long> loads,
 long startAtBatchId,
 Date startAtLastUpdateTime,
 int maxRowsToRetrieve,
 boolean ascending)

Specified by:

listOutgoingBatches in interface IOutgoingBatchService

listOutgoingBatchesWithLimit

public List<OutgoingBatch> listOutgoingBatchesWithLimit(int offset,
 int limit,
 List<FilterCriterion> filter,
 String orderColumn,
 String orderDirection)

Specified by:

listOutgoingBatchesWithLimit in interface IOutgoingBatchService

countOutgoingBatchesWithLimit

public int countOutgoingBatchesWithLimit(List<FilterCriterion> filter)

Specified by:

countOutgoingBatchesWithLimit in interface IOutgoingBatchService

toStringList

protected List<String> toStringList(List<AbstractBatch.Status> statuses)

containsOnlyStatus

protected boolean containsOnlyStatus(AbstractBatch.Status status,
 List<AbstractBatch.Status> statuses)

getOutgoingBatches

public OutgoingBatches getOutgoingBatches(String nodeId,
 boolean includeDisabledChannels)

Select batches to process. Batches that are NOT in error will be returned first. They will be ordered by batch id as the batches will have already been created by #buildOutgoingBatches(String) in channel priority order.

Specified by:

getOutgoingBatches in interface IOutgoingBatchService

getOutgoingBatches

public OutgoingBatches getOutgoingBatches(String nodeId,
 String channelThread,
 boolean includeDisabledChannels)

Specified by:

getOutgoingBatches in interface IOutgoingBatchService

getOutgoingBatches

public OutgoingBatches getOutgoingBatches(String nodeId,
 String channelThread,
 NodeGroupLinkAction eventAction,
 NodeGroupLinkAction defaultEventAction,
 boolean includeDisabledChannels)

Specified by:

getOutgoingBatches in interface IOutgoingBatchService

getBatchesForChannelWindows

public List<OutgoingBatch> getBatchesForChannelWindows(OutgoingBatches batches,
 String targetNodeId,
 NodeChannel channel,
 List<NodeGroupChannelWindow> windows)

inTimeWindow

public boolean inTimeWindow(List<NodeGroupChannelWindow> windows,
 String targetNodeId)

If NodeGroupChannelWindows are defined for this channel, then check to see if the time (according to the offset passed in) is within on of the configured windows.

getOutgoingBatchRange

public OutgoingBatches getOutgoingBatchRange(String nodeId,
 Date startDate,
 Date endDate,
 String... channels)

Specified by:

getOutgoingBatchRange in interface IOutgoingBatchService

getOutgoingBatchRange

public OutgoingBatches getOutgoingBatchRange(long startBatchId,
 long endBatchId)

Specified by:

getOutgoingBatchRange in interface IOutgoingBatchService

getOutgoingBatchByLoad

public OutgoingBatches getOutgoingBatchByLoad(long loadId)

Specified by:

getOutgoingBatchByLoad in interface IOutgoingBatchService

getOutgoingBatchByLoadRangeAndTable

public OutgoingBatches getOutgoingBatchByLoadRangeAndTable(long loadId,
 long startBatchId,
 long endBatchId,
 String tableName)

Specified by:

getOutgoingBatchByLoadRangeAndTable in interface IOutgoingBatchService

getOutgoingBatchErrors

public OutgoingBatches getOutgoingBatchErrors(int maxRows)

Specified by:

getOutgoingBatchErrors in interface IOutgoingBatchService

getNodesInError

public List<String> getNodesInError()

Specified by:

getNodesInError in interface IOutgoingBatchService

getNextOutgoingBatchForEachNode

public List<OutgoingBatch> getNextOutgoingBatchForEachNode()

isInitialLoadComplete

public boolean isInitialLoadComplete(String nodeId)

Specified by:

isInitialLoadComplete in interface IOutgoingBatchService

areAllLoadBatchesComplete

public boolean areAllLoadBatchesComplete(String nodeId)

Specified by:

areAllLoadBatchesComplete in interface IOutgoingBatchService

isUnsentDataOnChannelForNode

public boolean isUnsentDataOnChannelForNode(String channelId,
 String nodeId)

Specified by:

isUnsentDataOnChannelForNode in interface IOutgoingBatchService

buildStatusList

protected StringBuilder buildStatusList(Object[] args,
 AbstractBatch.Status... statuses)

findOutgoingBatchSummaryByNode

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

Specified by:

findOutgoingBatchSummaryByNode in interface IOutgoingBatchService

findOutgoingBatchSummary

public List<OutgoingBatchSummary> findOutgoingBatchSummary(AbstractBatch.Status... statuses)

Specified by:

findOutgoingBatchSummary in interface IOutgoingBatchService

findOutgoingBatchSummaryByChannel

public List<OutgoingBatchSummary> findOutgoingBatchSummaryByChannel(AbstractBatch.Status... statuses)

Specified by:

findOutgoingBatchSummaryByChannel in interface IOutgoingBatchService

getAllBatches

public List<Long> getAllBatches()

Specified by:

getAllBatches in interface IOutgoingBatchService

getBatchesInProgress

public List<OutgoingBatch> getBatchesInProgress()

Specified by:

getBatchesInProgress in interface IOutgoingBatchService

getReadyQueues

public Collection<String> getReadyQueues(String nodeId,
 boolean refreshCache)

Specified by:

getReadyQueues in interface IOutgoingBatchService

getReadyQueues

public Map<String,Collection<String>> getReadyQueues(boolean refreshCache)

Specified by:

getReadyQueues in interface IOutgoingBatchService

getReadyChannelsFromDb

public Map<String,ReadyChannels> getReadyChannelsFromDb()

Specified by:

getReadyChannelsFromDb in interface IOutgoingBatchService