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 and Description
OutgoingBatchService(IParameterService parameterService, ISymmetricDialect symmetricDialect, INodeService nodeService, IConfigurationService configurationService, ISequenceService sequenceService, IClusterService clusterService, IExtensionService extensionService)

Method Summary

Modifier and Type	Method and Description
boolean	areAllLoadBatchesComplete(java.lang.String nodeId)
protected java.lang.StringBuilder	buildStatusList(java.lang.Object[] args, AbstractBatch.Status... statuses)
int	cancelLoadBatches(long loadId)
protected boolean	containsOnlyStatus(AbstractBatch.Status status, java.util.List<AbstractBatch.Status> statuses)
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<OutgoingBatch>	getBatchesForChannelWindows(OutgoingBatches batches, java.lang.String targetNodeId, NodeChannel channel, java.util.List<NodeGroupChannelWindow> windows)
java.util.List<OutgoingBatch>	getNextOutgoingBatchForEachNode()
java.util.List<java.lang.String>	getNodesInError()
OutgoingBatches	getOutgoingBatchByLoad(long loadId)
OutgoingBatches	getOutgoingBatchByLoadRangeAndTable(long loadId, long startBatchId, long endBatchId, java.lang.String tableName)
OutgoingBatches	getOutgoingBatchErrors(int maxRows)
OutgoingBatches	getOutgoingBatches(java.lang.String nodeId, boolean includeDisabledChannels) Select batches to process.
OutgoingBatches	getOutgoingBatches(java.lang.String nodeId, java.lang.String channelThread, 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	inTimeWindow(java.util.List<NodeGroupChannelWindow> windows, java.lang.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(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 maxRowsToRetrieve, boolean ascending)
void	markAllAsSentForNode(java.lang.String nodeId, boolean includeConfigChannel)
void	markAllConfigAsSentForNode(java.lang.String nodeId)
protected java.util.List<java.lang.String>	toStringList(java.util.List<AbstractBatch.Status> statuses)
void	updateAbandonedRoutingBatches()
void	updateCommonBatchExtractStatistics(OutgoingBatch outgoingBatch)
void	updateOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, OutgoingBatch outgoingBatch)
void	updateOutgoingBatch(OutgoingBatch outgoingBatch)
void	updateOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction, java.util.List<OutgoingBatch> batches, int flushSize)
void	updateOutgoingBatches(java.util.List<OutgoingBatch> outgoingBatches)
void	updateOutgoingBatchStatus(org.jumpmind.db.sql.ISqlTransaction transaction, AbstractBatch.Status status, java.lang.String nodeId, long startBatchId, long endBatchId)

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

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, 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 Detail

OutgoingBatchService

public OutgoingBatchService(IParameterService parameterService,
                            ISymmetricDialect symmetricDialect,
                            INodeService nodeService,
                            IConfigurationService configurationService,
                            ISequenceService sequenceService,
                            IClusterService clusterService,
                            IExtensionService extensionService)

Method Detail

cancelLoadBatches

public int cancelLoadBatches(long loadId)

Specified by:

cancelLoadBatches in interface IOutgoingBatchService

markAllAsSentForNode

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

Specified by:

markAllAsSentForNode in interface IOutgoingBatchService

markAllConfigAsSentForNode

public void markAllConfigAsSentForNode(java.lang.String nodeId)

Specified by:

markAllConfigAsSentForNode in interface IOutgoingBatchService

copyOutgoingBatches

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

Specified by:

copyOutgoingBatches in interface IOutgoingBatchService

updateAbandonedRoutingBatches

public void updateAbandonedRoutingBatches()

Specified by:

updateAbandonedRoutingBatches in interface IOutgoingBatchService

updateOutgoingBatches

