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.jmx | |
org.jgroups.mux | |
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 | Class | Description |
---|---|---|
class |
JChannel |
JChannel is a pure Java implementation of Channel.
|
Modifier and Type | Method | Description |
---|---|---|
Channel |
ChannelFactory.createChannel() |
Create a new channel with the properties defined in the factory
|
Channel |
ChannelFactory.createChannel(java.lang.Object props) |
|
Channel |
ChannelFactory.createChannel(java.lang.String stack_name) |
|
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. |
Channel |
JChannelFactory.createChannel(java.lang.String stack_name) |
|
Channel |
ChannelFactory.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id) |
Creates an implementation of the Channel using a given stack name and
registering it under a given identity.
|
Channel |
ChannelFactory.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id,
boolean register_for_state_transfer,
java.lang.String substate_id) |
Creates an implementation of the Channel using a given stack name and
registering it under a given identity.
|
Channel |
JChannelFactory.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id) |
|
Channel |
JChannelFactory.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id,
boolean register_for_state_transfer,
java.lang.String substate_id) |
Modifier and Type | Method | Description |
---|---|---|
void |
ChannelListener.channelClosed(Channel channel) |
|
void |
ChannelListenerAdapter.channelClosed(Channel channel) |
|
void |
ChannelListener.channelConnected(Channel channel) |
|
void |
ChannelListenerAdapter.channelConnected(Channel channel) |
|
void |
ChannelListener.channelDisconnected(Channel channel) |
|
void |
ChannelListenerAdapter.channelDisconnected(Channel channel) |
|
protected void |
Channel.notifyChannelClosed(Channel c) |
|
protected void |
Channel.notifyChannelConnected(Channel c) |
|
protected void |
Channel.notifyChannelDisconnected(Channel c) |
Modifier and Type | Field | Description |
---|---|---|
protected Channel |
DistributedQueue.channel |
|
protected Channel |
DistributedTree.channel |
|
protected Channel |
MessageDispatcher.channel |
Modifier and Type | Method | Description |
---|---|---|
Channel |
DistributedHashtable.getChannel() |
Deprecated.
|
Channel |
DistributedQueue.getChannel() |
|
Channel |
DistributedTree.getChannel() |
Returns the Channel the DistributedTree is connected to
|
Channel |
MessageDispatcher.getChannel() |
Offers access to the underlying Channel.
|
Channel |
NotificationBus.getChannel() |
Answers the Channel.
|
Channel |
ReplicatedHashMap.getChannel() |
|
Channel |
ReplicatedHashtable.getChannel() |
Deprecated.
|
Channel |
ReplicatedTree.getChannel() |
Returns the Channel the DistributedTree is connected to
|
Modifier and Type | Method | Description |
---|---|---|
void |
PullPushAdapter.channelClosed(Channel channel) |
Deprecated.
|
void |
RpcDispatcher.channelClosed(Channel channel) |
|
void |
PullPushAdapter.channelConnected(Channel channel) |
Deprecated.
|
void |
RpcDispatcher.channelConnected(Channel channel) |
|
void |
PullPushAdapter.channelDisconnected(Channel channel) |
Deprecated.
|
void |
RpcDispatcher.channelDisconnected(Channel channel) |
|
void |
MessageDispatcher.setChannel(Channel ch) |
Constructor | Description |
---|---|
DistributedHashtable(Channel channel,
boolean persistent,
long state_timeout) |
Deprecated.
|
DistributedHashtable(Channel channel,
long state_timeout) |
Deprecated.
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2) |
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
boolean deadlock_detection) |
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
boolean deadlock_detection,
boolean concurrent_processing) |
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler) |
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler,
boolean deadlock_detection) |
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler,
boolean deadlock_detection,
boolean concurrent_processing) |
|
NotificationBus(Channel channel,
java.lang.String bus_name) |
|
ReplicatedHashMap(Channel channel) |
|
ReplicatedHashMap(Channel channel,
boolean persistent) |
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
java.lang.Object server_obj) |
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
java.lang.Object server_obj,
boolean deadlock_detection) |
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
java.lang.Object server_obj,
boolean deadlock_detection,
boolean concurrent_processing) |
|
VotingAdapter(Channel channel) |
Creates an instance of the VoteChannel that uses JGroups
for communication between group members.
|
Modifier and Type | Method | Description |
---|---|---|
void |
Draw.channelClosed(Channel channel) |
|
void |
Gossip.channelClosed(Channel channel) |
|
void |
Draw.channelConnected(Channel channel) |
|
void |
Gossip.channelConnected(Channel channel) |
|
void |
Draw.channelDisconnected(Channel channel) |
|
void |
Gossip.channelDisconnected(Channel channel) |
Constructor | Description |
---|---|
Draw(Channel channel) |
|
Draw(Channel channel,
boolean use_state,
long state_timeout) |
Modifier and Type | Method | Description |
---|---|---|
Channel |
JChannelFactory.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id) |
|
Channel |
JChannelFactory.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id,
boolean register_for_state_transfer,
java.lang.String substate_id) |
|
Channel |
JChannelFactoryMBean.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id) |
|
Channel |
JChannelFactoryMBean.createMultiplexerChannel(java.lang.String stack_name,
java.lang.String id,
boolean register_for_state_transfer,
java.lang.String substate_id) |
Modifier and Type | Class | Description |
---|---|---|
class |
MuxChannel |
Multiplexer channel is a lightweight version of a regular channel where
multiple MuxChannel(s) share the same underlying regular channel.
|
Modifier and Type | Method | Description |
---|---|---|
Channel |
Multiplexer.createMuxChannel(java.lang.String id,
java.lang.String stack_name) |
Modifier and Type | Method | Description |
---|---|---|
Channel |
ProtocolStack.getChannel() |
Modifier and Type | Method | Description |
---|---|---|
static void |
Util.close(Channel ch) |
|
static void |
Util.close(Channel... channels) |
|
static boolean |
Util.startFlush(Channel c) |
|
static boolean |
Util.startFlush(Channel c,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling) |
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants) |
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling) |
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.