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.conf |
Provides ways to configure a protocol stack.
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.jmx | |
org.jgroups.mux | |
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Class | Description |
---|---|---|
class |
ChannelClosedException |
Thrown if an operation is attemped on a closed channel.
|
class |
ChannelNotConnectedException |
Thrown if an operation is attemped on an unconnected channel.
|
class |
StateTransferException |
StateTransferException is thrown to indicate failure of
state transfer between cluster members. |
Modifier and Type | Method | Description |
---|---|---|
abstract void |
Channel.connect(java.lang.String cluster_name) |
Connects the channel to a group.
|
abstract void |
Channel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout) |
Connects the channel to a group and fetches the state
|
void |
JChannel.connect(java.lang.String cluster_name) |
Connects the channel to a group.
|
void |
JChannel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout) |
Connects this channel to a group and gets a state from a specified state
provider.
|
Channel |
ChannelFactory.createChannel() |
Create a new channel with the properties defined in the factory
|
Channel |
ChannelFactory.createChannel(java.lang.Object props) |
|
Channel |
JChannelFactory.createChannel() |
Creates a
JChannel implementation of the
Channel |
Channel |
JChannelFactory.createChannel(java.lang.Object properties) |
Deprecated.
JChannel 's conversion to type-specific
construction, and the subsequent deprecation of its
JChannel(Object) constructor, necessitate the
deprecation of this factory method as well. |
protected void |
JChannel.init(ProtocolStackConfigurator configurator) |
|
void |
Channel.open() |
Re-opens a closed channel.
|
void |
JChannel.open() |
Opens the channel.
|
Constructor | Description |
---|---|
JChannel() |
Constructs a
JChannel instance with the protocol stack
specified by the DEFAULT_PROTOCOL_STACK member. |
JChannel(java.io.File properties) |
Constructs a
JChannel instance with the protocol stack
configuration contained by the specified file. |
JChannel(java.lang.Object properties) |
Deprecated.
Use the constructors with specific parameter types instead.
|
JChannel(java.lang.String properties) |
Constructs a
JChannel instance with the protocol stack
configuration based upon the specified properties parameter. |
JChannel(java.net.URL properties) |
Constructs a
JChannel instance with the protocol stack
configuration indicated by the specified URL. |
JChannel(ProtocolStackConfigurator configurator) |
Constructs a
JChannel instance with the protocol stack
configuration contained by the protocol stack configurator parameter. |
JChannel(org.w3c.dom.Element properties) |
Constructs a
JChannel instance with the protocol stack
configuration contained by the specified XML element. |
JChannelFactory(java.io.File properties) |
Constructs a
JChannelFactory instance that utilizes the
specified file for protocl stack configuration. |
JChannelFactory(java.lang.String properties) |
Constructs a
JChannel instance with the protocol stack
configuration based upon the specified properties parameter. |
JChannelFactory(java.net.URL properties) |
Constructs a
JChannelFactory instance that utilizes the
specified file for protocl stack configuration. |
JChannelFactory(org.w3c.dom.Element properties) |
Constructs a
JChannelFactory instance that utilizes the
specified file for protocl stack configuration. |
Modifier and Type | Class | Description |
---|---|---|
class |
VoteException |
This exception is thrown when voting listener cannot vote on the
specified decree.
|
Modifier and Type | Method | Description |
---|---|---|
void |
DistributedLockManager.lock(java.lang.Object lockId,
java.lang.Object owner,
int timeout) |
Locks an object with
lockId on behalf of the specified
owner . |
void |
LockManager.lock(java.lang.Object obj,
java.lang.Object owner,
int timeout) |
Obtain lock on
obj for specified owner . |
boolean |
DistributedLockManager.processResponses(RspList responses,
int consensusType,
java.lang.Object decree) |
Processes the response list and votes like the default processResponses method with the consensusType VOTE_ALL
If the result of the voting is false, but this DistributedLockManager owns the lock, the result is changed to
true and the lock is released, but marked as multiple locked.
|
boolean |
VoteResponseProcessor.processResponses(RspList responses,
int consensusType,
java.lang.Object decree) |
Processes the responses returned by the other nodes.
|
boolean |
VotingAdapter.processResponses(RspList responses,
int consensusType,
java.lang.Object decree) |
Processes the response list and makes a decision according to the
type of the consensus for current voting.
|
void |
DistributedLockManager.unlock(java.lang.Object lockId,
java.lang.Object owner) |
Unlocks an object with
lockId on behalf of the specified
owner . |
void |
DistributedLockManager.unlock(java.lang.Object lockId,
java.lang.Object owner,
boolean releaseMultiLocked) |
Unlocks an object with
lockId on behalf of the specified
owner . |
void |
DistributedLockManager.unlock(java.lang.Object lockId,
java.lang.Object owner,
boolean releaseMultiLocked,
long timeout) |
|
void |
DistributedLockManager.unlock(java.lang.Object lockId,
java.lang.Object owner,
long timeout) |
|
void |
LockManager.unlock(java.lang.Object obj,
java.lang.Object owner) |
Release lock on
obj owned by specified owner . |
void |
LockManager.unlock(java.lang.Object obj,
java.lang.Object owner,
boolean releaseMultiLocked) |
Release lock on
obj owned by specified owner . |
boolean |
TwoPhaseVotingAdapter.vote(java.lang.Object decree,
long timeout) |
Performs the two-phase voting on the decree.
|
boolean |
TwoPhaseVotingAdapter.vote(java.lang.Object decree,
long timeout,
VoteResponseProcessor voteResponseProcessor) |
Performs the two-phase voting on the decree.
|
boolean |
VotingAdapter.vote(java.lang.Object decree,
int consensusType,
long timeout) |
Performs actual voting on the VoteChannel using the JGroups
facilities for communication.
|
boolean |
VotingAdapter.vote(java.lang.Object decree,
int consensusType,
long timeout,
VoteResponseProcessor voteResponseProcessor) |
Performs actual voting on the VoteChannel using the JGroups
facilities for communication.
|
boolean |
VotingAdapter.vote(java.lang.Object decree,
long timeout) |
Vote on the specified decree requiring all nodes to vote.
|
boolean |
VotingAdapter.vote(java.lang.Object decree,
long timeout,
VoteResponseProcessor voteResponseProcessor) |
Vote on the specified decree requiring all nodes to vote.
|
Constructor | Description |
---|---|
DistributedHashtable(java.lang.String groupname,
ChannelFactory factory,
java.lang.String properties,
boolean persistent,
long state_timeout) |
Deprecated.
Creates a DisttributedHashtable.
|
DistributedHashtable(java.lang.String groupname,
ChannelFactory factory,
java.lang.String properties,
long state_timeout) |
Deprecated.
Creates a DistributedHashtable
|
DistributedQueue(java.lang.String groupname,
ChannelFactory factory,
java.lang.String properties,
long state_timeout) |
Creates a DistributedQueue
|
DistributedTree(PullPushAdapter adapter,
java.io.Serializable id,
long state_timeout) |
|
ReplicatedHashMap(java.lang.String clustername,
ChannelFactory factory,
java.lang.String properties,
boolean persistent,
long state_timeout) |
Creates a ReplicatedHashMap.
|
ReplicatedHashMap(java.lang.String clustername,
ChannelFactory factory,
java.lang.String properties,
long state_timeout) |
Creates a ReplicatedHashMap
|
Modifier and Type | Method | Description |
---|---|---|
static ClassConfigurator |
ClassConfigurator.getInstance() |
|
static ClassConfigurator |
ClassConfigurator.getInstance(boolean init) |
|
static ProtocolStackConfigurator |
ConfiguratorFactory.getStackConfigurator(java.io.File file) |
Returns a protocol stack configurator based on the XML configuration
provided by the specified File.
|
static ProtocolStackConfigurator |
ConfiguratorFactory.getStackConfigurator(java.lang.String properties) |
Returns a protocol stack configurator based on the provided properties
string.
|
static ProtocolStackConfigurator |
ConfiguratorFactory.getStackConfigurator(java.net.URL url) |
Returns a protocol stack configurator based on the XML configuration
provided at the specified URL.
|
static ProtocolStackConfigurator |
ConfiguratorFactory.getStackConfigurator(org.w3c.dom.Element element) |
Returns a protocol stack configurator based on the XML configuration
provided by the specified XML element.
|
void |
ClassConfigurator.init() |
Modifier and Type | Method | Description |
---|---|---|
void |
DistributedHashtableDemo.start(ChannelFactory factory,
java.lang.String props,
boolean persist) |
|
void |
DistributedQueueDemo.start(java.lang.String groupname,
ChannelFactory factory,
java.lang.String props) |
|
void |
ReplicatedHashMapDemo.start(ChannelFactory factory,
java.lang.String props,
boolean persist) |
Modifier and Type | Method | Description |
---|---|---|
void |
JChannel.connect(java.lang.String channel_name) |
|
void |
JChannelMBean.connect(java.lang.String channel_name) |
Modifier and Type | Method | Description |
---|---|---|
void |
MuxChannel.connect(java.lang.String channel_name) |
|
void |
MuxChannel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout) |
|
void |
MuxChannel.open() |
Constructor | Description |
---|---|
ProtocolStack() |
Only used by Simulator; don't use
|
ProtocolStack(JChannel channel,
java.lang.String setup_string) |
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.