Package 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 Context

  • Field Details

    • log

      protected final org.slf4j.Logger log

    • channel

      protected NodeChannel channel

    • encountedTransactionBoundary

      protected boolean encountedTransactionBoundary

    • stats

      protected Map<String,Long> stats

    • nodeId

      protected String nodeId

    • requestGapDetection

      protected boolean requestGapDetection

    • batchSizeNotToExceed

      protected int batchSizeNotToExceed

    • routerTimers

      protected Map<String,SimpleRouterContext.RouterTimer> routerTimers

  • Constructor Details

    • SimpleRouterContext

      public SimpleRouterContext()

    • SimpleRouterContext

      public SimpleRouterContext(String nodeId, NodeChannel channel)

  • Method Details

    • addQueryTime

      public SimpleRouterContext.RouterTimer addQueryTime(String routerId, long qt)

    • getBinaryEncoding

      public BinaryEncoding getBinaryEncoding()

    • getBatchId

      public long getBatchId()

    • getSourceNodeId

      public String getSourceNodeId()

    • getChannel

      public NodeChannel getChannel()

    • getContextCache

      public Map<String,Object> getContextCache()

    • setEncountedTransactionBoundary

      public void setEncountedTransactionBoundary(boolean encountedTransactionBoundary)

    • isEncountedTransactionBoundary

      public boolean isEncountedTransactionBoundary()

    • getBatchSizeNotToExceed

      public int getBatchSizeNotToExceed()

    • setBatchSizeNotToExceed

      public void setBatchSizeNotToExceed(int batchSizeNotToExceed)

    • incrementStat

      public void incrementStat(long amount, String name)

    • getStat

      public long getStat(String name)

    • logStats

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

    • transferStats

      public void transferStats(SimpleRouterContext ctx)