org.jumpmind.symmetric.route

Class ChannelRouterContext

java.lang.Object

org.jumpmind.util.Context

org.jumpmind.symmetric.route.SimpleRouterContext

org.jumpmind.symmetric.route.ChannelRouterContext

public class ChannelRouterContext
extends SimpleRouterContext

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	STAT_BATCHES_COMMON
static java.lang.String	STAT_BATCHES_INSERTED
static java.lang.String	STAT_BATCHES_NONCOMMON
static java.lang.String	STAT_DATA_EVENTS_INSERTED
static java.lang.String	STAT_DATA_ROUTED_COUNT
static java.lang.String	STAT_DATA_ROUTER_MS
static java.lang.String	STAT_ENQUEUE_DATA_MS
static java.lang.String	STAT_ENQUEUE_EOD_MS
static java.lang.String	STAT_INSERT_BATCHES_MS
static java.lang.String	STAT_INSERT_DATA_EVENTS_MS
static java.lang.String	STAT_QUERY_TIME_MS
static java.lang.String	STAT_READ_DATA_MS
static java.lang.String	STAT_REREAD_DATA_MS
static java.lang.String	STAT_ROUTE_TOTAL_TIME
static java.lang.String	STAT_UPDATE_BATCHES_MS

Fields inherited from class org.jumpmind.symmetric.route.SimpleRouterContext

channel, encountedTransactionBoundary, log, nodeId, requestGapDetection, stats

Fields inherited from class org.jumpmind.util.Context

context

Constructor Summary

Constructors

Constructor and Description
ChannelRouterContext(java.lang.String nodeId, NodeChannel channel, org.jumpmind.db.sql.ISqlTransaction transaction, IBatchAlgorithm batchAlgorithm)

Method Summary

Modifier and Type	Method and Description
void	addData(long dataId)
void	addDataEvent(long dataId, long batchId)
void	addTimesByRouter(java.lang.String routerId, long millis)
void	addUsedDataRouter(IDataRouter dataRouter)
void	cleanup()
void	clearDataEventsList()
protected void	clearState()
void	commit()
java.util.Map<TriggerRouter,java.util.Set<Node>>	getAvailableNodes()
java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,OutgoingBatch>>	getBatchesByGroups()
java.util.Map<java.lang.String,OutgoingBatch>	getBatchesByNodes()
long	getCommittedDataEventCount()
long	getCreatedTimeInMs()
java.util.List<DataEvent>	getDataEventList()
java.util.List<DataGap>	getDataGaps()
java.util.List<java.lang.Long>	getDataIds()
long	getDataReadCount()
long	getDataRereadCount()
long	getEndDataId()
Data	getLastDataProcessed()
long	getLastLoadId()
int	getMaxBatchesJdbcFlushSize()
long	getMaxPeekAheadQueueSize()
long	getPeekAheadFillCount()
org.jumpmind.db.sql.ISqlTransaction	getSqlTransaction()
long	getStartDataId()
java.util.Map<java.lang.String,java.lang.Long>	getTimesByRouter()
java.util.Set<IDataRouter>	getUsedDataRouters()
void	incrementDataReadCount(long dataReadCount)
void	incrementDataRereadCount()
void	incrementPeekAheadFillCount(long peekAheadFillCount)
boolean	isBatchComplete(OutgoingBatch batch, DataMetaData dataMetaData)
boolean	isForceNonCommon()
boolean	isNeedsCommitted()
boolean	isNonCommonForIncoming()
boolean	isOnlyDefaultRoutersAssigned()
boolean	isOverrideContainsBigLob()
boolean	isProduceCommonBatches()
boolean	isProduceGroupBatches()
void	logStats(org.slf4j.Logger log, long totalTimeInMs)
void	removeLastData()
void	resetForNextData()
void	rollback()
void	setDataGaps(java.util.List<DataGap> dataGaps)
void	setEndDataId(long endDataId)
void	setForceNonCommon(boolean forceNonCommon)
void	setLastDataProcessed(Data lastDataProcessed)
void	setLastLoadId(long lastLoadId)
void	setMaxBatchesJdbcFlushSize(int maxBatchesJdbcFlushSize)
void	setMaxPeekAheadQueueSize(long maxPeekAheadQueueSize)
void	setNeedsCommitted(boolean b)
void	setNonCommonForIncoming(boolean nonCommonForIncoming)
void	setOnlyDefaultRoutersAssigned(boolean onlyDefaultRoutersAssigned)
void	setOverrideContainsBigLob(boolean overrideContainsBigLob)
void	setProduceCommonBatches(boolean defaultRoutersOnly)
void	setProduceGroupBatches(boolean produceGroupBatches)
void	setStartDataId(long startDataId)

Methods inherited from class org.jumpmind.symmetric.route.SimpleRouterContext

getBatchId, getBinaryEncoding, getChannel, getContextCache, getSourceNodeId, getStat, incrementStat, isEncountedTransactionBoundary, setEncountedTransactionBoundary, transferStats

Methods inherited from class org.jumpmind.util.Context

get, getContext, keySet, put, remove

Methods inherited from class java.lang.Object

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

Field Detail

STAT_INSERT_DATA_EVENTS_MS

public static final java.lang.String STAT_INSERT_DATA_EVENTS_MS

See Also:

Constant Field Values

STAT_DATA_ROUTER_MS

public static final java.lang.String STAT_DATA_ROUTER_MS

See Also:

Constant Field Values

STAT_QUERY_TIME_MS

public static final java.lang.String STAT_QUERY_TIME_MS

See Also:

Constant Field Values

STAT_READ_DATA_MS

public static final java.lang.String STAT_READ_DATA_MS

See Also:

Constant Field Values

STAT_REREAD_DATA_MS

public static final java.lang.String STAT_REREAD_DATA_MS

See Also:

Constant Field Values

STAT_ENQUEUE_DATA_MS

public static final java.lang.String STAT_ENQUEUE_DATA_MS

See Also:

Constant Field Values

STAT_ENQUEUE_EOD_MS

public static final java.lang.String STAT_ENQUEUE_EOD_MS

See Also:

Constant Field Values

STAT_DATA_EVENTS_INSERTED

public static final java.lang.String STAT_DATA_EVENTS_INSERTED

See Also:

Constant Field Values

STAT_DATA_ROUTED_COUNT

public static final java.lang.String STAT_DATA_ROUTED_COUNT

See Also:

Constant Field Values

STAT_INSERT_BATCHES_MS

public static final java.lang.String STAT_INSERT_BATCHES_MS

See Also:

Constant Field Values

STAT_BATCHES_INSERTED

public static final java.lang.String STAT_BATCHES_INSERTED

See Also:

Constant Field Values

STAT_BATCHES_COMMON

public static final java.lang.String STAT_BATCHES_COMMON

See Also:

Constant Field Values

STAT_BATCHES_NONCOMMON

public static final java.lang.String STAT_BATCHES_NONCOMMON

See Also:

Constant Field Values

STAT_UPDATE_BATCHES_MS

public static final java.lang.String STAT_UPDATE_BATCHES_MS

See Also:

Constant Field Values

STAT_ROUTE_TOTAL_TIME

public static final java.lang.String STAT_ROUTE_TOTAL_TIME

See Also:

Constant Field Values

Constructor Detail

ChannelRouterContext

public ChannelRouterContext(java.lang.String nodeId,
                            NodeChannel channel,
                            org.jumpmind.db.sql.ISqlTransaction transaction,
                            IBatchAlgorithm batchAlgorithm)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

Method Detail

getDataEventList

public java.util.List<DataEvent> getDataEventList()

clearDataEventsList

public void clearDataEventsList()

addDataEvent

public void addDataEvent(long dataId,
                         long batchId)

addData

public void addData(long dataId)

removeLastData

public void removeLastData()

getCommittedDataEventCount

public long getCommittedDataEventCount()

getBatchesByNodes

