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.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(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 |
ReplicatedTree.getChannel()
Returns the Channel the DistributedTree is connected to
|
Channel |
ReplicatedHashMap.getChannel() |
Channel |
MessageDispatcher.getChannel() |
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) |
ReplicatedHashMap(Channel channel)
Constructs a new ReplicatedHashMap with channel.
|
ReplicatedHashMap(ConcurrentMap<K,V> map,
Channel channel)
Constructs a new ReplicatedHashMap using provided map instance.
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
Object server_obj) |
RpcDispatcher(Channel channel,
Object server_obj) |
Constructor and Description |
---|
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
Object serverObject) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
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,
Class<? extends Protocol> neighbor,
boolean create_fork_if_absent) |
Constructor and Description |
---|
ForkChannel(Channel main_channel,
String fork_stack_id,
String fork_channel_id,
boolean create_fork_if_absent,
int position,
Class<? extends Protocol> neighbor,
Protocol... protocols)
Creates a new fork-channel from a main-channel.
|
ForkChannel(Channel main_channel,
String fork_stack_id,
String fork_channel_id,
Protocol... protocols)
Creates a new fork-channel from a main-channel.
|
Modifier and Type | Method and Description |
---|---|
static void |
Util.addFlush(Channel ch,
FLUSH flush) |
static void |
Util.close(Channel... channels) |
static void |
Util.close(Channel ch) |
static void |
Util.shutdown(Channel ch)
Drops messages to/from other members and then closes the channel.
|
static boolean |
Util.startFlush(Channel c) |
static boolean |
Util.startFlush(Channel c,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling) |
static boolean |
Util.startFlush(Channel c,
List<Address> flushParticipants) |
static boolean |
Util.startFlush(Channel c,
List<Address> flushParticipants,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling) |
static void |
Util.waitUntilAllChannelsHaveSameSize(long timeout,
long interval,
Channel... channels)
Blocks until all channels have the same view
|
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.