Package org.jumpmind.symmetric.model

Class OutgoingBatch

java.lang.Object

org.jumpmind.symmetric.model.AbstractBatch

org.jumpmind.symmetric.model.OutgoingBatch

All Implemented Interfaces:

Serializable

public class OutgoingBatch
extends AbstractBatch

Used for tracking the sending a collection of data to a node in the system. A new outgoing_batch is created and given a status of 'NE'. After sending the outgoing_batch to its target node, the status becomes 'SE'. The node responds with either a success status of 'OK' or an error status of 'ER'. An error while sending to the node also results in an error status of 'ER' regardless of whether the node sends that acknowledgement.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.model.AbstractBatch

AbstractBatch.Status

Constructor Summary

Constructors

Constructor	Description
OutgoingBatch()
OutgoingBatch(String nodeId, String channelId, AbstractBatch.Status status)

Method Summary

Modifier and Type	Method	Description
Date	getExtractStartTime()
Date	getLastUpdatedTime()
Date	getLoadStartTime()
String	getStagedLocation()
Integer	getThreadId()
Date	getTransferStartTime()
boolean	isExtractJobFlag()
void	setExtractJobFlag(boolean extractJobFlag)
void	setExtractStartTime(Date extractStartTime)
void	setLoadStartTime(Date loadStartTime)
void	setThreadId(Integer threadId)
void	setTransferStartTime(Date transferStartTime)
String	toString()

Methods inherited from class org.jumpmind.symmetric.model.AbstractBatch

buildBatchSummary, equals, getBatchId, getByteCount, getChannelId, getConflictLoseCount, getConflictWinCount, getCreateBy, getCreateTime, getDataDeleteRowCount, getDataInsertRowCount, getDataRowCount, getDataUpdateRowCount, getExtractCount, getExtractDeleteRowCount, getExtractInsertRowCount, getExtractMillis, getExtractRowCount, getExtractUpdateRowCount, getFailedDataId, getFailedLineNumber, getFallbackInsertCount, getFallbackUpdateCount, getFileCounts, getFilterMillis, getIgnoreCount, getIgnoreRowCount, getLastUpdatedHostName, getLoadCount, getLoadDeleteRowCount, getLoadId, getLoadInsertRowCount, getLoadMillis, getLoadRowCount, getLoadUpdateRowCount, getMissingDeleteCount, getNetworkMillis, getNodeBatchId, getNodeId, getOtherRowCount, getProcessedRowCount, getReloadRowCount, getRouterMillis, getSentCount, getSkipCount, getSqlCode, getSqlMessage, getSqlState, getStatus, getSummary, getTableCounts, getTableExtractedCount, getTableLoadedCount, getTransformExtractMillis, getTransformLoadMillis, hashCode, incrementByteCount, incrementDataInsertRowCount, incrementDataRowCount, incrementExtractRowCount, incrementExtractRowCount, incrementFileCount, incrementIgnoreCount, incrementIgnoreRowCount, incrementRowCount, incrementTableCount, isBulkLoaderFlag, isCommonFlag, isErrorFlag, isLoadFlag, resetExtractRowStats, resetRouterStats, resetStats, revertStatsOnError, setBatchId, setBulkLoaderFlag, setByteCount, setChannelId, setCommonFlag, setConflictLoseCount, setConflictWinCount, setCreateBy, setCreateTime, setDataDeleteRowCount, setDataInsertRowCount, setDataRowCount, setDataUpdateRowCount, setErrorFlag, setExtractCount, setExtractDeleteRowCount, setExtractInsertRowCount, setExtractMillis, setExtractRowCount, setExtractUpdateRowCount, setFailedDataId, setFailedLineNumber, setFallbackInsertCount, setFallbackUpdateCount, setFilterMillis, setIgnoreCount, setIgnoreRowCount, setLastUpdatedHostName, setLastUpdatedTime, setLoadCount, setLoadDeleteRowCount, setLoadFlag, setLoadId, setLoadInsertRowCount, setLoadMillis, setLoadRowCount, setLoadUpdateRowCount, setMissingDeleteCount, setNetworkMillis, setNodeId, setOtherRowCount, setProcessedRowCount, setReloadRowCount, setRouterMillis, setSentCount, setSkipCount, setSqlCode, setSqlMessage, setSqlMessage, setSqlState, setStatus, setStatusFromString, setSummary, setTableExtractedCount, setTableLoadedCount, setTransformExtractMillis, setTransformLoadMillis, totalRowCount

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

OutgoingBatch

public OutgoingBatch()

OutgoingBatch

public OutgoingBatch(String nodeId,
 String channelId,
 AbstractBatch.Status status)

Method Details

getLastUpdatedTime

public Date getLastUpdatedTime()

Overrides:

getLastUpdatedTime in class AbstractBatch

getStagedLocation

public String getStagedLocation()

Overrides:

getStagedLocation in class AbstractBatch

toString

public String toString()

Overrides:

toString in class Object

setExtractJobFlag

public void setExtractJobFlag(boolean extractJobFlag)

isExtractJobFlag

public boolean isExtractJobFlag()

getExtractStartTime

public Date getExtractStartTime()

setExtractStartTime

public void setExtractStartTime(Date extractStartTime)

getTransferStartTime

public Date getTransferStartTime()

setTransferStartTime

public void setTransferStartTime(Date transferStartTime)

getLoadStartTime

public Date getLoadStartTime()

setLoadStartTime

public void setLoadStartTime(Date loadStartTime)

getThreadId

public Integer getThreadId()

setThreadId

public void setThreadId(Integer threadId)