public class RemoteNodeStatus
extends java.lang.Object
implements java.io.Serializable
| Modifier and Type | Class and Description |
|---|---|
static class |
RemoteNodeStatus.Status |
| Constructor and Description |
|---|
RemoteNodeStatus(java.lang.String nodeId,
java.lang.String channelId,
java.util.Map<java.lang.String,Channel> channels) |
| 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) |
public RemoteNodeStatus(java.lang.String nodeId,
java.lang.String channelId,
java.util.Map<java.lang.String,Channel> channels)
public boolean failed()
public java.lang.String getNodeId()
public void setNodeId(java.lang.String nodeId)
public java.lang.String getQueue()
public void setQueue(java.lang.String queue)
public RemoteNodeStatus.Status getStatus()
public void setStatus(RemoteNodeStatus.Status status)
public long getDataProcessed()
public long getBatchesProcessed()
public long getReloadBatchesProcessed()
public void updateIncomingStatus(java.util.List<IncomingBatch> incomingBatches)
public void updateOutgoingStatus(java.util.List<OutgoingBatch> outgoingBatches, java.util.List<BatchAck> batches)
public void resetCounts()
public void setComplete(boolean complete)
public boolean isComplete()
public boolean waitCompleted(long milliseconds)
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic java.util.Map<java.lang.String,java.lang.Integer> getTableCounts()
public java.lang.String getTableSummary()
protected void incrementTableCounts(AbstractBatch batch)
public void resetTableSummary()