Uses of Class
org.jgroups.JChannel

Packages that use JChannel

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.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of JChannel in org.jgroups

Fields in org.jgroups declared as JChannel

Modifier and Type	Field	Description
protected JChannel	Channel.ch	Deprecated.
protected JChannel	JChannelProbeHandler.ch

Methods in org.jgroups that return JChannel

Modifier and Type	Method	Description
protected JChannel	JChannel._close(boolean disconnect)
protected JChannel	JChannel._connect(Event evt)
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(java.lang.String cluster_name)	Joins the cluster.
protected JChannel	JChannel.connect(java.lang.String cluster_name, boolean useFlushIfPresent)	Connects the channel to a cluster.
JChannel	JChannel.connect(java.lang.String cluster_name, Address target, long timeout)	Joins the cluster and gets the state from a specified state provider.
JChannel	JChannel.connect(java.lang.String cluster_name, Address target, long timeout, boolean useFlushIfPresent)	Joins the cluster and gets a state from a specified state provider.
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, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
protected JChannel	JChannel.init()	Initializes all variables.
protected JChannel	JChannel.init(ProtocolStackConfigurator configurator)
protected JChannel	JChannel.init(JChannel ch)
JChannel	JChannel.name(java.lang.String name)
protected JChannel	JChannel.notifyChannelClosed(JChannel c)
protected JChannel	JChannel.notifyChannelConnected(JChannel c)
protected JChannel	JChannel.notifyChannelDisconnected(JChannel c)
protected JChannel	JChannel.notifyListeners(java.util.function.Consumer<ChannelListener> func, java.lang.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, java.lang.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(java.lang.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(java.util.List<Address> flushParticipants, boolean automatic_resume)	Performs the flush of the cluster but only for the specified flush participants.
protected JChannel	JChannel.startStack(java.lang.String cluster_name)
JChannel	JChannel.stats(boolean stats)
JChannel	JChannel.stopFlush()	Stops the current flush round.
JChannel	JChannel.stopFlush(java.util.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

Methods in org.jgroups with parameters of type JChannel

Modifier and Type	Method	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)

Constructors in org.jgroups with parameters of type JChannel

Constructor	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)

Uses of JChannel in org.jgroups.blocks

Fields in org.jgroups.blocks declared as JChannel

Modifier and Type	Field	Description
protected JChannel	MessageDispatcher.channel

Methods in org.jgroups.blocks that return JChannel

Modifier and Type	Method	Description
JChannel	MessageDispatcher.getChannel()
JChannel	ReplicatedHashMap.getChannel()
JChannel	ReplicatedTree.getChannel()	Returns the Channel the DistributedTree is connected to

Methods in org.jgroups.blocks with parameters of type JChannel

Modifier and Type	Method	Description
void	MessageDispatcher.channelClosed(JChannel channel)
void	MessageDispatcher.channelConnected(JChannel channel)
void	MessageDispatcher.channelDisconnected(JChannel channel)
<X extends MessageDispatcher> X	MessageDispatcher.setChannel(JChannel ch)

Constructors in org.jgroups.blocks with parameters of type JChannel

Constructor	Description
MessageDispatcher(JChannel channel)
MessageDispatcher(JChannel channel, RequestHandler req_handler)
ReplicatedHashMap(java.util.concurrent.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, java.lang.Object server_obj)

Uses of JChannel in org.jgroups.blocks.atomic

Fields in org.jgroups.blocks.atomic declared as JChannel

Modifier and Type	Field	Description
protected JChannel	CounterService.ch

Methods in org.jgroups.blocks.atomic with parameters of type JChannel

Modifier and Type	Method	Description
void	CounterService.setChannel(JChannel ch)

Constructors in org.jgroups.blocks.atomic with parameters of type JChannel

Constructor	Description
CounterService(JChannel ch)

Uses of JChannel in org.jgroups.blocks.executor

Fields in org.jgroups.blocks.executor declared as JChannel

Modifier and Type	Field	Description
protected JChannel	ExecutionRunner.ch
protected JChannel	ExecutionService.ch

Methods in org.jgroups.blocks.executor with parameters of type JChannel

Modifier and Type	Method	Description
void	ExecutionRunner.setChannel(JChannel ch)
void	ExecutionService.setChannel(JChannel ch)

Constructors in org.jgroups.blocks.executor with parameters of type JChannel

Constructor	Description
DistributedFuture(JChannel 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.
DistributedFuture(JChannel 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.
ExecutionRunner(JChannel channel)
ExecutionService(JChannel ch)

Uses of JChannel in org.jgroups.blocks.locking

Fields in org.jgroups.blocks.locking declared as JChannel

Modifier and Type	Field	Description
protected JChannel	LockService.ch

Methods in org.jgroups.blocks.locking with parameters of type JChannel

Modifier and Type	Method	Description
void	LockService.setChannel(JChannel ch)

Constructors in org.jgroups.blocks.locking with parameters of type JChannel

Constructor	Description
LockService(JChannel ch)

Uses of JChannel in org.jgroups.demos

Fields in org.jgroups.demos declared as JChannel

Modifier and Type	Field	Description
protected JChannel	CounterServiceDemo.ch
protected JChannel	ExecutionServiceDemo.ch
protected JChannel	LockServiceDemo.ch
protected JChannel	RelayDemo.ch
protected JChannel	RelayDemoRpc.ch
protected JChannel	Chat.channel

Methods in org.jgroups.demos with parameters of type JChannel

Modifier and Type	Method	Description
void	Draw.channelClosed(JChannel channel)
void	Draw.channelConnected(JChannel channel)
void	Draw.channelDisconnected(JChannel channel)
protected void	RelayDemo.eventLoop(JChannel ch)
void	Chat.start(JChannel ch)	Method called from other app, injecting channel
void	CounterServiceDemo.start(JChannel ch)
void	LockServiceDemo.start(JChannel ch)
void	ReplicatedHashMapDemo.start(JChannel channel)

Constructors in org.jgroups.demos with parameters of type JChannel

Constructor	Description
Draw(JChannel channel)
Draw(JChannel channel, boolean use_state, long state_timeout)

Uses of JChannel in org.jgroups.fork

Subclasses of JChannel in org.jgroups.fork

Modifier and Type	Class	Description
class	ForkChannel	Implementation of a ForkChannel, which is a light-weight channel.

Fields in org.jgroups.fork declared as JChannel

Modifier and Type	Field	Description
protected JChannel	ForkChannel.main_channel

Fields in org.jgroups.fork with type parameters of type JChannel

Modifier and Type	Field	Description
protected java.util.concurrent.ConcurrentMap<java.lang.String,JChannel>	ForkProtocolStack.fork_channels

Methods in org.jgroups.fork that return JChannel

Modifier and Type	Method	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)

Methods in org.jgroups.fork that return types with arguments of type JChannel

Modifier and Type	Method	Description
java.util.concurrent.ConcurrentMap<java.lang.String,JChannel>	ForkProtocolStack.getForkChannels()

Methods in org.jgroups.fork with parameters of type JChannel

Modifier and Type	Method	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, 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.
JChannel	ForkProtocolStack.putIfAbsent(java.lang.String id, JChannel fc)

Constructors in org.jgroups.fork with parameters of type JChannel

Constructor	Description
ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, boolean create_fork_if_absent, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, Protocol... protocols)	Creates a new fork-channel from a main-channel.
ForkChannel(JChannel 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.

Uses of JChannel in org.jgroups.jmx

Methods in org.jgroups.jmx with parameters of type JChannel

Modifier and Type	Method	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.registerChannel(JChannel ch, javax.management.MBeanServer server, javax.management.ObjectName namePrefix, java.lang.String cluster_name, boolean register_protocols)
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 void	JmxConfigurator.unregisterChannel(JChannel c, javax.management.MBeanServer server, javax.management.ObjectName prefix, java.lang.String clusterName)
static javax.management.DynamicMBean	JmxConfigurator.wrap(JChannel ch)	Wrap JChannel with DynamicMBean interface.

Uses of JChannel in org.jgroups.protocols

Fields in org.jgroups.protocols declared as JChannel

Modifier and Type	Field	Description
protected JChannel	RELAY.bridge	Deprecated. The bridge between the two local clusters, usually based on a TCP config

Fields in org.jgroups.protocols with type parameters of type JChannel

Modifier and Type	Field	Description
protected java.util.function.Function<java.lang.String,JChannel>	RELAY.bridge_creator	Deprecated.

Methods in org.jgroups.protocols that return types with arguments of type JChannel

Modifier and Type	Method	Description
java.util.function.Function<java.lang.String,JChannel>	RELAY.getBridgeCreator()	Deprecated.

Methods in org.jgroups.protocols with parameters of type JChannel

Modifier and Type	Method	Description
protected void	FORK.getStateFrom(JChannel channel, Protocol prot, java.lang.String stack, java.lang.String ch, java.io.DataOutputStream out)

Method parameters in org.jgroups.protocols with type arguments of type JChannel

Modifier and Type	Method	Description
RELAY	RELAY.setBridgeCreator(java.util.function.Function<java.lang.String,JChannel> bc)	Deprecated.

Uses of JChannel in org.jgroups.protocols.relay

Fields in org.jgroups.protocols.relay declared as JChannel

Modifier and Type	Field	Description
protected JChannel	Route.bridge
protected JChannel	Relayer.Bridge.channel

Methods in org.jgroups.protocols.relay that return JChannel

Modifier and Type	Method	Description
JChannel	Route.bridge()
JChannel	RELAY2.getBridge(java.lang.String site_name)	Returns the bridge channel to a given site

Methods in org.jgroups.protocols.relay with parameters of type JChannel

Modifier and Type	Method	Description
protected boolean	RELAY2.sendTopoReq(JChannel bridge, Address dest)

Constructors in org.jgroups.protocols.relay with parameters of type JChannel

Constructor	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)

Uses of JChannel in org.jgroups.protocols.relay.config

Methods in org.jgroups.protocols.relay.config that return JChannel

Modifier and Type	Method	Description
abstract JChannel	RelayConfig.BridgeConfig.createChannel()
JChannel	RelayConfig.ProgrammaticBridgeConfig.createChannel()
JChannel	RelayConfig.PropertiesBridgeConfig.createChannel()

Uses of JChannel in org.jgroups.stack

Fields in org.jgroups.stack declared as JChannel

Modifier and Type	Field	Description
protected JChannel	ProtocolStack.channel

Methods in org.jgroups.stack that return JChannel

Modifier and Type	Method	Description
JChannel	ProtocolStack.getChannel()

Methods in org.jgroups.stack with parameters of type JChannel

Modifier and Type	Method	Description
ProtocolStack	ProtocolStack.setChannel(JChannel ch)

Constructors in org.jgroups.stack with parameters of type JChannel

Constructor	Description
NonReflectiveProbeHandler(JChannel ch)
ProtocolStack(JChannel channel)

Uses of JChannel in org.jgroups.util

Methods in org.jgroups.util with parameters of type JChannel

Modifier and Type	Method	Description
static boolean	Util.allChannelsHaveSameView(JChannel... channels)
static void	Util.assertAllChannelsHaveSameView(JChannel... channels)
static void	Util.closeFast(JChannel... channels)	Closes all non-coordinators first, in parallel, then closes the coord.
static boolean	Util.isCoordinator(JChannel ch)
static java.lang.String	Util.printViews(JChannel... channels)
static void	Util.registerChannel(JChannel channel, java.lang.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, java.util.List<Address> flushParticipants)	Performs the flush of the given channel and the specified flush participants
static boolean	Util.startFlush(JChannel 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, JChannel... channels)	Blocks until all channels have the same view

Method parameters in org.jgroups.util with type arguments of type JChannel

Modifier and Type	Method	Description
static void	Util.waitUntilAllChannelsHaveSameView(long timeout, long interval, java.util.Collection<JChannel> channels)