public interface Member
Modifier and Type | Field and Description |
---|---|
static byte[] |
SHUTDOWN_PAYLOAD
When a member leaves the cluster, the payload of the memberDisappeared member
will be the following bytes.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
getCommand()
returns the command associated with this member
|
byte[] |
getData(boolean getalive)
Highly optimized version of serializing a member into a byte array
Returns a cached byte[] reference, do not modify this data
|
byte[] |
getData(boolean getalive,
boolean reset)
Highly optimized version of serializing a member into a byte array
Returns a cached byte[] reference, do not modify this data
|
int |
getDataLength()
Length of a message obtained by
getData(boolean) or
getData(boolean, boolean) . |
byte[] |
getDomain()
Domain for this cluster
|
byte[] |
getHost()
Returns the listen host for the ChannelReceiver implementation
|
long |
getMemberAliveTime()
Contains information on how long this member has been online.
|
java.lang.String |
getName()
Returns the name of this node, should be unique within the group.
|
byte[] |
getPayload()
returns the payload associated with this member
|
int |
getPort()
Returns the listen port for the ChannelReceiver implementation
|
int |
getSecurePort()
Returns the secure listen port for the ChannelReceiver implementation.
|
int |
getUdpPort()
Returns the UDP port that this member is listening to for UDP messages.
|
byte[] |
getUniqueId()
returns a UUID unique for this member over all sessions.
|
boolean |
isFailing() |
boolean |
isReady()
The current state of the member
|
boolean |
isSuspect()
The current state of the member
|
void |
setCommand(byte[] command) |
void |
setMemberAliveTime(long memberAliveTime) |
void |
setPayload(byte[] payload) |
static final byte[] SHUTDOWN_PAYLOAD
java.lang.String getName()
byte[] getHost()
ChannelReceiver
int getPort()
ChannelReceiver
int getSecurePort()
ChannelReceiver
int getUdpPort()
long getMemberAliveTime()
void setMemberAliveTime(long memberAliveTime)
boolean isReady()
boolean isSuspect()
boolean isFailing()
byte[] getUniqueId()
byte[] getPayload()
void setPayload(byte[] payload)
byte[] getCommand()
void setCommand(byte[] command)
byte[] getDomain()
byte[] getData(boolean getalive)
getalive
- calculate memberAlive timebyte[] getData(boolean getalive, boolean reset)
getalive
- calculate memberAlive timereset
- reset the cached data package, and create a new oneint getDataLength()
getData(boolean)
or
getData(boolean, boolean)
.Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.