|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Message | |
org.javagroups | |
org.javagroups.blocks | |
org.javagroups.demos | |
org.javagroups.demos.wb | |
org.javagroups.protocols | |
org.javagroups.stack | |
org.javagroups.util |
Uses of Message in org.javagroups |
Methods in org.javagroups that return Message | |
Message |
Message.copy()
|
Message |
Message.makeReply()
|
Methods in org.javagroups with parameters of type Message | |
void |
EnsChannel.send(Message msg)
|
void |
JChannel.send(Message msg)
implementation of the Transport interface. Sends a message through the protocol stack |
void |
Transport.send(Message msg)
|
abstract void |
Channel.send(Message msg)
Sends a message to a (unicast) destination. |
void |
MessageListener.receive(Message msg)
|
Uses of Message in org.javagroups.blocks |
Fields in org.javagroups.blocks declared as Message | |
protected Message |
GroupRequest.request_msg
|
Methods in org.javagroups.blocks with parameters of type Message | |
void |
ConnectionTable1_4.send(Message msg)
Sends a message to a unicast destination. |
void |
ConnectionTable1_4.receive(Message msg)
Calls the receiver callback. |
void |
ConnectionTable1_4.Receiver.receive(Message msg)
|
void |
TransactionalHashtable.receive(Message msg)
|
java.lang.Object |
ReplicationManager.handle(Message msg)
|
void |
ReplicatedTree.receive(Message msg)
Callback. |
void |
ReplicatedHashtable.receive(Message msg)
|
void |
NotificationBus.receive(Message msg)
|
void |
MessageListenerAdapter.receive(Message msg)
Receive message from group. |
void |
GroupRequest.reset(Message m,
int mode,
long timeout)
Resets the group request, so it can be reused for another execution. |
void |
GroupRequest.reset(Message m,
java.util.Vector members,
int rsp_mode,
long timeout,
int expected_rsps)
|
void |
GroupRequest.receiveResponse(Message m)
Callback (called by RequestCorrelator or Transport). |
void |
DistributedTree.receive(Message msg)
|
void |
DistributedQueue.receive(Message msg)
|
void |
VotingAdapter.receive(Message msg)
Receive the message. |
void |
RspCollector.receiveResponse(Message msg)
|
void |
RequestCorrelator.sendRequest(long id,
Message msg,
RspCollector coll)
Helper method for RequestCorrelator.sendRequest(long,List,Message,RspCollector) . |
void |
RequestCorrelator.sendRequest(long id,
java.util.List dest_mbrs,
Message msg,
RspCollector coll)
Send a request to a group. |
boolean |
RequestCorrelator.receiveMessage(Message msg)
Handles a message coming from a layer below |
void |
PullPushAdapter.send(java.io.Serializable identifier,
Message msg)
|
void |
PullPushAdapter.send(Message msg)
|
protected void |
PullPushAdapter.handleMessage(Message msg)
Check whether the message has an identifier. |
java.lang.Object |
RequestHandler.handle(Message msg)
|
void |
MessageDispatcher.send(Message msg)
|
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout)
Cast a message to all members, and wait for mode responses. |
void |
MessageDispatcher.castMessage(java.util.Vector dests,
long req_id,
Message msg,
RspCollector coll)
Multicast a message request to all members in dests and receive responses
via the RspCollector interface. |
java.lang.Object |
MessageDispatcher.sendMessage(Message msg,
int mode,
long timeout)
Sends a message to a single member (destination = msg.dest) and returns the response. |
java.lang.Object |
MessageDispatcher.handle(Message msg)
|
RspList |
RpcDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout)
|
java.lang.Object |
RpcDispatcher.sendMessage(Message msg,
int mode,
long timeout)
|
java.lang.Object |
RpcDispatcher.handle(Message req)
Message contains MethodCall. |
void |
DistributedHashtable.receive(Message msg)
|
void |
ConnectionTable.send(Message msg)
Sends a message to a unicast destination. |
void |
ConnectionTable.receive(Message msg)
Calls the receiver callback. |
void |
ConnectionTable.Receiver.receive(Message msg)
|
Constructors in org.javagroups.blocks with parameters of type Message | |
GroupRequest(Message m,
RequestCorrelator corr,
java.util.Vector members,
int rsp_mode)
|
|
GroupRequest(Message m,
RequestCorrelator corr,
java.util.Vector members,
int rsp_mode,
long timeout,
int expected_mbrs)
|
|
GroupRequest(Message m,
Transport transport,
java.util.Vector members,
int rsp_mode)
|
|
GroupRequest(Message m,
Transport transport,
java.util.Vector members,
int rsp_mode,
long timeout,
int expected_mbrs)
|
Uses of Message in org.javagroups.demos |
Methods in org.javagroups.demos with parameters of type Message | |
void |
QuoteServer.receive(Message msg)
|
void |
Chat.receive(Message msg)
|
Uses of Message in org.javagroups.demos.wb |
Methods in org.javagroups.demos.wb with parameters of type Message | |
void |
Whiteboard.receive(Message m)
|
Uses of Message in org.javagroups.protocols |
Methods in org.javagroups.protocols with parameters of type Message | |
void |
UNICAST.retransmit(long seqno,
Message msg)
Called by AckSenderWindow to resend messages for which no ACK has been received yet |
void |
TUNNEL.handleIncomingMessage(Message msg)
|
void |
TCP.receive(Message msg)
ConnectionTable.Receiver interface |
java.lang.Object |
STATE_TRANSFER.handle(Message msg)
|
void |
SMACK.retransmit(long seqno,
Message msg,
Address dest)
|
java.lang.Object |
MessageProtocolEXAMPLE.handle(Message req)
Callback. |
protected void |
JMS.sendMessage(Message msg)
Publish message in the JMS topic. |
java.lang.Object |
FLOW_CONTROL.handle(Message req)
Called when a request for this protocol layer is received. |
Uses of Message in org.javagroups.stack |
Methods in org.javagroups.stack that return Message | |
Message |
NakReceiverWindow.remove()
Find the entry with seqno head . |
Message |
AckReceiverWindow.remove()
Removes a message whose seqno is equal to next_to_remove , increments the latter. |
Message |
RouterStub.receive()
Receives a message from the router (blocking mode). |
Methods in org.javagroups.stack with parameters of type Message | |
void |
NakReceiverWindow.add(long seqno,
Message msg)
Adds a message according to its sequence number (ordered). |
void |
AckReceiverWindow.add(long seqno,
Message msg)
|
void |
AckSenderWindow.add(long seqno,
Message msg)
Adds a new message to the retransmission table. |
void |
AckSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg)
|
void |
AckMcastSenderWindow.add(long seqno,
Message msg,
java.util.Vector receivers)
Adds a new message to the hash table. |
void |
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg,
Address dest)
Retranmit the given msg |
boolean |
RouterStub.send(Message msg,
java.lang.String groupname)
Sends a message to the router. |
RspList |
MessageProtocol.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout)
Cast a message to all members, and wait for mode responses. |
java.lang.Object |
MessageProtocol.sendMessage(Message msg,
int mode,
long timeout)
Sends a message to a single member (destination = msg.dest) and returns the response. |
java.lang.Object |
MessageProtocol.handle(Message req)
Processes a request destined for this layer. |
java.lang.Object |
RpcProtocol.handle(Message req)
Message contains MethodCall. |
void |
ProtocolStack.send(Message msg)
|
Uses of Message in org.javagroups.util |
Methods in org.javagroups.util with parameters of type Message | |
static java.lang.String |
Util.printMessage(Message msg)
Tries to read an object from the message's buffer and prints it |
static java.lang.String |
Util.printMethodCall(Message msg)
Tries to read a MethodCall object from the message's buffer and prints it. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |