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.stack |
Support for managing protocol stacks.
|
Modifier and Type | Method and Description |
---|---|
void |
Channel.addChannelListener(ChannelListener listener)
Adds a ChannelListener instance that will be notified when a channel event such as connect,
disconnect or close occurs.
|
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 |
Channel.removeChannelListener(ChannelListener listener)
Removes a ChannelListener previously installed
|
void |
JChannel.resetStats() |
void |
JChannel.send(Address dst,
Object obj) |
void |
JChannel.send(Message msg) |
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 |
ReplCache.get(K key)
Returns the value associated with key
|
V |
PartitionedHashMap.get(K key) |
V |
Cache.get(K key) |
void |
ReplCache.put(K key,
V val) |
void |
PartitionedHashMap.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 |
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 |
ReplCache.start() |
void |
PartitionedHashMap.start() |
void |
MemcachedConnector.start() |
void |
Cache.start() |
void |
ReplCache.stop() |
void |
PartitionedHashMap.stop() |
void |
MemcachedConnector.stop() |
void |
Cache.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 |
TCPPING.clearDynamicHostList() |
void |
FRAG2.clearFragmentsFor(Address mbr) |
void |
UNICAST2.compact() |
String |
COUNTER.dumpPendingRequests() |
String |
SCOPE.dumpScopes() |
Map<String,Object> |
SEQUENCER.dumpStats() |
String |
TP.dumpTimerTasks() |
void |
TP.evictLogicalAddressCache() |
void |
SCOPE.expire(short scope)
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 |
UNICAST2.printAgeOutCache() |
String |
UNICAST.printAgeOutCache() |
String |
FD_SOCK.printCache() |
String |
UNICAST2.printConnections() |
String |
UNICAST.printConnections() |
String |
TCP.printConnections() |
String |
COUNTER.printCounters() |
String |
FC.printCreditors() |
String |
UFC.printCredits() |
String |
MFC.printCredits() |
String |
FC.printCredits() |
String |
Locking.printLocks() |
String |
TP.printLogicalAddressCache() |
String |
FlowControl.printReceiverCredits() |
String |
FC.printReceiverCredits() |
String |
UNICAST2.printRetransmitTableSizes() |
String |
UFC.printSenderCredits() |
String |
MFC.printSenderCredits() |
String |
FC.printSenderCredits() |
String |
SEQUENCER.printStats() |
String |
FD_SOCK.printSuspectHistory() |
String |
FD_ALL.printSuspectHistory() |
String |
FD.printSuspectHistory() |
String |
FD_ALL.printTimestamps() |
String |
UNICAST.printUnackedMessages() |
void |
UNICAST2.purgeAndCompact() |
void |
UNICAST2.reapIdleConnections() |
void |
UNICAST.reapIdleConnections() |
void |
UNICAST2.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
UNICAST.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
SCOPE.removeAllQueues() |
boolean |
TCPGOSSIP.removeInitialHost(String hostname,
int port) |
void |
SEQUENCER.resetStats() |
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() |
void |
FD_ALL.startFailureDetection() |
void |
FD.startFailureDetection() |
void |
DISCARD.startGui() |
void |
MERGE2.startMergeTask() |
void |
FD_ALL.stopFailureDetection() |
void |
FD.stopFailureDetection() |
void |
DISCARD.stopGui() |
void |
MERGE2.stopMergeTask() |
void |
MFC.unblock()
Allows to unblock a blocked sender from an external program, e.g.
|
void |
FlowControl.unblock()
Allows to unblock all blocked senders from an external program, e.g.
|
void |
FC.unblock()
Allows to unblock a blocked sender from an external program, e.g.
|
void |
Locking.unlockAll() |
Modifier and Type | Method and Description |
---|---|
void |
GMS.cancelMerge() |
void |
StreamingStateTransfer.closeBarrierAndSuspendStable() |
void |
STATE_TRANSFER.closeBarrierAndSuspendStable() |
void |
NAKACK.compact() |
String |
GMS.dumpViewHandlerHistory() |
String |
GMS.dumpViewHandlerQueue() |
void |
GMS.fixDigests() |
void |
STABLE.gc() |
void |
StreamingStateTransfer.openBarrierAndResumeStable() |
void |
STATE_TRANSFER.openBarrierAndResumeStable() |
String |
NAKACK.printDigestHistory() |
String |
NAKACK.printLossRates() |
String |
GMS.printMergeIdHistory() |
String |
NAKACK.printMessages() |
String |
GMS.printPreviousMembers() |
String |
GMS.printPreviousViews() |
String |
NAKACK.printRetransmitStats() |
String |
NAKACK.printRetransmitTableSizes() |
String |
NAKACK.printStabilityMessages() |
void |
GMS.resumeViewHandler() |
void |
STABLE.runMessageGarbageCollection() |
void |
FLUSH.startFlush() |
void |
FLUSH.stopFlush() |
void |
GMS.suspect(String suspected_member) |
void |
GMS.suspendViewHandler() |
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 © 2012 JBoss by Red Hat. All Rights Reserved.