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

Uses of JChannel in org.jgroups

Fields in org.jgroups declared as JChannel

Modifier and Type	Field	Description
protected final 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()
protected JChannel	JChannel.cleanup()
JChannel	JChannel.clearChannelListeners()
JChannel	JChannel.connect(String cluster_name)	Joins the cluster.
protected JChannel	JChannel.connect(String cluster_name, boolean useFlushIfPresent)	Deprecated, for removal: This API element is subject to removal in a future version.
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)	Deprecated, for removal: This API element is subject to removal in a future version.
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)	Deprecated, for removal: This API element is subject to removal in a future version.
protected JChannel	JChannel.getState(Address target, long timeout, Callable<Boolean> flushInvoker)
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.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 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.setStats(boolean stats)
JChannel	JChannel.setUpHandler(UpHandler h)
JChannel	JChannel.startFlush(boolean automatic_resume)	Deprecated, for removal: This API element is subject to removal in a future version.
JChannel	JChannel.startFlush(List<Address> flushParticipants, boolean automatic_resume)	Deprecated, for removal: This API element is subject to removal in a future version.
protected JChannel	JChannel.startStack(String cluster_name)
JChannel	JChannel.stats(boolean stats)
JChannel	JChannel.stopFlush()	Deprecated, for removal: This API element is subject to removal in a future version.
JChannel	JChannel.stopFlush(List<Address> flushParticipants)	Deprecated, for removal: This API element is subject to removal in a future version.
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
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.blocks

Fields in org.jgroups.blocks declared as JChannel

Modifier and Type	Field	Description
private JChannel	ReplCache.ch
protected JChannel	MessageDispatcher.channel
private final JChannel	ReplicatedHashMap.channel
(package private) JChannel	ReplicatedTree.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.blocks.locking

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

Modifier and Type	Field	Description
protected JChannel	LockService.ch	Deprecated.

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

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

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

Modifier	Constructor	Description
	LockService(JChannel ch)	Deprecated.

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	LockServiceDemo.ch
protected static final JChannel	ProgrammaticChat.ch
protected JChannel	RelayDemo.ch
protected JChannel	RelayDemoRpc.ch
protected JChannel	Chat.channel
private JChannel	Draw.channel
private JChannel	Topology.channel
(package private) JChannel	TotalOrder.channel

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	LockServiceDemo.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)

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.tests

Fields in org.jgroups.tests declared as JChannel

Modifier and Type	Field	Description
protected JChannel	FlowControlTest.ch
protected JChannel	MessageSendTest.ch
(package private) JChannel	PingPong.ch
(package private) JChannel	LargeState.channel
(package private) JChannel	MessageDispatcherSpeedTest.channel
protected JChannel	RoundTripRpc.channel
(package private) JChannel	RpcDispatcherBlocking.channel
protected JChannel	RpcDispatcherSpeedTest.channel
protected JChannel	UnicastTest.channel
private JChannel	UnicastTestRpc.channel

Methods in org.jgroups.tests that return JChannel

Modifier and Type	Method	Description
protected static JChannel	InfinispanStackMerge3Test.createChannel(TP transport, String name)

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

Modifier and Type	Method	Description
protected static int	MessageSendTest.findFragSize(JChannel ch)
protected static List<String>	UnicastTestRpc.getSites(JChannel channel)
protected static String	InfinispanStackMerge3Test.printViews(JChannel... channels)

Uses of JChannel in org.jgroups.tests.perf

Fields in org.jgroups.tests.perf declared as JChannel

Modifier and Type	Field	Description
protected JChannel	MPerf.channel
protected JChannel	MPerfRpc.channel
private JChannel	ProgrammaticUPerf.channel
private static final JChannel	ProgrammaticUPerf2.channel
private JChannel	UPerf.channel

Methods in org.jgroups.tests.perf with parameters of type JChannel

Modifier and Type	Method	Description
protected static List<String>	UPerf.getSites(JChannel channel)

Uses of JChannel in org.jgroups.tests.rt.transports

Fields in org.jgroups.tests.rt.transports declared as JChannel

Modifier and Type	Field	Description
protected JChannel	JGroupsTransport.ch

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 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 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.waitUntilAllChannelsHaveSameView(long timeout, long interval, Collection<JChannel> channels)