Package | Description |
---|---|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
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.
|
Modifier and Type | Field and Description |
---|---|
protected Channel |
JGroupsTransport.channel |
Modifier and Type | Method and Description |
---|---|
Channel |
JGroupsTransport.getChannel() |
Channel |
JGroupsChannelLookup.getJGroupsChannel(Properties p)
Retrieves a JGroups channel.
|
Constructor and Description |
---|
CommandAwareRpcDispatcher(Channel channel,
JGroupsTransport transport,
ExecutorService asyncExecutor,
InboundInvocationHandler inboundInvocationHandler) |
JGroupsTransport(Channel channel)
This form is used when the transport is created by an external source and passed in to the
GlobalConfiguration.
|
Modifier and Type | Class and Description |
---|---|
class |
JChannel
JChannel is a default implementation of a Channel abstraction.
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Field and Description |
---|---|
protected Channel |
MessageDispatcher.channel |
Modifier and Type | Method and Description |
---|---|
Channel |
ReplicatedTree.getChannel()
Returns the Channel the DistributedTree is connected to
|
Channel |
ReplicatedHashMap.getChannel() |
Channel |
MessageDispatcher.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
MessageDispatcher.channelClosed(Channel channel) |
void |
MessageDispatcher.channelConnected(Channel channel) |
void |
MessageDispatcher.channelDisconnected(Channel channel) |
void |
MessageDispatcher.setChannel(Channel ch) |
Constructor and Description |
---|
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(ConcurrentMap<K,V> map,
Channel channel)
Constructs a new ReplicatedHashMap using provided map instance.
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
Object server_obj) |
RpcDispatcher(Channel channel,
Object server_obj) |
Constructor and Description |
---|
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
Object serverObject) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
Object serverObject,
MethodLookup method_lookup) |
Modifier and Type | Method and Description |
---|---|
void |
Draw.channelClosed(Channel channel) |
void |
Draw.channelConnected(Channel channel) |
void |
Draw.channelDisconnected(Channel channel) |
Constructor and Description |
---|
Draw(Channel channel) |
Draw(Channel channel,
boolean use_state,
long state_timeout) |
Modifier and Type | Method and Description |
---|---|
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,
List<Address> flushParticipants) |
static boolean |
Util.startFlush(Channel c,
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
|
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.