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.jmx | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
abstract java.lang.Object |
Channel.peek(long timeout)
Returns the next message, view, block, suspect or other event without removing
it from the queue.
|
java.lang.Object |
JChannel.peek(long timeout)
Just peeks at the next message, view or block.
|
abstract java.lang.Object |
Channel.receive(long timeout)
Receives a message, a view change or a block event.
|
java.lang.Object |
JChannel.receive(long timeout)
Blocking receive method.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
RpcDispatcher.sendMessage(Message msg,
int mode,
long timeout) |
java.lang.Object |
MessageDispatcher.sendMessage(Message msg,
int mode,
long timeout)
Sends a message to a single member (destination = msg.dest) and returns the response.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
JChannel.peek(long timeout) |
java.lang.Object |
JChannelMBean.peek(long timeout) |
java.lang.Object |
JChannel.receive(long timeout) |
java.lang.Object |
JChannelMBean.receive(long timeout) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
RpcProtocol.callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout) |
java.lang.Object |
RpcProtocol.callRemoteMethod(Address dest,
java.lang.String method_name,
int mode,
long timeout) |
java.lang.Object |
RpcProtocol.callRemoteMethod(Address dest,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout) |
java.lang.Object |
RpcProtocol.callRemoteMethod(Address dest,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.String[] signature,
int mode,
long timeout) |
java.lang.Object |
MessageProtocol.sendMessage(Message msg,
int mode,
long timeout)
Sends a message to a single member (destination = msg.dest) and returns the response.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
Promise.getResultWithTimeout(long timeout)
Blocks until a result is available, or timeout milliseconds have elapsed
|
java.lang.Object |
Queue.peek(long timeout)
returns the first object on the queue, without removing it.
|
java.lang.Object |
LinkedListQueue.peek(long timeout)
returns the first object on the queue, without removing it.
|
java.lang.Object |
Queue2.peek(long timeout)
returns the first object on the queue, without removing it.
|
java.lang.Object |
Queue.remove(long timeout)
Removes 1 element from the head.
|
java.lang.Object |
LinkedListQueue.remove(long timeout)
Removes 1 element from the head.
|
java.lang.Object |
Queue2.remove(long timeout)
Removes 1 element from the head.
|
boolean |
AckCollector.waitForAllAcks(long timeout) |
void |
Queue2.waitUntilEmpty(long timeout)
Blocks until the queue has no elements left.
|
void |
CondVar.waitUntilWithTimeout(java.lang.Object result,
long timeout)
Waits until the condition matches the expected result.
|
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.