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(org.jgroups.Address address,
int loadFactor,
Predicate<? super CommandMessage<?>> messageFilter)
Initializes a JoinMessage with the given
loadFactor . |
Modifier and Type | Method and Description |
---|---|
int |
getLoadFactor()
Returns the loadFactor the member wishes to join with.
|
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(org.jgroups.Address address, int loadFactor, Predicate<? super CommandMessage<?>> messageFilter)
loadFactor
.address
- The address of the cluster memberloadFactor
- The loadFactor the member wishes to join withmessageFilter
- A predicate the will filter command messages this node will accept.public int getLoadFactor()
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.