Package org.jumpmind.symmetric.model

Class ProcessInfo

java.lang.Object
org.jumpmind.symmetric.model.ProcessInfo
All Implemented Interfaces:
Serializable, Cloneable, Comparable<ProcessInfo>
public class ProcessInfo extends Object implements Serializable, Comparable<ProcessInfo>, Cloneable
See Also:

  • Constructor Details

    • ProcessInfo

      public ProcessInfo()

    • ProcessInfo

      public ProcessInfo(ProcessInfoKey key)

  • Method Details

    • getSourceNodeId

      public String getSourceNodeId()

    • getTargetNodeId

      public String getTargetNodeId()

    • getProcessType

      public ProcessType getProcessType()

    • getKey

      public ProcessInfoKey getKey()

    • setKey

      public void setKey(ProcessInfoKey key)

    • getStatus

      public ProcessInfo.ProcessStatus getStatus()

    • setStatus

      public void setStatus(ProcessInfo.ProcessStatus status)

    • getCurrentDataCount

      public long getCurrentDataCount()

    • setCurrentDataCount

      public void setCurrentDataCount(long dataCount)

    • getCurrentRowCount

      public long getCurrentRowCount()

    • setCurrentRowCount

      public void setCurrentRowCount(long rowCount)

    • getTotalBatchCount

      public long getTotalBatchCount()

    • setTotalBatchCount

      public void setTotalBatchCount(long batchCount)

    • incrementCurrentDataCount

      public void incrementCurrentDataCount()

    • incrementBatchCount

      public void incrementBatchCount()

    • incrementCurrentBatchCount

      public void incrementCurrentBatchCount()

    • getCurrentBatchCount

      public long getCurrentBatchCount()

    • setCurrentBatchCount

      public void setCurrentBatchCount(long currentBatchCount)

    • getCurrentBatchId

      public long getCurrentBatchId()

    • setCurrentBatchId

      public void setCurrentBatchId(long currentBatchId)

    • setCurrentLoadId

      public void setCurrentLoadId(long loadId)

    • getCurrentLoadId

      public long getCurrentLoadId()

    • getQueue

      public String getQueue()

    • getCurrentChannelId

      public String getCurrentChannelId()

    • setCurrentChannelId

      public void setCurrentChannelId(String currentChannelId)

    • getThread

      public Thread getThread()

    • setThread

      public void setThread(Thread thread)

    • getStartTime

      public Date getStartTime()

    • getEndTime

      public Date getEndTime()

    • setEndTime

      public void setEndTime(Date endTime)

    • setCurrentTableName

      public void setCurrentTableName(String currentTableName)

    • getCurrentTableName

      public String getCurrentTableName()

    • getLastStatusChangeTime

      public Date getLastStatusChangeTime()

    • getCurrentBatchStartTime

      public Date getCurrentBatchStartTime()

    • setCurrentBatchStartTime

      public void setCurrentBatchStartTime(Date currentBatchStartTime)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • showInError

      public String showInError(String identityNodeId)

    • compareTo

      public int compareTo(ProcessInfo o)
      Specified by:
      compareTo in interface Comparable<ProcessInfo>

    • getThreadData

      public ProcessInfo.ThreadData getThreadData()

    • getThreadData

      public static ProcessInfo.ThreadData getThreadData(long threadId)

    • getTotalDataCount

      public long getTotalDataCount()

    • setTotalDataCount

      public void setTotalDataCount(long totalDataCount)

    • setListener

      public void setListener(IProcessInfoListener listener)

    • isBulkLoadFlag

      public boolean isBulkLoadFlag()

    • setBulkLoadFlag

      public void setBulkLoadFlag(boolean bulkLoadFlag)

    • copy

      public ProcessInfo copy()

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object