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.atomic | |
org.jgroups.blocks.executor | |
org.jgroups.blocks.locking | |
org.jgroups.blocks.mux | |
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.fork | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Class and Description |
---|---|
class |
JChannel
JChannel is a default implementation of a Channel abstraction.
|
Modifier and Type | Method and Description |
---|---|
abstract Channel |
Channel.name(java.lang.String name)
Names a channel, same as
setName(String) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelListener.channelClosed(Channel channel)
Channel has been closed notification callback
|
void |
ChannelListener.channelConnected(Channel channel)
Channel has been connected notification callback
|
void |
ChannelListener.channelDisconnected(Channel channel)
Channel has been disconnected notification callback
|
protected void |
Channel.notifyChannelClosed(Channel c) |
protected void |
Channel.notifyChannelConnected(Channel c) |
protected void |
Channel.notifyChannelDisconnected(Channel c) |
Modifier and Type | Field and Description |
---|---|
protected Channel |
MessageDispatcher.channel |
Modifier and Type | Method and Description |
---|---|
Channel |
ReplicatedHashMap.getChannel() |
Channel |
MessageDispatcher.getChannel() |
Channel |
ReplicatedTree.getChannel()
Returns the Channel the DistributedTree is connected to
|
Modifier and Type | Method and Description |
---|---|
void |
MessageDispatcher.channelClosed(Channel channel) |
void |
MessageDispatcher.channelConnected(Channel channel) |
void |
MessageDispatcher.channelDisconnected(Channel channel) |
void |
MessageDispatcher.setChannel(Channel ch) |
Constructor and Description |
---|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2) |
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler) |
MessageDispatcher(Channel channel,
RequestHandler req_handler) |
ReplicatedHashMap(Channel channel)
Constructs a new ReplicatedHashMap with channel.
|
ReplicatedHashMap(java.util.concurrent.ConcurrentMap<K,V> map,
Channel channel)
Constructs a new ReplicatedHashMap using provided map instance.
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
java.lang.Object server_obj) |
RpcDispatcher(Channel channel,
java.lang.Object server_obj) |
Modifier and Type | Field and Description |
---|---|
protected Channel |
CounterService.ch |
Modifier and Type | Method and Description |
---|---|
void |
CounterService.setChannel(Channel ch) |
Constructor and Description |
---|
CounterService(Channel ch) |
Modifier and Type | Field and Description |
---|---|
protected Channel |
ExecutionService.ch |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionService.setChannel(Channel ch) |
Constructor and Description |
---|
DistributedFuture(Channel channel,
java.util.concurrent.locks.Lock unfinishedLock,
java.util.concurrent.locks.Condition condition,
java.util.Set<java.util.concurrent.Future<?>> futuresToFinish,
java.util.concurrent.Callable<V> callable)
Creates a FutureTask that will upon running, execute the
given Callable.
|
DistributedFuture(Channel channel,
java.util.concurrent.locks.Lock unfinishedLock,
java.util.concurrent.locks.Condition condition,
java.util.Set<java.util.concurrent.Future<?>> futuresToFinish,
java.lang.Runnable runnable,
V result)
Creates a FutureTask that will upon running, execute the
given Runnable, and arrange that get will return the
given result on successful completion.
|
ExecutionService(Channel ch) |
Modifier and Type | Field and Description |
---|---|
protected Channel |
LockService.ch |
Modifier and Type | Method and Description |
---|---|
void |
LockService.setChannel(Channel ch) |
Constructor and Description |
---|
LockService(Channel ch) |
Constructor and Description |
---|
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
java.lang.Object serverObject) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
java.lang.Object serverObject,
MethodLookup method_lookup) |
Modifier and Type | Method and Description |
---|---|
void |
Draw.channelClosed(Channel channel) |
void |
Draw.channelConnected(Channel channel) |
void |
Draw.channelDisconnected(Channel channel) |
Modifier and Type | Class and Description |
---|---|
class |
ForkChannel
Implementation of a ForkChannel, which is a light-weight channel.
|
Modifier and Type | Field and Description |
---|---|
protected Channel |
ForkChannel.main_channel |
Modifier and Type | Method and Description |
---|---|
void |
ForkChannel.channelClosed(Channel channel) |
void |
ForkChannel.channelConnected(Channel channel) |
void |
ForkChannel.channelDisconnected(Channel channel) |
protected static FORK |
ForkChannel.getFORK(Channel ch,
int position,
java.lang.Class<? extends Protocol> neighbor,
boolean create_fork_if_absent)
Creates a new FORK protocol, or returns the existing one, or throws an exception.
|
Constructor and Description |
---|
ForkChannel(Channel main_channel,
java.lang.String fork_stack_id,
java.lang.String fork_channel_id,
boolean create_fork_if_absent,
int position,
java.lang.Class<? extends Protocol> neighbor,
Protocol... protocols)
Creates a new fork-channel from a main-channel.
|
ForkChannel(Channel main_channel,
java.lang.String fork_stack_id,
java.lang.String fork_channel_id,
Protocol... protocols)
Creates a new fork-channel from a main-channel.
|
Modifier and Type | Method and Description |
---|---|
static void |
Util.shutdown(Channel ch)
Drops messages to/from other members and then closes the channel.
|
static boolean |
Util.startFlush(Channel c)
Performs the flush of the given channel
|
static boolean |
Util.startFlush(Channel c,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling)
Performs the flush of the given channel within the specfied number of attempts along with random
sleep time after each such attempt.
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants)
Performs the flush of the given channel and the specified flush participants
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling)
Performs the flush of the given channel for the specified flush participants and the given
number of attempts along with random sleep time after each such attempt.
|
static void |
Util.waitUntilAllChannelsHaveSameView(long timeout,
long interval,
Channel... channels)
Blocks until all channels have the same view
|
Copyright © 1998-2020 Red Hat. All Rights Reserved.