Package 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

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.route.SimpleRouterContext

SimpleRouterContext.RouterTimer

Field Summary

Fields

Modifier and Type	Field	Description
static final String	STAT_BATCHES_COMMON
static final String	STAT_BATCHES_INSERTED
static final String	STAT_BATCHES_NONCOMMON
static final String	STAT_DATA_EVENTS_INSERTED
static final String	STAT_DATA_ROUTED_COUNT
static final String	STAT_DATA_ROUTER_MS
static final String	STAT_ENQUEUE_DATA_MS
static final String	STAT_ENQUEUE_EOD_MS
static final String	STAT_INSERT_BATCHES_MS
static final String	STAT_INSERT_DATA_EVENTS_MS
static final String	STAT_LOOKUP_AVAILABLE_NODES_MS
static final String	STAT_LOOKUP_TRIGGER_ROUTERS_MS
static final String	STAT_MULTI_QUERY_COUNT
static final String	STAT_QUERY_EXEC_TIME_MS
static final String	STAT_READ_DATA_MS
static final String	STAT_REREAD_DATA_MS
static final String	STAT_ROUTE_TOTAL_TIME
static final String	STAT_UPDATE_BATCHES_MS

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

batchSizeNotToExceed, channel, encountedTransactionBoundary, log, nodeId, requestGapDetection, routerTimers, stats

Fields inherited from class org.jumpmind.util.Context

context

Constructor Summary

Constructors

Constructor	Description
ChannelRouterContext(String nodeId, NodeChannel channel, ISqlTransaction transaction, IBatchAlgorithm batchAlgorithm)

Method Summary

