org.apache.catalina.tribes.group
Class RpcChannel
java.lang.Object
org.apache.catalina.tribes.group.RpcChannel
- All Implemented Interfaces:
- ChannelListener
public class RpcChannel
- extends Object
- implements ChannelListener
A channel to handle RPC messaging
- Author:
- Filip Hanik
FIRST_REPLY
public static final int FIRST_REPLY
- See Also:
- Constant Field Values
MAJORITY_REPLY
public static final int MAJORITY_REPLY
- See Also:
- Constant Field Values
ALL_REPLY
public static final int ALL_REPLY
- See Also:
- Constant Field Values
NO_REPLY
public static final int NO_REPLY
- See Also:
- Constant Field Values
RpcChannel
public RpcChannel(byte[] rpcId,
Channel channel,
RpcCallback callback)
- 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 groupchannel
- Channelcallback
- RpcCallback
send
public Response[] send(Member[] destination,
Serializable message,
int rpcOptions,
int channelOptions,
long timeout)
throws ChannelException
- Send a message and wait for the response.
- Parameters:
destination
- Member[] - the destination for the message, and the members you request a reply frommessage
- Serializable - the message you are sending outrpcOptions
- int - FIRST_REPLY, MAJORITY_REPLY or ALL_REPLYchannelOptions
- channel sender optionstimeout
- long - timeout in milliseconds, if no reply is received within this time null is returned
- Returns:
- Response[] - an array of response objects.
- Throws:
ChannelException
messageReceived
public void messageReceived(Serializable msg,
Member sender)
- Description copied from interface:
ChannelListener
- Receive a message from the channel
- Specified by:
messageReceived
in interface ChannelListener
- Parameters:
msg
- Serializablesender
- - the source of the message
breakdown
public void breakdown()
finalize
public void finalize()
- Overrides:
finalize
in class Object
accept
public boolean accept(Serializable msg,
Member sender)
- Description copied from interface:
ChannelListener
- Invoked by the channel to determine if the listener will process this message or not.
- Specified by:
accept
in interface ChannelListener
- Parameters:
msg
- Serializablesender
- Member
- Returns:
- boolean
getChannel
public Channel getChannel()
getCallback
public RpcCallback getCallback()
getRpcId
public byte[] getRpcId()
setChannel
public void setChannel(Channel channel)
setCallback
public void setCallback(RpcCallback callback)
setRpcId
public void setRpcId(byte[] rpcId)
getReplyMessageOptions
public int getReplyMessageOptions()
setReplyMessageOptions
public void setReplyMessageOptions(int replyMessageOptions)
bToS
protected static String bToS(byte[] data)
Copyright © 2000-2012 Apache Software Foundation. All Rights Reserved.