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.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.tests | |
org.jgroups.tests.perf | |
org.jgroups.tests.rt.transports | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected JChannel |
Channel.ch
Deprecated.
|
protected JChannel |
JChannelProbeHandler.ch |
Modifier and Type | Method and Description |
---|---|
protected JChannel |
JChannel._close(boolean disconnect) |
protected JChannel |
JChannel._connect(Event connect_event) |
JChannel |
JChannel.addAddressGenerator(AddressGenerator address_generator)
Sets the new
AddressGenerator . |
JChannel |
JChannel.addChannelListener(ChannelListener listener)
Adds a ChannelListener that will be notified when a connect, disconnect or close occurs
|
protected JChannel |
JChannel.checkClosed() |
protected JChannel |
JChannel.checkClosedOrNotConnected() |
JChannel |
JChannel.clearChannelListeners() |
JChannel |
JChannel.connect(String cluster_name)
Joins the cluster.
|
JChannel |
JChannel.connect(String cluster_name,
Address target,
long timeout)
Joins the cluster and gets the state from a specified state provider.
|
JChannel |
JChannel.connect(String cluster_name,
Address target,
long timeout,
boolean useFlushIfPresent)
Joins the cluster and gets a state from a specified state provider.
This method invokes
connect() and then getState .
If the FLUSH protocol is in the channel's stack definition, only one flush round is executed for both connecting and
fetching the state rather than two flushes if we invoke connect and getState in succession.
If the channel is closed a ChannelClosed exception will be thrown. |
protected JChannel |
JChannel.connect(String cluster_name,
boolean useFlushIfPresent)
Connects the channel to a cluster.
|
JChannel |
JChannel.disconnect()
Leaves the cluster (disconnects the channel if it is connected).
|
JChannel |
JChannel.getState(Address target,
long timeout)
Retrieves the full state from the target member.
|
JChannel |
JChannel.getState(Address target,
long timeout,
boolean useFlushIfPresent)
Retrieves state from the target member.
|
protected JChannel |
JChannel.getState(Address target,
long timeout,
Callable<Boolean> flushInvoker) |
protected JChannel |
JChannel.init()
Initializes all variables.
|
protected JChannel |
JChannel.init(JChannel ch) |
protected JChannel |
JChannel.init(ProtocolStackConfigurator configurator) |
JChannel |
JChannel.name(String name) |
protected JChannel |
JChannel.notifyChannelClosed(JChannel c) |
protected JChannel |
JChannel.notifyChannelConnected(JChannel c) |
protected JChannel |
JChannel.notifyChannelDisconnected(JChannel c) |
protected JChannel |
JChannel.notifyListeners(Consumer<ChannelListener> func,
String msg) |
JChannel |
JChannel.receiver(Receiver r) |
JChannel |
JChannel.removeChannelListener(ChannelListener listener) |
protected JChannel |
JChannelProbeHandler.resetAllStats() |
JChannel |
JChannel.resetStats() |
JChannel |
JChannel.send(Address dst,
byte[] buf)
Sends a message.
|
JChannel |
JChannel.send(Address dst,
byte[] buf,
int offset,
int length)
Sends a message to a destination.
|
JChannel |
JChannel.send(Address dst,
Object obj)
Helper method to create a Message with given parameters and invoke
send(Message) . |
JChannel |
JChannel.send(Message msg)
Sends a message.
|
protected JChannel |
JChannel.setAddress()
Generates and sets local_addr.
|
JChannel |
JChannel.setDiscardOwnMessages(boolean flag) |
JChannel |
JChannel.setName(String name)
Sets the logical name for the channel.
|
JChannel |
JChannel.setReceiver(Receiver r) |
JChannel |
JChannel.setStats(boolean stats) |
JChannel |
JChannel.setUpHandler(UpHandler h) |
JChannel |
JChannel.startFlush(boolean automatic_resume)
Performs the flush of the cluster, ie.
|
JChannel |
JChannel.startFlush(List<Address> flushParticipants,
boolean automatic_resume)
Performs the flush of the cluster but only for the specified flush participants.
All pending messages are flushed out but only for the flush participants.
|
protected JChannel |
JChannel.startStack(String cluster_name) |
JChannel |
JChannel.stats(boolean stats) |
JChannel |
JChannel.stopFlush()
Stops the current flush round.
|
JChannel |
JChannel.stopFlush(List<Address> flushParticipants)
Stops the current flush of the cluster for the specified flush participants.
|
protected JChannel |
JChannel.stopStack(boolean stop,
boolean destroy) |
JChannel |
JChannel.up(MessageBatch batch)
Callback invoked by the protocol stack to deliver a message batch
|
Modifier and Type | Method and Description |
---|---|
void |
ChannelListener.channelClosed(JChannel channel)
Channel has been closed notification callback
|
void |
ChannelListener.channelConnected(JChannel channel)
Channel has been connected notification callback
|
void |
ChannelListener.channelDisconnected(JChannel channel)
Channel has been disconnected notification callback
|
protected JChannel |
JChannel.init(JChannel ch) |
protected JChannel |
JChannel.notifyChannelClosed(JChannel c) |
protected JChannel |
JChannel.notifyChannelConnected(JChannel c) |
protected JChannel |
JChannel.notifyChannelDisconnected(JChannel c) |
Constructor and Description |
---|
Channel(JChannel ch)
Deprecated.
|
JChannel(JChannel ch)
Creates a channel with the same configuration as the channel passed to this constructor.
|
JChannelProbeHandler(JChannel ch) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
MessageDispatcher.channel |
Modifier and Type | Method and Description |
---|---|
JChannel |
ReplicatedTree.getChannel()
Returns the Channel the DistributedTree is connected to
|
JChannel |
ReplicatedHashMap.getChannel() |
JChannel |
MessageDispatcher.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
MessageDispatcher.channelClosed(JChannel channel) |
void |
MessageDispatcher.channelConnected(JChannel channel) |
void |
MessageDispatcher.channelDisconnected(JChannel channel) |
<X extends MessageDispatcher> |
MessageDispatcher.setChannel(JChannel ch) |
Constructor and Description |
---|
MessageDispatcher(JChannel channel) |
MessageDispatcher(JChannel channel,
RequestHandler req_handler) |
ReplicatedHashMap(ConcurrentMap<K,V> map,
JChannel channel)
Constructs a new ReplicatedHashMap using provided map instance.
|
ReplicatedHashMap(JChannel channel)
Constructs a new ReplicatedHashMap with channel.
|
ReplicatedTree(JChannel channel)
Expects an already connected channel.
|
RpcDispatcher(JChannel channel,
Object server_obj) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
CounterService.ch |
Modifier and Type | Method and Description |
---|---|
void |
CounterService.setChannel(JChannel ch) |
Constructor and Description |
---|
CounterService(JChannel ch) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
ExecutionRunner.ch |
protected JChannel |
ExecutionService.ch |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionRunner.setChannel(JChannel ch) |
void |
ExecutionService.setChannel(JChannel ch) |
Constructor and Description |
---|
DistributedFuture(JChannel channel,
Lock unfinishedLock,
Condition condition,
Set<Future<?>> futuresToFinish,
Callable<V> callable)
Creates a FutureTask that will upon running, execute the
given Callable.
|
DistributedFuture(JChannel channel,
Lock unfinishedLock,
Condition condition,
Set<Future<?>> futuresToFinish,
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.
|
ExecutionRunner(JChannel channel) |
ExecutionService(JChannel ch) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
LockService.ch |
Modifier and Type | Method and Description |
---|---|
void |
LockService.setChannel(JChannel ch) |
Constructor and Description |
---|
LockService(JChannel ch) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
ExecutionServiceDemo.ch |
protected JChannel |
LockServiceDemo.ch |
protected JChannel |
CounterServiceDemo.ch |
protected JChannel |
RelayDemoRpc.ch |
Modifier and Type | Method and Description |
---|---|
void |
Draw.channelClosed(JChannel channel) |
void |
Draw.channelConnected(JChannel channel) |
void |
Draw.channelDisconnected(JChannel channel) |
void |
ReplicatedHashMapDemo.start(JChannel channel) |
void |
LockServiceDemo.start(JChannel ch) |
void |
Chat.start(JChannel ch)
Method called from other app, injecting channel
|
void |
CounterServiceDemo.start(JChannel ch) |
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 JChannel |
ForkChannel.main_channel |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,JChannel> |
ForkProtocolStack.fork_channels |
Modifier and Type | Method and Description |
---|---|
JChannel |
ForkProtocolStack.get(String fork_channel_id) |
JChannel |
ForkChannel.name(String name) |
JChannel |
ForkProtocolStack.putIfAbsent(String id,
JChannel fc) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,JChannel> |
ForkProtocolStack.getForkChannels() |
Modifier and Type | Method and Description |
---|---|
void |
ForkChannel.channelClosed(JChannel channel) |
void |
ForkChannel.channelConnected(JChannel channel) |
void |
ForkChannel.channelDisconnected(JChannel channel) |
protected static FORK |
ForkChannel.getFORK(JChannel ch,
ProtocolStack.Position position,
Class<? extends Protocol> neighbor,
boolean create_fork_if_absent)
Creates a new FORK protocol, or returns the existing one, or throws an exception.
|
JChannel |
ForkProtocolStack.putIfAbsent(String id,
JChannel fc) |
Constructor and Description |
---|
ForkChannel(JChannel main_channel,
String fork_stack_id,
String fork_channel_id,
boolean create_fork_if_absent,
ProtocolStack.Position position,
Class<? extends Protocol> neighbor,
Protocol... protocols)
Creates a new fork-channel from a main-channel.
|
ForkChannel(JChannel 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 |
JmxConfigurator.registerChannel(JChannel channel,
MBeanServer server,
String name)
Registers an already created channel with the given MBeanServer.
|
static void |
JmxConfigurator.registerChannel(JChannel channel,
MBeanServer server,
String domain,
String cluster_name,
boolean register_protocols)
Registers an already created channel with the given MBeanServer.
|
static void |
JmxConfigurator.unregisterChannel(JChannel c,
MBeanServer server,
String clusterName) |
static void |
JmxConfigurator.unregisterChannel(JChannel c,
MBeanServer server,
String domain,
String clusterName) |
static 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,
String stack,
String ch,
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(String site_name)
Returns the bridge channel to a given site
|
Constructor and Description |
---|
Bridge(JChannel ch,
String cluster_name,
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 | Field and Description |
---|---|
protected JChannel |
FlowControlTest.ch |
protected JChannel |
UnicastTest.channel |
protected JChannel |
RpcDispatcherSpeedTest.channel |
protected JChannel |
RoundTripRpc.channel |
Modifier and Type | Method and Description |
---|---|
protected void |
UnicastTest._init(JChannel ch,
long sleep_time,
String name) |
protected static List<String> |
UnicastTestRpc.getSites(JChannel channel) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
MPerf.channel |
protected JChannel |
MPerfRpc.channel |
Modifier and Type | Method and Description |
---|---|
protected static List<String> |
UPerf.getSites(JChannel channel) |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
JGroupsTransport.ch |
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 String |
Util.printViews(JChannel... channels) |
static void |
Util.registerChannel(JChannel channel,
String name) |
static void |
Util.shutdown(JChannel ch)
Drops messages to/from other members and then closes the channel.
|
static boolean |
Util.startFlush(JChannel c)
Performs the flush of the given channel
|
static boolean |
Util.startFlush(JChannel 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(JChannel c,
List<Address> flushParticipants)
Performs the flush of the given channel and the specified flush participants
|
static boolean |
Util.startFlush(JChannel c,
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,
JChannel... channels)
Blocks until all channels have the same view
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.