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.admin
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.atomic
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	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
JChannel	JChannelProbeHandler.channel()
protected JChannel	JChannel.checkClosed()
protected JChannel	JChannel.checkClosedOrNotConnected()
protected JChannel	JChannel.cleanup()
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.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. The state transfer is initiated by invoking getState() on this channel.
protected JChannel	JChannel.init()	Initializes all variables.
protected final 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.probeHandler(DiagnosticsHandler.ProbeHandler h)
JChannel	JChannel.receiver(Receiver r)
JChannel	JChannel.removeChannelListener(ChannelListener listener)
protected JChannel	JChannelProbeHandler.resetAllStats()
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 JChannel.send(Message).
JChannel	JChannel.send(Message msg)	Sends a message.
protected JChannel	JChannel.setAddress()	Generates 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.setUpHandler(UpHandler h)
JChannel	JChannel.stack(ProtocolStack st)
JChannel	JChannel.stack(ProtocolStack st, boolean delete_old_stack)
protected JChannel	JChannel.startStack(String cluster_name)
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	JChannelProbeHandler.channel(JChannel ch)
default void	ChannelListener.channelClosed(JChannel channel)	Channel has been closed notification callback
default void	ChannelListener.channelConnected(JChannel channel)	Channel has been connected notification callback
default void	ChannelListener.channelDisconnected(JChannel channel)	Channel has been disconnected notification callback
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

Modifier	Constructor	Description
	JChannelProbeHandler(JChannel ch)

Uses of JChannel in org.jgroups.admin

Fields in org.jgroups.admin declared as JChannel

Modifier and Type	Field	Description
protected final JChannel	Admin.ch
protected final JChannel	AdminHandler.ch
protected JChannel	SwitchAdminHandler.new_channel

Methods in org.jgroups.admin that return JChannel

Modifier and Type	Method	Description
JChannel	Admin.channel()
JChannel	AdminHandler.channel()
protected static JChannel	SwitchAdminHandler.createNewChannel(int version, String config, String name)

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

Modifier	Constructor	Description
	Admin(JChannel ch)
protected	AdminHandler(JChannel ch)
	PartitionHandler(JChannel ch)
	ProbeAdminHandler(JChannel ch)
	SwitchAdminHandler(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.channelDisconnected(JChannel channel)
<X extends MessageDispatcher> X	MessageDispatcher.setChannel(JChannel ch)

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

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

Uses of JChannel in org.jgroups.blocks.atomic

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

Modifier	Constructor	Description
	CounterService(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 static final JChannel	ProgrammaticChat.ch
protected JChannel	RelayDemo.ch
protected JChannel	RelayDemoRpc.ch
protected JChannel	Chat.channel

Methods in org.jgroups.demos that return JChannel

Modifier and Type	Method	Description
JChannel	Churn.Entry.channel()	Returns the value of the channel record component.

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

Modifier and Type	Method	Description
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	ReplicatedHashMapDemo.start(JChannel channel)

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

Modifier	Constructor	Description
	Draw(JChannel channel)
	Draw(JChannel channel, boolean use_state, long state_timeout)
protected	Entry(JChannel channel, String name)	Creates an instance of a Entry record class.

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 final JChannel	ForkChannel.main_channel

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

Modifier and Type	Field	Description
protected final ConcurrentMap<String,JChannel>	ForkProtocolStack.fork_channels

Methods in org.jgroups.fork that return JChannel

Modifier and Type	Method	Description
JChannel	ForkProtocolStack.get(String fork_channel_id)
JChannel	ForkChannel.name(String name)
JChannel	ForkProtocolStack.putIfAbsent(String id, JChannel fc)

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

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

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

Modifier	Constructor	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.

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, 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.registerChannel(JChannel ch, MBeanServer server, ObjectName namePrefix, String cluster_name, boolean register_protocols)
static void	JmxConfigurator.unregisterChannel(JChannel c, MBeanServer server, String clusterName)
static void	JmxConfigurator.unregisterChannel(JChannel c, MBeanServer server, String domain, String clusterName)
static void	JmxConfigurator.unregisterChannel(JChannel c, MBeanServer server, ObjectName prefix, String clusterName)
static DynamicMBean	JmxConfigurator.wrap(JChannel ch)	Wrap JChannel with DynamicMBean interface.

Uses of JChannel in org.jgroups.protocols

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

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

Uses of JChannel in org.jgroups.protocols.relay

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

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

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

Modifier and Type	Method	Description
JChannel	Route.bridge()
JChannel	RELAY.getBridge(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

Modifier	Constructor	Description
protected	Bridge(JChannel ch, Relayer3 r, String cluster_name, String channel_name, AddressGenerator addr_generator)
protected	Bridge(JChannel ch, String cluster, String name, AddressGenerator gen)
	Route(Address site_master, JChannel bridge, RELAY 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

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

Uses of JChannel in org.jgroups.util

Fields in org.jgroups.util declared as JChannel

Modifier and Type	Field	Description
protected JChannel	Metrics.ch

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 Map<String, Map<String, Metrics.Entry<Object>>>	Metrics.extract(JChannel ch)
static Map<String, Map<String, Metrics.Entry<Object>>>	Metrics.extract(JChannel ch, Predicate<AccessibleObject> filter)
static boolean	Tests.hasThreadPool(JChannel... channels)
static boolean	Util.isCoordinator(JChannel ch)
static boolean	Tests.mcastRetransmissionAvailable(JChannel... channels)
static String	Util.printViews(JChannel... channels)
static boolean	Tests.processingPolicyIs(Class<? extends MessageProcessingPolicy> policy_class, JChannel... channels)
static void	Util.registerChannel(JChannel channel, String name)
static void	Util.removeFromViews(Address mbr, JChannel... channels)
static void	Util.shutdown(JChannel ch)	Drops messages to/from other members and then closes the channel.
static void	Util.shutdown(JChannel ch, boolean graceful_close)
static boolean	Tests.ucastRetransmissionAvailable(JChannel... channels)
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.close(Collection<JChannel> channels)
static void	Util.waitUntilAllChannelsHaveSameView(long timeout, long interval, Collection<JChannel> channels)