public class GossipRouter extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
GossipRouter.ConnectionTearListener |
Modifier and Type | Field and Description |
---|---|
static byte |
CLOSE |
static byte |
CONNECT |
static byte |
CONNECT_OK |
protected List<GossipRouter.ConnectionTearListener> |
connectionTearListeners |
protected ThreadFactory |
default_thread_factory |
static byte |
DISCONNECT |
static byte |
DISCONNECT_OK |
static byte |
GOSSIP_GET |
protected Log |
log |
static byte |
MESSAGE |
static byte |
OP_FAIL |
static byte |
PING |
static int |
PORT |
static byte |
SUSPECT |
protected Timer |
timer |
Constructor and Description |
---|
GossipRouter() |
GossipRouter(int port) |
GossipRouter(int port,
String bindAddressString) |
GossipRouter(int port,
String bindAddressString,
boolean jmx) |
GossipRouter(int port,
String bindAddressString,
boolean jmx,
long expiryTime) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
destroy() |
String |
dumpAddresssMappings() |
String |
dumpRoutingTable() |
String |
dumpRoutingTableDetailed() |
int |
getBacklog() |
String |
getBindAddress() |
ThreadFactory |
getDefaultThreadPoolThreadFactory() |
long |
getExpiryTime() |
long |
getLingerTimeout() |
int |
getPort() |
long |
getSocketReadTimeout() |
boolean |
isDiscardLoopbacks() |
boolean |
isRunning() |
boolean |
isStarted() |
static void |
main(String[] args) |
void |
setBacklog(int backlog) |
void |
setBindAddress(String bindAddress) |
void |
setDiscardLoopbacks(boolean discard_loopbacks) |
void |
setExpiryTime(long expiryTime) |
void |
setLingerTimeout(long linger_timeout) |
void |
setPort(int port) |
void |
setSocketReadTimeout(long sock_read_timeout) |
void |
start()
Lifecycle operation.
|
void |
stop()
Always called before destroy().
|
static String |
type2String(int type) |
public static final byte CONNECT
public static final byte DISCONNECT
public static final byte GOSSIP_GET
public static final byte MESSAGE
public static final byte SUSPECT
public static final byte PING
public static final byte CLOSE
public static final byte CONNECT_OK
public static final byte OP_FAIL
public static final byte DISCONNECT_OK
public static final int PORT
protected List<GossipRouter.ConnectionTearListener> connectionTearListeners
protected ThreadFactory default_thread_factory
protected Timer timer
protected final Log log
public GossipRouter()
public GossipRouter(int port)
public GossipRouter(int port, String bindAddressString)
public GossipRouter(int port, String bindAddressString, boolean jmx)
public GossipRouter(int port, String bindAddressString, boolean jmx, long expiryTime)
public void setPort(int port)
public int getPort()
public void setBindAddress(String bindAddress)
public String getBindAddress()
public int getBacklog()
public void setBacklog(int backlog)
public void setExpiryTime(long expiryTime)
public long getExpiryTime()
public boolean isStarted()
public boolean isDiscardLoopbacks()
public void setDiscardLoopbacks(boolean discard_loopbacks)
public long getLingerTimeout()
public void setLingerTimeout(long linger_timeout)
public long getSocketReadTimeout()
public void setSocketReadTimeout(long sock_read_timeout)
public ThreadFactory getDefaultThreadPoolThreadFactory()
public static String type2String(int type)
public void start() throws Exception
Exception
public void stop()
public void clear()
public void destroy()
public boolean isRunning()
public String dumpRoutingTable()
public String dumpRoutingTableDetailed()
public String dumpAddresssMappings()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.