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.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.
|
Modifier and Type | Method and Description |
---|---|
void |
JChannel.close() |
void |
JChannel.connect(String cluster_name) |
protected void |
JChannel.connect(String cluster_name,
boolean useFlushIfPresent)
Connects the channel to a group.
|
void |
JChannel.disconnect() |
Map<String,Object> |
JChannel.dumpStats() |
Map<String,Object> |
JChannel.dumpStats(String protocol_name) |
String |
JChannel.dumpTimerQueue() |
String |
JChannel.printProtocolSpec(boolean include_properties)
Returns a pretty-printed form of all the protocols.
|
void |
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 |
ReplCache.dump() |
String |
PartitionedHashMap.dump() |
void |
Cache.enableReaping(long interval)
Runs the reaper every interval ms, evicts expired items
|
V |
Cache.get(K key) |
V |
ReplCache.get(K key)
Returns the value associated with key
|
V |
PartitionedHashMap.get(K key) |
void |
ReplCache.put(K key,
V val) |
void |
PartitionedHashMap.put(K key,
V val) |
V |
Cache.put(K key,
V val,
long caching_time) |
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
|
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 |
ReplCache.remove(K key)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
PartitionedHashMap.remove(K key) |
void |
ReplCache.remove(K key,
boolean synchronous)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
Cache.start() |
void |
MemcachedConnector.start() |
void |
ReplCache.start() |
void |
PartitionedHashMap.start() |
void |
Cache.stop() |
void |
MemcachedConnector.stop() |
void |
ReplCache.stop() |
void |
PartitionedHashMap.stop() |
String |
Cache.toString() |
Modifier and Type | Method and Description |
---|---|
String |
JmxDemo.sayName() |
Modifier and Type | Method and Description |
---|---|
void |
TCPGOSSIP.addInitialHost(String hostname,
int port) |
void |
FRAG2.clearAllFragments() |
void |
TP.clearDifferentClusterCache() |
void |
TP.clearDifferentVersionCache() |
void |
TCPPING.clearDynamicHostList() |
void |
FRAG2.clearFragmentsFor(Address mbr) |
void |
MERGE3.clearViews() |
void |
UNICAST3.closeIdleConnections() |
String |
COUNTER.dumpPendingRequests() |
static String |
SHARED_LOOPBACK.dumpRoutingTable() |
String |
SCOPE.dumpScopes()
Deprecated.
|
Map<String,Object> |
SEQUENCER.dumpStats() |
String |
TP.dumpTimerTasks() |
String |
MERGE3.dumpViews() |
void |
TP.evictLogicalAddressCache() |
void |
SCOPE.expire(short scope)
Deprecated.
Multicasts an EXPIRE message to all members, and - on reception - each member removes the scope locally
|
String |
Discovery.findAllViewsAsString() |
String |
Discovery.findInitialMembersAsString() |
void |
BARRIER.openBarrier() |
String |
UNICAST.printAgeOutCache() |
String |
UNICAST3.printAgeOutCache() |
String |
UNICAST2.printAgeOutCache() |
String |
PDC.printCache() |
String |
FD_SOCK.printCache() |
String |
UNICAST.printConnections() |
String |
UNICAST3.printConnections() |
String |
TCP.printConnections() |
String |
UNICAST2.printConnections() |
String |
COUNTER.printCounters() |
String |
FC.printCreditors()
Deprecated.
|
String |
MFC.printCredits() |
String |
UFC.printCredits() |
String |
FC.printCredits()
Deprecated.
|
String |
Locking.printLocks() |
String |
TP.printLogicalAddressCache() |
String |
FlowControl.printReceiverCredits() |
String |
FC.printReceiverCredits()
Deprecated.
|
String |
UNICAST.printReceiveWindowMessages() |
String |
UNICAST3.printReceiveWindowMessages() |
String |
UNICAST2.printReceiveWindowMessages() |
String |
MFC.printSenderCredits() |
String |
UFC.printSenderCredits() |
String |
FC.printSenderCredits()
Deprecated.
|
String |
UNICAST.printSendWindowMessages() |
String |
UNICAST3.printSendWindowMessages() |
String |
UNICAST2.printSendWindowMessages() |
String |
SEQUENCER.printStats() |
String |
FD_ALL.printSuspectHistory() |
String |
FD.printSuspectHistory() |
String |
FD_SOCK.printSuspectHistory() |
String |
FD_ALL.printTimestamps() |
String |
TP.printWhoHasCache() |
void |
UNICAST.reapIdleConnections() |
void |
UNICAST2.reapIdleConnections() |
void |
UNICAST.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
UNICAST3.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
UNICAST2.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
SCOPE.removeAllQueues()
Deprecated.
|
void |
UNICAST3.removeExpiredConnections() |
boolean |
TCPGOSSIP.removeInitialHost(String hostname,
int port) |
void |
SEQUENCER.resetStats() |
void |
MERGE3.sendInfo() |
void |
MERGE2.sendMergeSolicitation()
Discovers members and detects whether we have multiple coordinator.
|
void |
UNICAST2.sendStableMessages() |
void |
Discovery.setForceSendingDiscoveryRsps(boolean flag) |
void |
RELAY.setRelay(boolean relay) |
String |
FC.showLastBlockingTimes()
Deprecated.
|
void |
FD_ALL.startFailureDetection() |
void |
FD.startFailureDetection() |
void |
DISCARD.startGui() |
void |
MERGE2.startMergeTask() |
boolean |
FD_SOCK.startNodeCrashMonitor() |
void |
FD_ALL.stopFailureDetection() |
void |
FD.stopFailureDetection() |
void |
DISCARD.stopGui() |
void |
MERGE2.stopMergeTask() |
void |
UNICAST3.triggerXmit() |
void |
UNICAST2.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 |
FC.unblock()
Deprecated.
Allows to unblock a blocked sender from an external program, e.g.
|
void |
Locking.unlockAll() |
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 |
---|---|
void |
GossipRouter.clear() |
String |
GossipRouter.dumpAddresssMappings() |
String |
GossipRouter.dumpRoutingTable() |
String |
GossipRouter.dumpRoutingTableDetailed() |
void |
Protocol.resetStatistics() |
void |
GossipRouter.start()
Lifecycle operation.
|
void |
GossipRouter.stop()
Always called before destroy().
|
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.