Package org.jumpmind.symmetric.model

Class RemoteNodeStatus

java.lang.Object

org.jumpmind.symmetric.model.RemoteNodeStatus

All Implemented Interfaces:

Serializable

public class RemoteNodeStatus
extends Object
implements Serializable

Indicates the status of an attempt to transport data from or to a remove node.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	RemoteNodeStatus.Status

Constructor Summary

Constructors

Constructor	Description
RemoteNodeStatus(String nodeId, String channelId, Map<String,Channel> channels)

Method Summary

Modifier and Type	Method	Description
boolean	failed()
long	getBatchesProcessed()
long	getDataProcessed()
String	getNodeId()
String	getQueue()
long	getReloadBatchesProcessed()
RemoteNodeStatus.Status	getStatus()
Map<String,Integer>	getTableCounts()
String	getTableSummary()
protected void	incrementTableCounts(AbstractBatch batch)
boolean	isComplete()
void	resetCounts()
void	resetTableSummary()
void	setComplete(boolean complete)
void	setDataProcessed(long dataProcessed)
void	setNodeId(String nodeId)
void	setQueue(String queue)
void	setStatus(RemoteNodeStatus.Status status)
void	updateIncomingStatus(List<IncomingBatch> incomingBatches)
void	updateOutgoingStatus(List<OutgoingBatch> outgoingBatches, List<BatchAck> batches)
boolean	waitCompleted(long milliseconds)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RemoteNodeStatus

public RemoteNodeStatus(String nodeId,
 String channelId,
 Map<String,Channel> channels)

Method Details

failed

public boolean failed()

getNodeId

public String getNodeId()

setNodeId

public void setNodeId(String nodeId)

getQueue

public String getQueue()

setQueue

public void setQueue(String queue)

getStatus

public RemoteNodeStatus.Status getStatus()

setStatus

public void setStatus(RemoteNodeStatus.Status status)

getDataProcessed

public long getDataProcessed()

setDataProcessed

public void setDataProcessed(long dataProcessed)

getBatchesProcessed

public long getBatchesProcessed()

getReloadBatchesProcessed

public long getReloadBatchesProcessed()

updateIncomingStatus

public void updateIncomingStatus(List<IncomingBatch> incomingBatches)

updateOutgoingStatus

public void updateOutgoingStatus(List<OutgoingBatch> outgoingBatches,
 List<BatchAck> batches)

resetCounts

public void resetCounts()

setComplete

public void setComplete(boolean complete)

isComplete

public boolean isComplete()

waitCompleted

public boolean waitCompleted(long milliseconds)
                      throws InterruptedException

Throws:

InterruptedException

getTableCounts

public Map<String,Integer> getTableCounts()

getTableSummary

public String getTableSummary()

incrementTableCounts

protected void incrementTableCounts(AbstractBatch batch)

resetTableSummary

public void resetTableSummary()