org.jumpmind.symmetric.service.impl

Class IncomingBatchService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.IncomingBatchService

All Implemented Interfaces:

IIncomingBatchService, IService

public class IncomingBatchService
extends AbstractService
implements IIncomingBatchService

See Also:

IIncomingBatchService

Field Summary

Fields

Modifier and Type	Field and Description
protected IClusterService	clusterService

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

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

Constructor Summary

Constructors

Constructor and Description
IncomingBatchService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IClusterService clusterService)

Method Summary

Modifier and Type	Method and Description
boolean	acquireIncomingBatch(IncomingBatch batch)
protected java.lang.StringBuilder	buildStatusList(java.lang.Object[] args, AbstractBatch.Status... statuses)
protected boolean	containsOnlyErrorStatus(java.util.List<AbstractBatch.Status> statuses)
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)
protected java.util.List<java.lang.String>	toStringList(java.util.List<AbstractBatch.Status> statuses)
int	updateIncomingBatch(IncomingBatch batch)
int	updateIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, IncomingBatch batch)

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

Field Detail

clusterService

protected IClusterService clusterService

Constructor Detail

IncomingBatchService

public IncomingBatchService(IParameterService parameterService,
                            ISymmetricDialect symmetricDialect,
                            IClusterService clusterService)

Method Detail

getNodesInError

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

Specified by:

getNodesInError in interface IIncomingBatchService

refreshIncomingBatch

public void refreshIncomingBatch(IncomingBatch batch)

Specified by:

refreshIncomingBatch in interface IIncomingBatchService

findIncomingBatch

public IncomingBatch findIncomingBatch(long batchId,
                                       java.lang.String nodeId)

Specified by:

findIncomingBatch in interface IIncomingBatchService

countIncomingBatchesInError

public int countIncomingBatchesInError()

Specified by:

countIncomingBatchesInError in interface IIncomingBatchService

countIncomingBatchesInError

public int countIncomingBatchesInError(java.lang.String channelId)

Specified by:

countIncomingBatchesInError in interface IIncomingBatchService

findIncomingBatchErrors

public java.util.List<IncomingBatch> findIncomingBatchErrors(int maxRows)

Specified by:

findIncomingBatchErrors in interface IIncomingBatchService

markIncomingBatchesOk

public void markIncomingBatchesOk(java.lang.String nodeId)

Specified by:

markIncomingBatchesOk in interface IIncomingBatchService

removingIncomingBatches

public void removingIncomingBatches(java.lang.String nodeId)

Specified by:

removingIncomingBatches in interface IIncomingBatchService

listIncomingBatchesInErrorFor

public java.util.List<IncomingBatch> listIncomingBatchesInErrorFor(java.lang.String nodeId)

Specified by:

listIncomingBatchesInErrorFor in interface IIncomingBatchService

isRecordOkBatchesEnabled

public boolean isRecordOkBatchesEnabled()

Specified by:

isRecordOkBatchesEnabled in interface IIncomingBatchService

listIncomingBatchTimes

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

Specified by:

listIncomingBatchTimes in interface IIncomingBatchService

listIncomingBatches

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

Specified by:

listIncomingBatches in interface IIncomingBatchService

containsOnlyErrorStatus

protected boolean containsOnlyErrorStatus(java.util.List<AbstractBatch.Status> statuses)

toStringList

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

acquireIncomingBatch

public boolean acquireIncomingBatch(IncomingBatch batch)

Specified by:

acquireIncomingBatch in interface IIncomingBatchService

insertIncomingBatch

public void insertIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                                IncomingBatch batch)

Specified by:

insertIncomingBatch in interface IIncomingBatchService

insertIncomingBatch

public void insertIncomingBatch(IncomingBatch batch)

Specified by:

insertIncomingBatch in interface IIncomingBatchService

deleteIncomingBatch

public int deleteIncomingBatch(IncomingBatch batch)

Specified by:

deleteIncomingBatch in interface IIncomingBatchService

updateIncomingBatch

public int updateIncomingBatch(IncomingBatch batch)

Specified by:

updateIncomingBatch in interface IIncomingBatchService

updateIncomingBatch

public int updateIncomingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                               IncomingBatch batch)

Specified by:

updateIncomingBatch in interface IIncomingBatchService

findMaxBatchIdsByChannel

public java.util.Map<java.lang.String,BatchId> findMaxBatchIdsByChannel()

Specified by:

findMaxBatchIdsByChannel in interface IIncomingBatchService

findIncomingBatchSummaryByNode

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

Specified by:

findIncomingBatchSummaryByNode in interface IIncomingBatchService

buildStatusList

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

findIncomingBatchSummaryByChannel

public java.util.List<IncomingBatchSummary> findIncomingBatchSummaryByChannel(AbstractBatch.Status... statuses)

Specified by:

findIncomingBatchSummaryByChannel in interface IIncomingBatchService

findIncomingBatchSummary

public java.util.List<IncomingBatchSummary> findIncomingBatchSummary(AbstractBatch.Status... statuses)

Specified by:

findIncomingBatchSummary in interface IIncomingBatchService

findIncomingBatchSummaryByNodeAndChannel

public java.util.List<IncomingBatchSummary> findIncomingBatchSummaryByNodeAndChannel(java.lang.String nodeId,
                                                                                     java.lang.String channelId,
                                                                                     java.util.Date sinceCreateTime,
                                                                                     AbstractBatch.Status... statuses)

Specified by:

findIncomingBatchSummaryByNodeAndChannel in interface IIncomingBatchService

findLastUpdatedByChannel

public java.util.Map<java.lang.String,java.util.Date> findLastUpdatedByChannel()

Specified by:

findLastUpdatedByChannel in interface IIncomingBatchService

getAllBatches

public java.util.List<BatchId> getAllBatches()

Specified by:

getAllBatches in interface IIncomingBatchService