java.lang.Object
org.broadleafcommerce.common.persistence.transaction.TransactionInfo

public class TransactionInfo extends Object
POJO for in-progress transaction information. Includes thread and query information.
Author:
Jeff Fischer
  • Field Details

    • entityManager

      protected WeakReference<jakarta.persistence.EntityManager> entityManager
    • definition

      protected WeakReference<org.springframework.transaction.TransactionDefinition> definition
    • beginStack

      protected String beginStack
    • compressedBeginStack

      protected CompressedItem compressedBeginStack
    • thread

      protected WeakReference<Thread> thread
    • threadName

      protected String threadName
    • threadId

      protected String threadId
    • startTime

      protected Long startTime
    • queries

      protected LinkedBlockingQueue<String> queries
    • compressedQueries

      protected LinkedBlockingQueue<CompressedItem> compressedQueries
    • additionalParams

      protected Map<String,String> additionalParams
    • currentStackElement

      protected String currentStackElement
    • lastLogTime

      protected Long lastLogTime
    • stuckThreadStartTime

      protected Long stuckThreadStartTime
    • faultStateDetected

      protected Boolean faultStateDetected
    • isCompressed

      protected Boolean isCompressed
    • requestContext

      protected String requestContext
    • isAbbreviated

      protected Boolean isAbbreviated
    • abbreviatedLength

      protected Integer abbreviatedLength
    • decompressStatementForLog

      protected Boolean decompressStatementForLog
    • maxQueryListLength

      protected Integer maxQueryListLength
    • totalQueries

      protected Integer totalQueries
  • Constructor Details

    • TransactionInfo

      public TransactionInfo()
    • TransactionInfo

      public TransactionInfo(jakarta.persistence.EntityManager em, org.springframework.transaction.TransactionDefinition definition, boolean isCompressed, boolean isAbbreviated, int abbreviatedLength, boolean decompressStatementForLog, int maxQueryListLength)
  • Method Details

    • getEntityManager

      public jakarta.persistence.EntityManager getEntityManager()
    • setEntityManager

      public void setEntityManager(jakarta.persistence.EntityManager entityManager)
    • getDefinition

      public org.springframework.transaction.TransactionDefinition getDefinition()
    • setDefinition

      public void setDefinition(org.springframework.transaction.TransactionDefinition definition)
    • getBeginStack

      public String getBeginStack()
    • setBeginStack

      public void setBeginStack(String beginStack)
    • getCompressedBeginStack

      public CompressedItem getCompressedBeginStack()
    • setCompressedBeginStack

      public void setCompressedBeginStack(CompressedItem compressedBeginStack)
    • getThread

      public Thread getThread()
    • setThread

      public void setThread(Thread thread)
    • getThreadName

      public String getThreadName()
    • setThreadName

      public void setThreadName(String threadName)
    • getThreadId

      public String getThreadId()
    • setThreadId

      public void setThreadId(String threadId)
    • getCurrentStackElement

      public String getCurrentStackElement()
    • setCurrentStackElement

      public void setCurrentStackElement(String currentStackElement)
    • getLastLogTime

      public Long getLastLogTime()
    • setLastLogTime

      public void setLastLogTime(Long lastLogTime)
    • getStuckThreadStartTime

      public Long getStuckThreadStartTime()
    • setStuckThreadStartTime

      public void setStuckThreadStartTime(Long stuckThreadStartTime)
    • getStartTime

      public Long getStartTime()
    • setStartTime

      public void setStartTime(Long startTime)
    • getAdditionalParams

      public Map<String,String> getAdditionalParams()
    • setAdditionalParams

      public void setAdditionalParams(Map<String,String> additionalParams)
    • getQueries

      public LinkedBlockingQueue<String> getQueries()
    • setQueries

      public void setQueries(LinkedBlockingQueue<String> queries)
    • getCompressedQueries

      public LinkedBlockingQueue<CompressedItem> getCompressedQueries()
    • setCompressedQueries

      public void setCompressedQueries(LinkedBlockingQueue<CompressedItem> compressedQueries)
    • getDecompressStatementForLog

      public Boolean getDecompressStatementForLog()
    • setDecompressStatementForLog

      public void setDecompressStatementForLog(Boolean decompressStatementForLog)
    • getFaultStateDetected

      public Boolean getFaultStateDetected()
    • setFaultStateDetected

      public void setFaultStateDetected(Boolean faultStateDetected)
    • getAbbreviated

      public Boolean getAbbreviated()
    • setAbbreviated

      public void setAbbreviated(Boolean abbreviated)
    • getAbbreviatedLength

      public Integer getAbbreviatedLength()
    • setAbbreviatedLength

      public void setAbbreviatedLength(Integer abbreviatedLength)
    • getMaxQueryListLength

      public Integer getMaxQueryListLength()
    • setMaxQueryListLength

      public void setMaxQueryListLength(Integer maxQueryListLength)
    • clear

      public void clear()
    • logStatement

      public void logStatement(String statement)
    • initialize

      protected void initialize()
    • toString

      public String toString()
      Overrides:
      toString in class Object