org.jumpmind.symmetric.route

Class SimpleRouterContext

java.lang.Object

org.jumpmind.util.Context

org.jumpmind.symmetric.route.SimpleRouterContext

Direct Known Subclasses:

ChannelRouterContext

public class SimpleRouterContext
extends org.jumpmind.util.Context

Field Summary

Fields

Modifier and Type	Field and Description
protected NodeChannel	channel
protected boolean	encountedTransactionBoundary
protected org.slf4j.Logger	log
protected java.lang.String	nodeId
protected boolean	requestGapDetection
protected java.util.Map<java.lang.String,java.lang.Long>	stats

Fields inherited from class org.jumpmind.util.Context

context

Constructor Summary

Constructors

Constructor and Description
SimpleRouterContext()
SimpleRouterContext(java.lang.String nodeId, NodeChannel channel)

Method Summary

Modifier and Type	Method and Description
long	getBatchId()
org.jumpmind.db.util.BinaryEncoding	getBinaryEncoding()
NodeChannel	getChannel()
java.util.Map<java.lang.String,java.lang.Object>	getContextCache()
java.lang.String	getSourceNodeId()
long	getStat(java.lang.String name)
void	incrementStat(long amount, java.lang.String name)
boolean	isEncountedTransactionBoundary()
void	logStats(org.slf4j.Logger log, long totalTimeInMs)
void	setEncountedTransactionBoundary(boolean encountedTransactionBoundary)
void	transferStats(SimpleRouterContext ctx)

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

log

protected final org.slf4j.Logger log

channel

protected NodeChannel channel

encountedTransactionBoundary

protected boolean encountedTransactionBoundary

stats

protected java.util.Map<java.lang.String,java.lang.Long> stats

nodeId

protected java.lang.String nodeId

requestGapDetection

protected boolean requestGapDetection

Constructor Detail

SimpleRouterContext

public SimpleRouterContext()

SimpleRouterContext

public SimpleRouterContext(java.lang.String nodeId,
                           NodeChannel channel)

Method Detail

getBinaryEncoding

public org.jumpmind.db.util.BinaryEncoding getBinaryEncoding()

getBatchId

public long getBatchId()

getSourceNodeId

public java.lang.String getSourceNodeId()

getChannel

public NodeChannel getChannel()

getContextCache

public java.util.Map<java.lang.String,java.lang.Object> getContextCache()

setEncountedTransactionBoundary

public void setEncountedTransactionBoundary(boolean encountedTransactionBoundary)

isEncountedTransactionBoundary

public boolean isEncountedTransactionBoundary()

incrementStat

public void incrementStat(long amount,
                          java.lang.String name)

getStat

public long getStat(java.lang.String name)

logStats

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

transferStats

public void transferStats(SimpleRouterContext ctx)