org.jumpmind.symmetric.model

Class RemoteNodeStatuses

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

java.util.ArrayList<RemoteNodeStatus>

org.jumpmind.symmetric.model.RemoteNodeStatuses

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Iterable<RemoteNodeStatus>, java.util.Collection<RemoteNodeStatus>, java.util.List<RemoteNodeStatus>, java.util.RandomAccess

public class RemoteNodeStatuses
extends java.util.ArrayList<RemoteNodeStatus>

See Also:

Serialized Form

Field Summary

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
RemoteNodeStatus	add(java.lang.String nodeId)
RemoteNodeStatus	add(java.lang.String nodeId, java.lang.String queue)
boolean	errorOccurred()
long	getDataProcessedCount()
boolean	isComplete()
void	waitForComplete(long timeout)
boolean	wasBatchProcessed()
boolean	wasDataProcessed()

Methods inherited from class java.util.ArrayList

add, add, addAll, addAll, clear, clone, contains, ensureCapacity, forEach, get, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSize

Methods inherited from class java.util.AbstractList

equals, hashCode

Methods inherited from class java.util.AbstractCollection

containsAll, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.List

containsAll, equals, hashCode

Methods inherited from interface java.util.Collection

parallelStream, stream

Constructor Detail

RemoteNodeStatuses

public RemoteNodeStatuses(java.util.Map<java.lang.String,Channel> channels)

Method Detail

wasDataProcessed

public boolean wasDataProcessed()

wasBatchProcessed

public boolean wasBatchProcessed()

getDataProcessedCount

public long getDataProcessedCount()

errorOccurred

public boolean errorOccurred()

add

public RemoteNodeStatus add(java.lang.String nodeId,
                            java.lang.String queue)

add

public RemoteNodeStatus add(java.lang.String nodeId)

isComplete

public boolean isComplete()

waitForComplete

public void waitForComplete(long timeout)