public void updateOutgoingBatches(java.util.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(org.jumpmind.db.sql.ISqlTransaction transaction,
                                OutgoingBatch outgoingBatch)

Specified by:

updateOutgoingBatch in interface IOutgoingBatchService

updateOutgoingBatches

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

Specified by:

updateOutgoingBatches in interface IOutgoingBatchService

updateOutgoingBatchStatus

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

Specified by:

updateOutgoingBatchStatus in interface IOutgoingBatchService

insertOutgoingBatch

public void insertOutgoingBatch(OutgoingBatch outgoingBatch)

Specified by:

insertOutgoingBatch in interface IOutgoingBatchService

insertOutgoingBatch

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

Specified by:

insertOutgoingBatch in interface IOutgoingBatchService

insertOutgoingBatches

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

Specified by:

insertOutgoingBatches in interface IOutgoingBatchService

findOutgoingBatch

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

Specified by:

findOutgoingBatch in interface IOutgoingBatchService

countOutgoingBatchesInError

public int countOutgoingBatchesInError()

Specified by:

countOutgoingBatchesInError in interface IOutgoingBatchService

countOutgoingBatchesInError

public int countOutgoingBatchesInError(java.lang.String channelId)

Specified by:

countOutgoingBatchesInError in interface IOutgoingBatchService

countOutgoingBatchesUnsent

public int countOutgoingBatchesUnsent()

Specified by:

countOutgoingBatchesUnsent in interface IOutgoingBatchService

countOutgoingBatchesUnsent

public int countOutgoingBatchesUnsent(java.lang.String channelId)

Specified by:

countOutgoingBatchesUnsent in interface IOutgoingBatchService

countOutgoingBatchesUnsentHeartbeat

public int countOutgoingBatchesUnsentHeartbeat()

Specified by:

countOutgoingBatchesUnsentHeartbeat in interface IOutgoingBatchService

countOutgoingBatchesPendingByChannel

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

Specified by:

countOutgoingBatchesPendingByChannel in interface IOutgoingBatchService

countUnsentBatchesByTargetNode

public int countUnsentBatchesByTargetNode(java.lang.String nodeId)

Specified by:

countUnsentBatchesByTargetNode in interface IOutgoingBatchService

countUnsentRowsByTargetNode

public long countUnsentRowsByTargetNode(java.lang.String nodeId)

Specified by:

countUnsentRowsByTargetNode in interface IOutgoingBatchService

countOutgoingBatches

public 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)

Specified by:

countOutgoingBatches in interface IOutgoingBatchService

listOutgoingBatches

public 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 maxRowsToRetrieve,
                                                         boolean ascending)

Specified by:

listOutgoingBatches in interface IOutgoingBatchService

toStringList

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

containsOnlyStatus

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

getOutgoingBatches

public OutgoingBatches getOutgoingBatches(java.lang.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(java.lang.String nodeId,
                                          java.lang.String channelThread,
                                          boolean includeDisabledChannels)

Specified by:

getOutgoingBatches in interface IOutgoingBatchService

getOutgoingBatches

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

Specified by:

getOutgoingBatches in interface IOutgoingBatchService

getBatchesForChannelWindows

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

inTimeWindow

public boolean inTimeWindow(java.util.List<NodeGroupChannelWindow> windows,
                            java.lang.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(java.lang.String nodeId,
                                             java.util.Date startDate,
                                             java.util.Date endDate,
                                             java.lang.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,
                                                           java.lang.String tableName)

Specified by:

getOutgoingBatchByLoadRangeAndTable in interface IOutgoingBatchService

getOutgoingBatchErrors

public OutgoingBatches getOutgoingBatchErrors(int maxRows)

Specified by:

getOutgoingBatchErrors in interface IOutgoingBatchService

getNodesInError

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

Specified by:

getNodesInError in interface IOutgoingBatchService

getNextOutgoingBatchForEachNode

public java.util.List<OutgoingBatch> getNextOutgoingBatchForEachNode()

isInitialLoadComplete

public boolean isInitialLoadComplete(java.lang.String nodeId)

Specified by:

isInitialLoadComplete in interface IOutgoingBatchService

areAllLoadBatchesComplete

public boolean areAllLoadBatchesComplete(java.lang.String nodeId)

Specified by:

areAllLoadBatchesComplete in interface IOutgoingBatchService

isUnsentDataOnChannelForNode

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

Specified by:

isUnsentDataOnChannelForNode in interface IOutgoingBatchService

buildStatusList

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

findOutgoingBatchSummaryByNode

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

Specified by:

findOutgoingBatchSummaryByNode in interface IOutgoingBatchService

findOutgoingBatchSummary

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

Specified by:

findOutgoingBatchSummary in interface IOutgoingBatchService

findOutgoingBatchSummaryByChannel

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

Specified by:

findOutgoingBatchSummaryByChannel in interface IOutgoingBatchService

getAllBatches

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

Specified by:

getAllBatches in interface IOutgoingBatchService