public class JoinMessage extends Object implements Externalizable
loadFactor
. Upon receiving this message, members should recalculate their Consistent Hash Ring,
including this member.Constructor and Description |
---|
JoinMessage()
Default constructor required by the
Streamable and Externalizable interfaces. |
JoinMessage(int loadFactor,
Predicate<? super CommandMessage<?>> messageFilter,
int order,
boolean expectReply)
Initializes a JoinMessage with the given
loadFactor . |
Modifier and Type | Method and Description |
---|---|
int |
getLoadFactor()
Returns the loadFactor the member wishes to join with.
|
int |
getOrder()
The index of this message compared to others about the same sender.
|
boolean |
isExpectReply()
Indicates whether the sender of this message expects a reply
|
Predicate<? super CommandMessage<?>> |
messageFilter()
Returns the command message filter used by the member.
|
void |
readExternal(ObjectInput in) |
void |
writeExternal(ObjectOutput out) |
public JoinMessage()
Streamable
and Externalizable
interfaces. Do not use
directly.public JoinMessage(int loadFactor, Predicate<? super CommandMessage<?>> messageFilter, int order, boolean expectReply)
loadFactor
.loadFactor
- The loadFactor the member wishes to join withmessageFilter
- A predicate the will filter command messages this node will accept.order
- The index of this update, allowing recipients to order themexpectReply
- Indicates whether the sending member expects a reply with membership informationpublic int getLoadFactor()
public boolean isExpectReply()
public int getOrder()
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
public Predicate<? super CommandMessage<?>> messageFilter()
Copyright © 2010–2017. All rights reserved.