com.hazelcast.internal.util.iterator

Class RestartingMemberIterator

java.lang.Object

com.hazelcast.internal.util.iterator.RestartingMemberIterator

All Implemented Interfaces:

ChainingFuture.ExceptionHandler, Iterator<Member>

public class RestartingMemberIterator
extends Object
implements Iterator<Member>, ChainingFuture.ExceptionHandler

Iterates over stable cluster from the oldest to youngest member. It restarts when detects a cluster topology change.

It can be used from multiple threads, but not concurrently.

Constructor Summary

Constructors

Constructor and Description
RestartingMemberIterator(ClusterService clusterService, int maxRetries)

Method Summary

Modifier and Type	Method and Description
int	getRetryCount()
<T extends Throwable> void	handle(T throwable)
boolean	hasNext()
Member	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

RestartingMemberIterator

public RestartingMemberIterator(ClusterService clusterService,
                                int maxRetries)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Member>

next

public Member next()

Specified by:

next in interface Iterator<Member>

remove

public void remove()

Specified by:

remove in interface Iterator<Member>

handle

public <T extends Throwable> void handle(T throwable)
                                  throws T extends Throwable

Specified by:

handle in interface ChainingFuture.ExceptionHandler

Throws:

T extends Throwable

getRetryCount

public int getRetryCount()