com.fr.third.jgroups.blocks.mux

类 MuxRequestCorrelator

java.lang.Object

com.fr.third.jgroups.blocks.RequestCorrelator

com.fr.third.jgroups.blocks.mux.MuxRequestCorrelator

public class MuxRequestCorrelator
extends RequestCorrelator

A request correlator that adds a mux header to incoming and outgoing messages.

作者:

Bela Ban, Paul Ferraro, Brian Stansberry

嵌套类概要

从类继承的嵌套类/接口 com.fr.third.jgroups.blocks.RequestCorrelator

RequestCorrelator.Header, RequestCorrelator.MultiDestinationHeader, RequestCorrelator.ResponseImpl

字段概要

字段

限定符和类型	字段和说明
protected static short	MUX_ID

从类继承的字段 com.fr.third.jgroups.blocks.RequestCorrelator

async_dispatching, id, local_addr, log, marshaller, request_handler, requests, started, transport, view

构造器概要

构造器

构造器和说明
MuxRequestCorrelator(short id, Protocol transport, RequestHandler handler, Address localAddr)

方法概要

方法

限定符和类型	方法和说明
protected void	prepareResponse(Message rsp)
void	sendRequest(long requestId, java.util.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

从类继承的方法 com.fr.third.jgroups.blocks.RequestCorrelator

asyncDispatching, asyncDispatching, done, getLocalAddress, getMarshaller, handleRequest, receive, receiveMessage, receiveSuspect, receiveView, registerProbeHandler, sendReply, sendRequest, sendResponse, setLocalAddress, setMarshaller, setRequestHandler, setSiteUnreachable, start, stop, unregisterProbeHandler

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

MUX_ID

protected static final short MUX_ID

构造器详细资料

MuxRequestCorrelator

public MuxRequestCorrelator(short id,
                    Protocol transport,
                    RequestHandler handler,
                    Address localAddr)

方法详细资料

sendRequest

public void sendRequest(long requestId,
               java.util.Collection<Address> dest_mbrs,
               Message msg,
               RspCollector coll,
               RequestOptions options)
                 throws java.lang.Exception

从类复制的说明: RequestCorrelator

Sends a request to a group. If no response collector is given, no responses are expected (making the call asynchronous)

覆盖:

sendRequest 在类中 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 data

coll - 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.

抛出:

java.lang.Exception

sendUnicastRequest

public void sendUnicastRequest(long id,
                      Address target,
                      Message msg,
                      RspCollector coll)
                        throws java.lang.Exception

从类复制的说明: RequestCorrelator

Sends a request to a single destination

覆盖:

sendUnicastRequest 在类中 RequestCorrelator

抛出:

java.lang.Exception

prepareResponse

protected void prepareResponse(Message rsp)

覆盖:

prepareResponse 在类中 RequestCorrelator