Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.mux |
Modifier and Type | Class and Description |
---|---|
class |
MessageDispatcher
Provides synchronous and asynchronous message sending with request-response
correlation; i.e., matching responses with the original request.
|
class |
RpcDispatcher
This class allows a programmer to invoke remote methods in all (or single)
group members and optionally wait for the return value(s).
|
Modifier and Type | Field and Description |
---|---|
protected RequestHandler |
MessageDispatcher.req_handler |
protected RequestHandler |
RequestCorrelator.request_handler
The handler for the incoming requests.
|
Modifier and Type | Method and Description |
---|---|
protected RequestCorrelator |
MessageDispatcher.createRequestCorrelator(Object transport,
RequestHandler handler,
Address local_addr) |
void |
RequestCorrelator.setRequestHandler(RequestHandler handler) |
void |
MessageDispatcher.setRequestHandler(RequestHandler rh) |
Constructor and Description |
---|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler) |
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler,
boolean deadlock_detection)
Deprecated.
|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler,
boolean deadlock_detection,
boolean concurrent_processing)
Deprecated.
|
MessageDispatcher(PullPushAdapter adapter,
Serializable id,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler)
Deprecated.
|
MessageDispatcher(PullPushAdapter adapter,
Serializable id,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler,
boolean concurrent_processing)
Deprecated.
|
RequestCorrelator(Object transport,
RequestHandler handler,
Address local_addr) |
RequestCorrelator(short id,
Object transport,
RequestHandler handler,
Address local_addr) |
RequestCorrelator(String name,
Object transport,
RequestHandler handler)
Deprecated.
|
RequestCorrelator(String name,
Object transport,
RequestHandler handler,
Address local_addr)
Deprecated.
|
RequestCorrelator(String name,
Object transport,
RequestHandler handler,
Address local_addr,
boolean concurrent_processing)
Deprecated.
|
RequestCorrelator(String name,
Object transport,
RequestHandler handler,
boolean deadlock_detection)
Deprecated.
|
RequestCorrelator(String name,
Object transport,
RequestHandler handler,
boolean deadlock_detection,
Address local_addr)
Deprecated.
|
RequestCorrelator(String name,
Object transport,
RequestHandler handler,
boolean deadlock_detection,
Address local_addr,
boolean concurrent_processing)
Deprecated.
|
RequestCorrelator(String name,
Object transport,
RequestHandler handler,
boolean deadlock_detection,
boolean concurrent_processing)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
MuxMessageDispatcher
A multiplexed message dispatcher.
|
class |
MuxRpcDispatcher
A multiplexed message dispatcher.
|
Modifier and Type | Method and Description |
---|---|
protected RequestCorrelator |
MuxMessageDispatcher.createRequestCorrelator(Object transport,
RequestHandler handler,
Address localAddr) |
protected RequestCorrelator |
MuxRpcDispatcher.createRequestCorrelator(Object transport,
RequestHandler handler,
Address localAddr) |
Constructor and Description |
---|
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler) |
MuxRequestCorrelator(short id,
Object transport,
RequestHandler handler,
Address localAddr) |
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.