public class MuxRequestCorrelator extends RequestCorrelator
RequestCorrelator.Header, RequestCorrelator.MultiDestinationHeader
Modifier and Type | Field and Description |
---|---|
protected static short |
MUX_ID |
id, local_addr, log, marshaller, request_handler, requests, started, transport, view
Constructor and Description |
---|
MuxRequestCorrelator(short id,
Protocol transport,
RequestHandler handler,
Address localAddr) |
Modifier and Type | Method and Description |
---|---|
protected void |
prepareResponse(Message rsp) |
void |
sendRequest(long requestId,
Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options)
Sends a request to a group.
|
void |
sendUnicastRequest(long id,
Address target,
Message msg,
RspCollector coll)
Sends a request to a single destination
|
done, getLocalAddress, getMarshaller, handleRequest, receive, receiveMessage, receiveSuspect, receiveView, registerProbeHandler, sendRequest, setLocalAddress, setMarshaller, setRequestHandler, start, stop, unregisterProbeHandler
public MuxRequestCorrelator(short id, Protocol transport, RequestHandler handler, Address localAddr)
public void sendRequest(long requestId, Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options) throws Exception
RequestCorrelator
sendRequest
in class RequestCorrelator
requestId
- The request ID. Must be unique for this JVM (e.g. current time in millisecs)dest_mbrs
- The list of members who should receive the call. Usually a group RPC
is sent via multicast, but a receiver drops the request if its own address
is not in this list. Will not be used if it is null.msg
- The request to be sent. The body of the message carries
the request datacoll
- A response collector (usually the object that invokes this method). Its methods
receiveResponse()
and suspect()
will be invoked when a message has been received
or a member is suspected, respectively.Exception
public void sendUnicastRequest(long id, Address target, Message msg, RspCollector coll) throws Exception
RequestCorrelator
sendUnicastRequest
in class RequestCorrelator
Exception
protected void prepareResponse(Message rsp)
prepareResponse
in class RequestCorrelator
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.