org.jumpmind.symmetric.model

Class RemoteNodeStatus

java.lang.Object

org.jumpmind.symmetric.model.RemoteNodeStatus

All Implemented Interfaces:

java.io.Serializable

public class RemoteNodeStatus
extends java.lang.Object
implements java.io.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 and Description
static class	RemoteNodeStatus.Status

Constructor Summary

Constructors

Constructor and Description
RemoteNodeStatus(java.lang.String nodeId, java.lang.String channelId, java.util.Map<java.lang.String,Channel> channels)

Method Summary

Modifier and Type	Method and Description
boolean	failed()
long	getBatchesProcessed()
long	getDataProcessed()
java.lang.String	getNodeId()
java.lang.String	getQueue()
long	getReloadBatchesProcessed()
RemoteNodeStatus.Status	getStatus()
java.util.Map<java.lang.String,java.lang.Integer>	getTableCounts()
java.lang.String	getTableSummary()
protected void	incrementTableCounts(AbstractBatch batch)
boolean	isComplete()
void	resetCounts()
void	resetTableSummary()
void	setComplete(boolean complete)
void	setNodeId(java.lang.String nodeId)
void	setQueue(java.lang.String queue)
void	setStatus(RemoteNodeStatus.Status status)
void	updateIncomingStatus(java.util.List<IncomingBatch> incomingBatches)
void	updateOutgoingStatus(java.util.List<OutgoingBatch> outgoingBatches, java.util.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 Detail

RemoteNodeStatus

public RemoteNodeStatus(java.lang.String nodeId,
                        java.lang.String channelId,
                        java.util.Map<java.lang.String,Channel> channels)

Method Detail

failed

public boolean failed()

getNodeId

public java.lang.String getNodeId()

setNodeId

public void setNodeId(java.lang.String nodeId)

getQueue

public java.lang.String getQueue()

setQueue

public void setQueue(java.lang.String queue)

getStatus

public RemoteNodeStatus.Status getStatus()

setStatus

public void setStatus(RemoteNodeStatus.Status status)

getDataProcessed

public long getDataProcessed()

getBatchesProcessed

public long getBatchesProcessed()

getReloadBatchesProcessed

public long getReloadBatchesProcessed()

updateIncomingStatus

public void updateIncomingStatus(java.util.List<IncomingBatch> incomingBatches)

updateOutgoingStatus

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

resetCounts

public void resetCounts()

setComplete

public void setComplete(boolean complete)

isComplete

public boolean isComplete()

waitCompleted

public boolean waitCompleted(long milliseconds)
                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getTableCounts

public java.util.Map<java.lang.String,java.lang.Integer> getTableCounts()

getTableSummary

public java.lang.String getTableSummary()

incrementTableCounts

protected void incrementTableCounts(AbstractBatch batch)

resetTableSummary

public void resetTableSummary()