public java.util.Map<java.lang.String,OutgoingBatch> getBatchesByNodes()

getBatchesByGroups

public java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,OutgoingBatch>> getBatchesByGroups()

getAvailableNodes

public java.util.Map<TriggerRouter,java.util.Set<Node>> getAvailableNodes()

commit

public void commit()

clearState

protected void clearState()

rollback

public void rollback()

cleanup

public void cleanup()

logStats

public void logStats(org.slf4j.Logger log,
                     long totalTimeInMs)

Overrides:

logStats in class SimpleRouterContext

setNeedsCommitted

public void setNeedsCommitted(boolean b)

isNeedsCommitted

public boolean isNeedsCommitted()

getUsedDataRouters

public java.util.Set<IDataRouter> getUsedDataRouters()

addUsedDataRouter

public void addUsedDataRouter(IDataRouter dataRouter)

getTimesByRouter

public java.util.Map<java.lang.String,java.lang.Long> getTimesByRouter()

addTimesByRouter

public void addTimesByRouter(java.lang.String routerId,
                             long millis)

resetForNextData

public void resetForNextData()

getCreatedTimeInMs

public long getCreatedTimeInMs()

setLastDataProcessed

public void setLastDataProcessed(Data lastDataProcessed)

getLastDataProcessed

public Data getLastDataProcessed()

getSqlTransaction

public org.jumpmind.db.sql.ISqlTransaction getSqlTransaction()

setProduceCommonBatches

public void setProduceCommonBatches(boolean defaultRoutersOnly)

isProduceCommonBatches

public boolean isProduceCommonBatches()

isNonCommonForIncoming

public boolean isNonCommonForIncoming()

setNonCommonForIncoming

public void setNonCommonForIncoming(boolean nonCommonForIncoming)

isForceNonCommon

public boolean isForceNonCommon()

setForceNonCommon

public void setForceNonCommon(boolean forceNonCommon)

setProduceGroupBatches

public void setProduceGroupBatches(boolean produceGroupBatches)

isProduceGroupBatches

public boolean isProduceGroupBatches()

setLastLoadId

public void setLastLoadId(long lastLoadId)

getLastLoadId

public long getLastLoadId()

getStartDataId

public long getStartDataId()

setStartDataId

public void setStartDataId(long startDataId)

getEndDataId

public long getEndDataId()

setEndDataId

public void setEndDataId(long endDataId)

getDataReadCount

public long getDataReadCount()

incrementDataReadCount

public void incrementDataReadCount(long dataReadCount)

getDataRereadCount

public long getDataRereadCount()

incrementDataRereadCount

public void incrementDataRereadCount()

getPeekAheadFillCount

public long getPeekAheadFillCount()

getMaxPeekAheadQueueSize

public long getMaxPeekAheadQueueSize()

setMaxPeekAheadQueueSize

public void setMaxPeekAheadQueueSize(long maxPeekAheadQueueSize)

incrementPeekAheadFillCount

public void incrementPeekAheadFillCount(long peekAheadFillCount)

getDataGaps

public java.util.List<DataGap> getDataGaps()

setDataGaps

public void setDataGaps(java.util.List<DataGap> dataGaps)

setOnlyDefaultRoutersAssigned

public void setOnlyDefaultRoutersAssigned(boolean onlyDefaultRoutersAssigned)

isOnlyDefaultRoutersAssigned

public boolean isOnlyDefaultRoutersAssigned()

getDataIds

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

isOverrideContainsBigLob

public boolean isOverrideContainsBigLob()

setOverrideContainsBigLob

public void setOverrideContainsBigLob(boolean overrideContainsBigLob)

isBatchComplete

public boolean isBatchComplete(OutgoingBatch batch,
                               DataMetaData dataMetaData)

getMaxBatchesJdbcFlushSize

public int getMaxBatchesJdbcFlushSize()

setMaxBatchesJdbcFlushSize

public void setMaxBatchesJdbcFlushSize(int maxBatchesJdbcFlushSize)