Package 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	Description
protected IClusterService	clusterService
protected Map<String,Collection<String>>	readyQueuesCache

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	acquireIncomingBatch(IncomingBatch batch)
protected StringBuilder	buildStatusList(Object[] args, AbstractBatch.Status... statuses)
protected boolean	containsOnlyErrorStatus(List<AbstractBatch.Status> statuses)
int	countIncomingBatchesInError()
int	countIncomingBatchesInError(String channelId)
int	countIncomingBatchesWithLimit(List<FilterCriterion> filter)
int	deleteIncomingBatch(IncomingBatch batch)
IncomingBatch	findIncomingBatch(long batchId, String nodeId)
List<IncomingBatch>	findIncomingBatchErrors(int maxRows)
List<IncomingBatchSummary>	findIncomingBatchSummary(AbstractBatch.Status... statuses)
List<IncomingBatchSummary>	findIncomingBatchSummaryByChannel(AbstractBatch.Status... statuses)
List<IncomingBatchSummary>	findIncomingBatchSummaryByNode(String nodeId, Date sinceCreateTime, AbstractBatch.Status... statuses)
List<IncomingBatchSummary>	findIncomingBatchSummaryByNodeAndChannel(String nodeId, String channelId, Date sinceCreateTime, AbstractBatch.Status... statuses)
Map<String,Date>	findLastUpdatedByChannel()
Map<String,BatchId>	findMaxBatchIdsByChannel()
List<BatchId>	getAllBatches()
Date	getIncomingBatchesLatestUpdateSql()
List<String>	getNodesInError()
Collection<String>	getReadyQueues(String sourceNodeId)
void	insertIncomingBatch(ISqlTransaction transaction, IncomingBatch batch)
void	insertIncomingBatch(IncomingBatch batch)
boolean	isRecordOkBatchesEnabled()
List<IncomingBatch>	listIncomingBatches(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads, Date startAtCreateTime, Date startAtLastUpdateTime, int maxRowsToRetrieve, boolean ascending)
List<IncomingBatch>	listIncomingBatchesInErrorFor(String nodeId)
List<IncomingBatch>	listIncomingBatchesWithLimit(int offset, int limit, List<FilterCriterion> filter, String orderColumn, String orderDirection)
List<Date>	listIncomingBatchTimes(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads, boolean ascending)
void	markIncomingBatchesOk(String nodeId)
void	refreshIncomingBatch(IncomingBatch batch)
void	removingIncomingBatches(String nodeId)
void	setReadyQueues(String sourceNodeId, Collection<String> queues)
protected List<String>	toStringList(List<AbstractBatch.Status> statuses)
int	updateIncomingBatch(ISqlTransaction transaction, IncomingBatch batch)
int	updateIncomingBatch(IncomingBatch batch)

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

Field Details

clusterService

protected IClusterService clusterService

readyQueuesCache

protected Map<String,Collection<String>> readyQueuesCache

Constructor Details

IncomingBatchService

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

Method Details

getNodesInError

public List<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,
 String nodeId)

Specified by:

findIncomingBatch in interface IIncomingBatchService

countIncomingBatchesInError

public int countIncomingBatchesInError()

Specified by:

countIncomingBatchesInError in interface IIncomingBatchService

countIncomingBatchesInError

public int countIncomingBatchesInError(String channelId)

Specified by:

countIncomingBatchesInError in interface IIncomingBatchService

getIncomingBatchesLatestUpdateSql

public Date getIncomingBatchesLatestUpdateSql()

Specified by:

getIncomingBatchesLatestUpdateSql in interface IIncomingBatchService

findIncomingBatchErrors

public List<IncomingBatch> findIncomingBatchErrors(int maxRows)

Specified by:

findIncomingBatchErrors in interface IIncomingBatchService

markIncomingBatchesOk

public void markIncomingBatchesOk(String nodeId)

Specified by:

markIncomingBatchesOk in interface IIncomingBatchService

removingIncomingBatches

public void removingIncomingBatches(String nodeId)

Specified by:

removingIncomingBatches in interface IIncomingBatchService

listIncomingBatchesInErrorFor

public List<IncomingBatch> listIncomingBatchesInErrorFor(String nodeId)

Specified by:

listIncomingBatchesInErrorFor in interface IIncomingBatchService

isRecordOkBatchesEnabled

public boolean isRecordOkBatchesEnabled()

Specified by:

isRecordOkBatchesEnabled in interface IIncomingBatchService

listIncomingBatchTimes

public List<Date> listIncomingBatchTimes(List<String> nodeIds,
 List<String> channels,
 List<AbstractBatch.Status> statuses,
 List<Long> loads,
 boolean ascending)

Specified by:

listIncomingBatchTimes in interface IIncomingBatchService

listIncomingBatches

public List<IncomingBatch> listIncomingBatches(List<String> nodeIds,
 List<String> channels,
 List<AbstractBatch.Status> statuses,
 List<Long> loads,
 Date startAtCreateTime,
 Date startAtLastUpdateTime,
 int maxRowsToRetrieve,
 boolean ascending)

Specified by:

listIncomingBatches in interface IIncomingBatchService

listIncomingBatchesWithLimit

public List<IncomingBatch> listIncomingBatchesWithLimit(int offset,
 int limit,
 List<FilterCriterion> filter,
 String orderColumn,
 String orderDirection)

Specified by:

listIncomingBatchesWithLimit in interface IIncomingBatchService

countIncomingBatchesWithLimit

public int countIncomingBatchesWithLimit(List<FilterCriterion> filter)

Specified by:

countIncomingBatchesWithLimit in interface IIncomingBatchService

containsOnlyErrorStatus

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

toStringList

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

acquireIncomingBatch

public boolean acquireIncomingBatch(IncomingBatch batch)

Specified by:

acquireIncomingBatch in interface IIncomingBatchService

insertIncomingBatch

public void insertIncomingBatch(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(ISqlTransaction transaction,
 IncomingBatch batch)

Specified by:

updateIncomingBatch in interface IIncomingBatchService

findMaxBatchIdsByChannel

public Map<String,BatchId> findMaxBatchIdsByChannel()

Specified by:

findMaxBatchIdsByChannel in interface IIncomingBatchService

findIncomingBatchSummaryByNode

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

Specified by:

findIncomingBatchSummaryByNode in interface IIncomingBatchService

buildStatusList

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

findIncomingBatchSummaryByChannel

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

Specified by:

findIncomingBatchSummaryByChannel in interface IIncomingBatchService

findIncomingBatchSummary

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

Specified by:

findIncomingBatchSummary in interface IIncomingBatchService

findIncomingBatchSummaryByNodeAndChannel

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

Specified by:

findIncomingBatchSummaryByNodeAndChannel in interface IIncomingBatchService

findLastUpdatedByChannel

public Map<String,Date> findLastUpdatedByChannel()

Specified by:

findLastUpdatedByChannel in interface IIncomingBatchService

getAllBatches

public List<BatchId> getAllBatches()

Specified by:

getAllBatches in interface IIncomingBatchService

getReadyQueues

public Collection<String> getReadyQueues(String sourceNodeId)

Specified by:

getReadyQueues in interface IIncomingBatchService

setReadyQueues

public void setReadyQueues(String sourceNodeId,
 Collection<String> queues)

Specified by:

setReadyQueues in interface IIncomingBatchService