Modifier and Type	Method	Description
void	addConfigDataMetaData(DataMetaData dataMetaData)
void	addData(long dataId)
void	addDataEvent(long dataId, long batchId)
void	addTimesByRouter(String routerId, long millis)
void	addUsedDataRouter(IDataRouter dataRouter)
void	cleanup()
void	clearDataEventsList()
protected void	clearState()
void	commit()
Map<TriggerRouter,Set<Node>>	getAvailableNodes()
Map<Integer,Map<String,OutgoingBatch>>	getBatchesByGroups()
Map<String,OutgoingBatch>	getBatchesByNodes()
long	getCommittedDataEventCount()
long	getCommittedDataIdCount()
DataMetaData	getConfigDataMetaData(Long dataId)
long	getCreatedTimeInMs()
List<DataEvent>	getDataEventList()
List<DataGap>	getDataGaps()
List<Long>	getDataIds()
long	getDataReadCount()
long	getDataRereadCount()
long	getEndDataId()
Data	getLastDataProcessed()
long	getLastLoadId()
int	getMaxBatchesJdbcFlushSize()
long	getMaxPeekAheadQueueSize()
long	getPeekAheadFillCount()
ISqlTransaction	getSqlTransaction()
long	getStartDataId()
Map<String,Long>	getTimesByRouter()
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	resetForNextData()
void	rollback()
void	setDataGaps(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

addQueryTime, getBatchId, getBatchSizeNotToExceed, getBinaryEncoding, getChannel, getContextCache, getSourceNodeId, getStat, incrementStat, isEncountedTransactionBoundary, setBatchSizeNotToExceed, 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 Details

STAT_INSERT_DATA_EVENTS_MS

public static final String STAT_INSERT_DATA_EVENTS_MS

See Also:

• Constant Field Values

STAT_DATA_ROUTER_MS

public static final String STAT_DATA_ROUTER_MS

See Also:

• Constant Field Values

STAT_QUERY_EXEC_TIME_MS

public static final String STAT_QUERY_EXEC_TIME_MS

See Also:

• Constant Field Values

STAT_READ_DATA_MS

public static final String STAT_READ_DATA_MS

See Also:

• Constant Field Values

STAT_REREAD_DATA_MS

public static final String STAT_REREAD_DATA_MS

See Also:

• Constant Field Values

STAT_ENQUEUE_DATA_MS

public static final String STAT_ENQUEUE_DATA_MS

See Also:

• Constant Field Values

STAT_ENQUEUE_EOD_MS

public static final String STAT_ENQUEUE_EOD_MS

See Also:

• Constant Field Values

STAT_DATA_EVENTS_INSERTED

public static final String STAT_DATA_EVENTS_INSERTED

See Also:

• Constant Field Values

STAT_DATA_ROUTED_COUNT

public static final String STAT_DATA_ROUTED_COUNT

See Also:

• Constant Field Values

STAT_INSERT_BATCHES_MS

public static final String STAT_INSERT_BATCHES_MS

See Also:

• Constant Field Values

STAT_BATCHES_INSERTED

public static final String STAT_BATCHES_INSERTED

See Also:

• Constant Field Values

STAT_BATCHES_COMMON

public static final String STAT_BATCHES_COMMON

See Also:

• Constant Field Values

STAT_BATCHES_NONCOMMON

public static final String STAT_BATCHES_NONCOMMON

See Also:

• Constant Field Values

STAT_UPDATE_BATCHES_MS

public static final String STAT_UPDATE_BATCHES_MS

See Also:

• Constant Field Values

STAT_MULTI_QUERY_COUNT

public static final String STAT_MULTI_QUERY_COUNT

See Also:

• Constant Field Values

STAT_LOOKUP_AVAILABLE_NODES_MS

public static final String STAT_LOOKUP_AVAILABLE_NODES_MS

See Also:

• Constant Field Values

STAT_LOOKUP_TRIGGER_ROUTERS_MS

public static final String STAT_LOOKUP_TRIGGER_ROUTERS_MS

See Also:

• Constant Field Values

STAT_ROUTE_TOTAL_TIME

public static final String STAT_ROUTE_TOTAL_TIME

See Also:

• Constant Field Values

Constructor Details

ChannelRouterContext

public ChannelRouterContext(String nodeId,
 NodeChannel channel,
 ISqlTransaction transaction,
 IBatchAlgorithm batchAlgorithm)

Method Details

getDataEventList

public List<DataEvent> getDataEventList()

clearDataEventsList

public void clearDataEventsList()

addDataEvent

public void addDataEvent(long dataId,
 long batchId)

addData

public void addData(long dataId)

addConfigDataMetaData

public void addConfigDataMetaData(DataMetaData dataMetaData)

getConfigDataMetaData

public DataMetaData getConfigDataMetaData(Long dataId)

getCommittedDataEventCount

public long getCommittedDataEventCount()

getCommittedDataIdCount

public long getCommittedDataIdCount()

getBatchesByNodes

public Map<String,OutgoingBatch> getBatchesByNodes()

getBatchesByGroups

public Map<Integer,Map<String,OutgoingBatch>> getBatchesByGroups()

getAvailableNodes

public Map<TriggerRouter,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 Set<IDataRouter> getUsedDataRouters()

addUsedDataRouter

public void addUsedDataRouter(IDataRouter dataRouter)

getTimesByRouter

public Map<String,Long> getTimesByRouter()

addTimesByRouter

public void addTimesByRouter(String routerId,
 long millis)

resetForNextData

public void resetForNextData()

getCreatedTimeInMs

public long getCreatedTimeInMs()

setLastDataProcessed

public void setLastDataProcessed(Data lastDataProcessed)

getLastDataProcessed

public Data getLastDataProcessed()

getSqlTransaction

public 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 List<DataGap> getDataGaps()

setDataGaps

public void setDataGaps(List<DataGap> dataGaps)

setOnlyDefaultRoutersAssigned

public void setOnlyDefaultRoutersAssigned(boolean onlyDefaultRoutersAssigned)

isOnlyDefaultRoutersAssigned

public boolean isOnlyDefaultRoutersAssigned()

getDataIds

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