| java.lang.Object org.apache.catalina.tribes.group.RpcChannel
RpcChannel | public class RpcChannel implements ChannelListener(Code) | | A channel to handle RPC messaging
author: Filip Hanik |
Inner Class :public static class RpcCollector | |
Inner Class :public static class RpcCollectorKey | |
ALL_REPLY | final public static int ALL_REPLY(Code) | | |
FIRST_REPLY | final public static int FIRST_REPLY(Code) | | |
MAJORITY_REPLY | final public static int MAJORITY_REPLY(Code) | | |
NO_REPLY | final public static int NO_REPLY(Code) | | |
RpcChannel | public RpcChannel(byte[] rpcId, Channel channel, RpcCallback callback)(Code) | | Create an RPC channel. You can have several RPC channels attached to a group
all separated out by the uniqueness
Parameters: rpcId - - the unique Id for this RPC group Parameters: channel - Channel Parameters: callback - RpcCallback |
breakdown | public void breakdown()(Code) | | |
finalize | public void finalize()(Code) | | |
getRpcId | public byte[] getRpcId()(Code) | | |
send | public Response[] send(Member[] destination, Serializable message, int rpcOptions, int channelOptions, long timeout) throws ChannelException(Code) | | Send a message and wait for the response.
Parameters: destination - Member[] - the destination for the message, and the members you request a reply from Parameters: message - Serializable - the message you are sending out Parameters: options - int - FIRST_REPLY, MAJORITY_REPLY or ALL_REPLY Parameters: timeout - long - timeout in milliseconds, if no reply is received within this time null is returned Response[] - an array of response objects. throws: ChannelException - |
setRpcId | public void setRpcId(byte[] rpcId)(Code) | | |
|
|