|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Channel | |
---|---|
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.mux | |
org.jgroups.demos | Provides demonstrations of JGroups functionality. |
org.jgroups.util | Provides useful functionality which cannot be assigned to any particular other package. |
Uses of Channel in org.jgroups |
---|
Subclasses of Channel in org.jgroups | |
---|---|
class |
JChannel
JChannel is a default implementation of a Channel abstraction. |
Methods in org.jgroups with parameters of type Channel | |
---|---|
void |
ChannelListener.channelClosed(Channel channel)
Channel has been closed notification callback |
void |
ChannelListener.channelConnected(Channel channel)
Channel has been connected notification callback |
void |
ChannelListener.channelDisconnected(Channel channel)
Channel has been disconnected notification callback |
protected void |
Channel.notifyChannelClosed(Channel c)
|
protected void |
Channel.notifyChannelConnected(Channel c)
|
protected void |
Channel.notifyChannelDisconnected(Channel c)
|
Uses of Channel in org.jgroups.blocks |
---|
Fields in org.jgroups.blocks declared as Channel | |
---|---|
protected Channel |
MessageDispatcher.channel
|
Methods in org.jgroups.blocks that return Channel | |
---|---|
Channel |
ReplicatedTree.getChannel()
Returns the Channel the DistributedTree is connected to |
Channel |
MessageDispatcher.getChannel()
|
Channel |
ReplicatedHashMap.getChannel()
|
Methods in org.jgroups.blocks with parameters of type Channel | |
---|---|
void |
MessageDispatcher.channelClosed(Channel channel)
|
void |
MessageDispatcher.channelConnected(Channel channel)
|
void |
MessageDispatcher.channelDisconnected(Channel channel)
|
void |
MessageDispatcher.setChannel(Channel ch)
|
Constructors in org.jgroups.blocks with parameters of type Channel | |
---|---|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2)
|
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler)
|
|
ReplicatedHashMap(Channel channel)
Constructs a new ReplicatedHashMap with channel. |
|
ReplicatedHashMap(java.util.concurrent.ConcurrentMap<K,V> map,
Channel channel)
Constructs a new ReplicatedHashMap using provided map instance. |
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
java.lang.Object server_obj)
|
|
RpcDispatcher(Channel channel,
java.lang.Object server_obj)
|
Uses of Channel in org.jgroups.blocks.mux |
---|
Constructors in org.jgroups.blocks.mux with parameters of type Channel | |
---|---|
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler)
|
|
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
java.lang.Object serverObject)
|
|
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
java.lang.Object serverObject,
MethodLookup method_lookup)
|
Uses of Channel in org.jgroups.demos |
---|
Methods in org.jgroups.demos with parameters of type Channel | |
---|---|
void |
Draw.channelClosed(Channel channel)
|
void |
Draw.channelConnected(Channel channel)
|
void |
Draw.channelDisconnected(Channel channel)
|
Constructors in org.jgroups.demos with parameters of type Channel | |
---|---|
Draw(Channel channel)
|
|
Draw(Channel channel,
boolean use_state,
long state_timeout)
|
Uses of Channel in org.jgroups.util |
---|
Methods in org.jgroups.util with parameters of type Channel | |
---|---|
static void |
Util.addFlush(Channel ch,
FLUSH flush)
|
static void |
Util.close(Channel... channels)
|
static void |
Util.close(Channel ch)
|
static void |
Util.shutdown(Channel ch)
Drops messages to/from other members and then closes the channel. |
static boolean |
Util.startFlush(Channel c)
|
static boolean |
Util.startFlush(Channel c,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling)
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants)
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling)
|
static void |
Util.waitUntilAllChannelsHaveSameSize(long timeout,
long interval,
Channel... channels)
Blocks until all channels have the same view |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |