Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.cs |
This package contains all client-server related interfaces and classes
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.protocols.tom | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
void |
JChannel.close()
Destroys the channel and its associated resources (e.g.
|
JChannel |
JChannel.connect(String cluster_name)
Joins the cluster.
|
protected JChannel |
JChannel.connect(String cluster_name,
boolean useFlushIfPresent)
Connects the channel to a cluster.
|
JChannel |
JChannel.disconnect()
Leaves the cluster (disconnects the channel if it is connected).
|
Map<String,Object> |
JChannel.dumpStats()
Returns a map of statistics of the various protocols and of the channel itself
|
Map<String,Object> |
JChannel.dumpStats(String protocol_name) |
String |
JChannel.printProtocolSpec(boolean include_props)
Dumps all protocols in string format.
|
JChannel |
JChannel.resetStats() |
String |
JChannel.toString(boolean details) |
Modifier and Type | Method and Description |
---|---|
void |
ReplCache.clear()
Removes all keys and values in the L2 and L1 caches
|
void |
Cache.disableReaping() |
String |
PartitionedHashMap.dump() |
String |
ReplCache.dump() |
void |
Cache.enableReaping(long interval)
Runs the reaper every interval ms, evicts expired items
|
V |
PartitionedHashMap.get(K key) |
V |
ReplCache.get(K key)
Returns the value associated with key
|
V |
Cache.get(K key) |
void |
PartitionedHashMap.put(K key,
V val) |
void |
ReplCache.put(K key,
V val) |
void |
PartitionedHashMap.put(K key,
V val,
long caching_time)
Adds a key/value to the cache, replacing a previous item if there was one
|
V |
Cache.put(K key,
V val,
long caching_time) |
void |
ReplCache.put(K key,
V val,
short repl_count,
long timeout)
Places a key/value pair into one or several nodes in the cluster.
|
void |
ReplCache.put(K key,
V val,
short repl_count,
long timeout,
boolean synchronous)
Places a key/value pair into one or several nodes in the cluster.
|
void |
PartitionedHashMap.remove(K key) |
void |
ReplCache.remove(K key)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
ReplCache.remove(K key,
boolean synchronous)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
PartitionedHashMap.start() |
void |
ReplCache.start() |
void |
MemcachedConnector.start() |
void |
Cache.start() |
void |
PartitionedHashMap.stop() |
void |
ReplCache.stop() |
void |
MemcachedConnector.stop() |
void |
Cache.stop() |
String |
Cache.toString() |
Modifier and Type | Method and Description |
---|---|
String |
NioBaseServer.printBuffers()
Prints send and receive buffers for all connections
|
String |
BaseServer.printConnections() |
void |
NioServer.start() |
void |
NioServer.stop() |
Modifier and Type | Method and Description |
---|---|
String |
JmxDemo.sayName() |
Modifier and Type | Method and Description |
---|---|
void |
TCPGOSSIP.addInitialHost(String hostname,
int port) |
void |
Discovery.addToCache(String filename) |
void |
TP.bundler(String type) |
void |
TP.bundlerStatsReset() |
void |
MERGE3.checkInconsistencies() |
void |
FRAG3.clearAllFragments() |
void |
FRAG2.clearAllFragments() |
void |
TCP.clearConnections() |
void |
TCP_NIO2.clearConnections() |
TP |
TP.clearDifferentClusterCache() |
TP |
TP.clearDifferentVersionCache() |
void |
UDP.clearDroppedMessagesCache() |
void |
TCPPING.clearDynamicHostList() |
void |
FRAG3.clearFragmentsFor(Address mbr) |
void |
FRAG2.clearFragmentsFor(Address mbr) |
void |
TP.clearLogicalAddressCache()
Clears the cache.
|
void |
MERGE3.clearViews() |
void |
UNICAST3.closeIdleConnections() |
void |
TP.disableDiagnostics() |
void |
Discovery.dumpCache(String output_filename) |
String |
COUNTER.dumpPendingRequests() |
static String |
SHARED_LOOPBACK.dumpRoutingTable() |
String |
TP.dumpTimerTasks() |
String |
MERGE3.dumpViews() |
TP |
TP.enableBlockingTimerTasks(boolean flag) |
void |
TP.enableDiagnostics() |
void |
TP.evictLogicalAddressCache() |
String |
Discovery.findInitialMembersAsString() |
void |
INJECT_VIEW.injectView(String newView) |
boolean |
FD_HOST.isAlive(String host) |
void |
BARRIER.openBarrier() |
String |
TCPGOSSIP.print() |
String |
TUNNEL.print() |
String |
SimpleTCP.printAddressTable() |
String |
UNICAST3.printAgeOutCache() |
String |
TCP_NIO2.printBuffers() |
String |
FD_SOCK.printCache() |
String |
PDC.printCache() |
String |
UNICAST3.printConnections() |
String |
TCP.printConnections() |
String |
TCP_NIO2.printConnections() |
String |
COUNTER.printCounters() |
String |
UFC.printCredits() |
String |
MFC.printCredits() |
String |
FD_HOST.printHosts() |
protected String |
BARRIER.printInFlightThreads() |
String |
Locking.printLocks() |
String |
TP.printLogicalAddressCache() |
String |
FlowControl.printReceiverCredits() |
String |
UNICAST3.printReceiveWindowMessages() |
String |
TCPGOSSIP.printReconnectList() |
String |
TUNNEL.printReconnectList() |
String |
UFC.printSenderCredits() |
String |
MFC.printSenderCredits() |
String |
UNICAST3.printSendWindowMessages() |
String |
STATS.printStats() |
String |
TCPGOSSIP.printStubs() |
String |
TUNNEL.printStubs() |
String |
FD_SOCK.printSuspectHistory() |
String |
FD.printSuspectHistory() |
String |
FD_ALL2.printSuspectHistory() |
String |
FD_HOST.printSuspectHistory() |
String |
FD_ALL.printSuspectHistory() |
String |
FD_ALL2.printTimestamps() |
String |
FD_HOST.printTimestamps() |
String |
FD_ALL.printTimestamps() |
String |
TP.printWhoHasCache() |
void |
UNICAST3.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
int |
UNICAST3.removeConnections(boolean remove_send_connections,
boolean remove_receive_connections)
Removes send- and/or receive-connections whose state is not OPEN (CLOSING or CLOSED).
|
int |
UNICAST3.removeExpiredConnections() |
boolean |
TCPGOSSIP.removeInitialHost(String hostname,
int port) |
void |
SEQUENCER2.resetStats() |
void |
SEQUENCER.resetStats() |
void |
Discovery.sendCacheInformation() |
void |
MERGE3.sendInfo() |
void |
ASYM_ENCRYPT.sendKeyRequest() |
void |
UNICAST3.sendPendingAcks() |
void |
TP.setMessageProcessingPolicy(String policy) |
void |
RELAY.setRelay(boolean relay) |
void |
FD.startFailureDetection() |
void |
FD_ALL2.startFailureDetection() |
void |
FD_ALL.startFailureDetection() |
void |
DISCARD.startGui() |
boolean |
FD_SOCK.startNodeCrashMonitor() |
void |
FD.stopFailureDetection() |
void |
FD_ALL2.stopFailureDetection() |
void |
FD_ALL.stopFailureDetection() |
void |
DISCARD.stopGui() |
void |
UNICAST3.triggerXmit() |
void |
FlowControl.unblock()
Allows to unblock all blocked senders from an external program, e.g.
|
void |
MFC.unblock()
Allows to unblock a blocked sender from an external program, e.g.
|
void |
Locking.unlockAll() |
void |
Discovery.weedOutCompletedDiscoveryResponses()
Removes responses which are done or whose timeout has expired (in the latter case, an expired response is marked as done)
|
void |
FILE_PING.writeInfo() |
Modifier and Type | Method and Description |
---|---|
String |
RELAY2.printRoutes() |
Modifier and Type | Method and Description |
---|---|
String |
SUPERVISOR.dumpRules() |
String |
SUPERVISOR.executions() |
void |
SUPERVISOR.installRule(long interval,
String classname) |
void |
SUPERVISOR.installRule(String name,
long interval,
String classname) |
void |
SUPERVISOR.uninstallRule(String name) |
Modifier and Type | Method and Description |
---|---|
String |
TOA.getMessageList() |
Modifier and Type | Method and Description |
---|---|
String |
GossipRouter.dumpAddresssMappings() |
String |
GossipRouter.dumpRoutingTable() |
void |
Protocol.resetStatistics() |
void |
GossipRouter.start()
Lifecycle operation.
|
void |
GossipRouter.stop()
Always called before destroy().
|
Modifier and Type | Method and Description |
---|---|
String |
MaxOneThreadPerSender.dump() |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.