public class SimpleRouterContext
extends org.jumpmind.util.Context
| 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 |
| Constructor and Description |
|---|
SimpleRouterContext() |
SimpleRouterContext(java.lang.String nodeId,
NodeChannel channel) |
| 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) |
protected final org.slf4j.Logger log
protected NodeChannel channel
protected boolean encountedTransactionBoundary
protected java.util.Map<java.lang.String,java.lang.Long> stats
protected java.lang.String nodeId
protected boolean requestGapDetection
public SimpleRouterContext()
public SimpleRouterContext(java.lang.String nodeId,
NodeChannel channel)
public org.jumpmind.db.util.BinaryEncoding getBinaryEncoding()
public long getBatchId()
public java.lang.String getSourceNodeId()
public NodeChannel getChannel()
public java.util.Map<java.lang.String,java.lang.Object> getContextCache()
public void setEncountedTransactionBoundary(boolean encountedTransactionBoundary)
public boolean isEncountedTransactionBoundary()
public void incrementStat(long amount,
java.lang.String name)
public long getStat(java.lang.String name)
public void logStats(org.slf4j.Logger log,
long totalTimeInMs)
public void transferStats(SimpleRouterContext ctx)