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.executor | |
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.fork | |
org.jgroups.jmx | |
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.relay.config | |
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 | Method and Description |
---|---|
JChannel |
JChannel.name(java.lang.String name) |
JChannel |
JChannel.receiver(Receiver r) |
Modifier and Type | Method and Description |
---|---|
protected void |
JChannel.init(JChannel ch) |
Constructor and Description |
---|
JChannel(JChannel ch)
Creates a channel with the same configuration as the channel passed to this constructor.
|
Constructor and Description |
---|
ReplicatedTree(JChannel channel)
Expects an already connected channel.
|
Modifier and Type | Field and Description |
---|---|
protected JChannel |
ExecutionRunner.ch |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionRunner.setChannel(JChannel ch) |
Constructor and Description |
---|
ExecutionRunner(JChannel channel) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
RelayDemoRpc.ch |
protected JChannel |
CounterServiceDemo.ch |
protected JChannel |
ExecutionServiceDemo.ch |
protected JChannel |
LockServiceDemo.ch |
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedHashMapDemo.start(JChannel channel) |
void |
CounterServiceDemo.start(JChannel ch) |
void |
LockServiceDemo.start(JChannel ch) |
void |
Chat.start(JChannel ch)
Method called from other app, injecting channel
|
Constructor and Description |
---|
Draw(JChannel channel) |
Draw(JChannel channel,
boolean use_state,
long state_timeout) |
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 java.util.concurrent.ConcurrentMap<java.lang.String,JChannel> |
ForkProtocolStack.fork_channels |
Modifier and Type | Method and Description |
---|---|
JChannel |
ForkProtocolStack.get(java.lang.String fork_channel_id) |
JChannel |
ForkChannel.name(java.lang.String name) |
JChannel |
ForkProtocolStack.putIfAbsent(java.lang.String id,
JChannel fc) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.ConcurrentMap<java.lang.String,JChannel> |
ForkProtocolStack.getForkChannels() |
Modifier and Type | Method and Description |
---|---|
JChannel |
ForkProtocolStack.putIfAbsent(java.lang.String id,
JChannel fc) |
Modifier and Type | Method and Description |
---|---|
static void |
JmxConfigurator.registerChannel(JChannel channel,
javax.management.MBeanServer server,
java.lang.String name)
Registers an already created channel with the given MBeanServer.
|
static void |
JmxConfigurator.registerChannel(JChannel channel,
javax.management.MBeanServer server,
java.lang.String domain,
java.lang.String cluster_name,
boolean register_protocols)
Registers an already created channel with the given MBeanServer.
|
static void |
JmxConfigurator.unregisterChannel(JChannel c,
javax.management.MBeanServer server,
java.lang.String clusterName) |
static void |
JmxConfigurator.unregisterChannel(JChannel c,
javax.management.MBeanServer server,
java.lang.String domain,
java.lang.String clusterName) |
static javax.management.DynamicMBean |
JmxConfigurator.wrap(JChannel ch)
Wrap JChannel with DynamicMBean interface.
|
Modifier and Type | Field and Description |
---|---|
protected JChannel |
RELAY.bridge
The bridge between the two local clusters, usually based on a TCP config
|
Modifier and Type | Method and Description |
---|---|
protected void |
FORK.getStateFrom(JChannel channel,
Protocol prot,
java.lang.String stack,
java.lang.String ch,
java.io.DataOutputStream out) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
Route.bridge |
protected JChannel |
Relayer.Bridge.channel |
Modifier and Type | Method and Description |
---|---|
JChannel |
Route.bridge() |
JChannel |
RELAY2.getBridge(java.lang.String site_name)
Returns the bridge channel to a given site
|
Constructor and Description |
---|
Bridge(JChannel ch,
java.lang.String cluster_name,
java.lang.String channel_name,
AddressGenerator addr_generator) |
Route(Address site_master,
JChannel bridge,
RELAY2 relay,
Log log) |
Modifier and Type | Method and Description |
---|---|
abstract JChannel |
RelayConfig.BridgeConfig.createChannel() |
JChannel |
RelayConfig.PropertiesBridgeConfig.createChannel() |
JChannel |
RelayConfig.ProgrammaticBridgeConfig.createChannel() |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
ProtocolStack.channel |
Modifier and Type | Method and Description |
---|---|
JChannel |
ProtocolStack.getChannel() |
Modifier and Type | Method and Description |
---|---|
ProtocolStack |
ProtocolStack.setChannel(JChannel ch) |
Constructor and Description |
---|
ProtocolStack(JChannel channel) |
Modifier and Type | Method and Description |
---|---|
static JChannel |
Util.createChannel(Protocol... prots) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Util.allChannelsHaveSameView(JChannel... channels) |
static void |
Util.assertAllChannelsHaveSameView(JChannel... channels) |
static boolean |
Util.isCoordinator(JChannel ch) |
static java.lang.String |
Util.printViews(JChannel... channels) |
static void |
Util.registerChannel(JChannel channel,
java.lang.String name) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.