## Uses of Class
org.jgroups.Message

Packages that use Message
org.jgroups: Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.auth
org.jgroups.blocks: Provides building blocks that are layered on top of channels.
org.jgroups.blocks.mux
org.jgroups.debug: Provides debug support, including testing, profiling, and a graphical view of a protocol stack.
org.jgroups.demos: Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb: A distributed whiteboard applet implemented using JGroups.
org.jgroups.mux
org.jgroups.protocols: Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.stack: Support for managing protocol stacks.
org.jgroups.util: Provides useful functionality which cannot be assigned to any particular other package.

Uses of Message in org.jgroups

Methods in org.jgroups that return Message
`Message` `Message.copy()`
`Message` `Message.copy(boolean copy_buffer)` Create a copy of the message.
`Message` `Message.copy(boolean copy_buffer, boolean copy_headers)` Create a copy of the message.
`Message` `Message.copy(boolean copy_buffer, short starting_id)` Doesn't copy any headers except for those with ID >= copy_headers_above
`Message` `Message.makeReply()`

Methods in org.jgroups with parameters of type Message
`void` `ReceiverAdapter.receive(Message msg)`
`void` `ExtendedReceiverAdapter.receive(Message msg)`
`void` `MessageListener.receive(Message msg)` Called when a message is received.
`void` `JChannel.send(Message msg)` 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.

Uses of Message in org.jgroups.auth

Methods in org.jgroups.auth with parameters of type Message
`boolean` `X509Token.authenticate(AuthToken token, Message msg)`
`boolean` `SimpleToken.authenticate(AuthToken token, Message msg)`
`boolean` `RegexMembership.authenticate(AuthToken token, Message msg)`
`boolean` `MD5Token.authenticate(AuthToken token, Message msg)`
`boolean` `FixedMembershipToken.authenticate(AuthToken token, Message msg)`
`abstract boolean` `AuthToken.authenticate(AuthToken token, Message msg)` This method should be implemented to perform the actual authentication of joining members.

Uses of Message in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Message
`protected Message` `Request.request_msg`

Methods in org.jgroups.blocks with parameters of type Message
`protected GroupRequest` `MessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)`
`RspList` `MessageDispatcher.castMessage(java.util.Collection<Address> dests, Message msg, RequestOptions options)` Sends a message to the members listed in dests.
`RspList` `MessageDispatcher.castMessage(java.util.Vector dests, Message msg, int mode, long timeout)` Deprecated.
`RspList` `MessageDispatcher.castMessage(java.util.Vector dests, Message msg, int mode, long timeout, boolean use_anycasting)` Deprecated.
`RspList` `MessageDispatcher.castMessage(java.util.Vector dests, Message msg, int mode, long timeout, boolean use_anycasting, RspFilter filter)` Deprecated.
`NotifyingFuture<RspList>` `MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options)`
`NotifyingFuture<RspList>` `MessageDispatcher.castMessageWithFuture(java.util.Vector dests, Message msg, int mode, long timeout, boolean use_anycasting, RspFilter filter)` Deprecated.
`java.lang.Object` `RpcDispatcher.handle(Message req)` Message contains MethodCall.
`java.lang.Object` `RequestHandler.handle(Message msg)`
`java.lang.Object` `MessageDispatcher.handle(Message msg)`
`protected void` `PullPushAdapter.handleMessage(Message msg)` Deprecated. Check whether the message has an identifier.
`protected void` `RequestCorrelator.handleRequest(Message req, RequestCorrelator.Header hdr)` Handle a request msg for this correlator
`protected void` `RequestCorrelator.prepareResponse(Message rsp)`
`void` `ReplicatedTree.receive(Message msg)` Callback.
`void` `ReplicatedHashMap.receive(Message msg)`
`void` `NotificationBus.receive(Message msg)` Deprecated.
`void` `MessageListenerAdapter.receive(Message msg)` Receive message from group.
`void` `DistributedTree.receive(Message msg)`
`void` `DistributedQueue.receive(Message msg)`
`void` `VotingAdapter.receive(Message msg)` Receive the message.
`boolean` `RequestCorrelator.receiveMessage(Message msg)` Handles a message coming from a layer below
`void` `PullPushAdapter.send(Message msg)` Deprecated. Sends a message with no identifier; listener member will get this message on the other group members.
`void` `MessageDispatcher.send(Message msg)` Deprecated.
`void` `PullPushAdapter.send(java.io.Serializable identifier, Message msg)` Deprecated. Sends a message to the group - listeners to this identifier will receive the messages.
`java.lang.Object` `MessageDispatcher.sendMessage(Message msg, int mode, long timeout)` Deprecated. Use `MessageDispatcher.sendMessage(org.jgroups.Message, RequestOptions)` instead
`java.lang.Object` `MessageDispatcher.sendMessage(Message msg, RequestOptions opts)`

`

`<T> NotifyingFuture<T>`

`

`MessageDispatcher.sendMessageWithFuture(Message msg, int mode, long timeout)`
Deprecated.

`

`<T> NotifyingFuture<T>`

`

`MessageDispatcher.sendMessageWithFuture(Message msg, RequestOptions options)`

`void` `RequestCorrelator.sendRequest(long id, java.util.Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)` Sends a request to a group.
`void` `RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll)`
`void` `RequestCorrelator.sendRequest(long id, Message msg, RspCollector coll)` Deprecated.
`void` `RequestCorrelator.sendUnicastRequest(long id, Address target, Message msg, RspCollector coll)` Sends a request to a single destination

Constructors in org.jgroups.blocks with parameters of type Message
`GroupRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options)`
`GroupRequest(Message msg, RequestCorrelator corr, java.util.Collection<Address> targets, RequestOptions options)`
`GroupRequest(Message m, Transport transport, java.util.Collection<Address> mbrs, RequestOptions options)`
`MultiRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options, int expected_mbrs)`
`MultiRequest(Message m, RequestCorrelator corr, java.util.Collection<Address> mbrs, RequestOptions options, int expected_mbrs)`
`MultiRequest(Message m, Transport transport, java.util.Collection<Address> mbrs, RequestOptions options, int expected_mbrs)`
`Request(Message request, RequestCorrelator corr, Transport transport, RequestOptions options)`
`Request(Message request, RequestCorrelator corr, Transport transport, RspFilter filter, int mode, long timeout)` Deprecated.
`UnicastRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options)`
`UnicastRequest(Message m, Transport transport, Address target, RequestOptions options)`

Uses of Message in org.jgroups.blocks.mux

Methods in org.jgroups.blocks.mux with parameters of type Message
`protected GroupRequest` `MuxRpcDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)`
`protected GroupRequest` `MuxMessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)`
`protected void` `MuxRequestCorrelator.prepareResponse(Message rsp)`
`void` `MuxRequestCorrelator.sendRequest(long requestId, java.util.Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)`
`void` `MuxRequestCorrelator.sendUnicastRequest(long id, Address target, Message msg, RspCollector coll)`

Uses of Message in org.jgroups.debug

Methods in org.jgroups.debug with parameters of type Message
`boolean` `Simulator.checkForDropMessage(Message msg, Address dest)`
`boolean` `Simulator.DropMessage.drop(Message msg, Address dest)`
`boolean` `Simulator.receiverDropFault(Message msg, Address src)`
`boolean` `Simulator.senderDropFault(Message msg, Address dest)`

Uses of Message in org.jgroups.demos

Methods in org.jgroups.demos with parameters of type Message
`void` `QuoteServer.receive(Message msg)`
`void` `Draw.receive(Message msg)`

Uses of Message in org.jgroups.demos.wb

Methods in org.jgroups.demos.wb with parameters of type Message
`void` `Whiteboard.receive(Message m)`

Uses of Message in org.jgroups.mux

Methods in org.jgroups.mux with parameters of type Message
`void` `MuxChannel.send(Message msg)` Deprecated.

Uses of Message in org.jgroups.protocols

Fields in org.jgroups.protocols with type parameters of type Message
`protected java.util.List<Message>` `SHUFFLE.down_msgs`
`protected java.util.concurrent.BlockingQueue<Message>` `DAISYCHAIN.forward_queue`
`protected java.util.concurrent.BlockingQueue<Message>` `DAISYCHAIN.send_queue`
`protected java.util.List<Message>` `SHUFFLE.up_msgs`

Methods in org.jgroups.protocols that return Message
`Message` `TransportedVectorTime.getAssociatedMessage()` Returns a message associated with this vector timestamp.
`protected static Message` `TP.readMessage(java.io.DataInputStream instream)`
`Message` `SCOPE.MessageQueue.remove()`

Methods in org.jgroups.protocols that return types with arguments of type Message
`protected static java.util.List<Message>` `TP.readMessageList(java.io.DataInputStream in)`

Methods in org.jgroups.protocols with parameters of type Message
`void` `SCOPE.MessageQueue.add(Message msg)`
`protected void` `RELAY.forwardToCoord(Message msg)` Wraps the message annd sends it to the current coordinator
`protected java.lang.Object` `UFC.handleDownMessage(Event evt, Message msg, Address dest, int length)`
`protected java.lang.Object` `MFC.handleDownMessage(Event evt, Message msg, Address dest, int length)`
`protected abstract java.lang.Object` `FlowControl.handleDownMessage(Event evt, Message msg, Address dest, int length)`
`protected void` `TP.passMessageUp(Message msg, boolean perform_cluster_name_matching, boolean multicast, boolean discard_own_mcast)`
`void` `RELAY.Receiver.receive(Message msg)`
`void` `UNICAST.retransmit(long seqno, Message msg)` Called by AckSenderWindow to resend messages for which no ACK has been received yet
`void` `SMACK.retransmit(long seqno, Message msg, Address dest)`
`void` `TP.Bundler.send(Message msg)`
`protected void` `TUNNEL.send(Message msg, Address dest, boolean multicast)`
`protected void` `TP.send(Message msg, Address dest, boolean multicast)` Serializes and sends a message.
`void` `TransportedVectorTime.setAssociatedMessage(Message owner)` Sets a message associated with this vector timestamp
`protected void` `TP.setSourceAddress(Message msg)` If the sender is null, set our own address.
`protected static void` `TP.writeMessage(Message msg, java.io.DataOutputStream dos, boolean multicast)` This method needs to be synchronized on out_stream when it is called

Method parameters in org.jgroups.protocols with type arguments of type Message
`protected static void` `TP.writeMessageList(Address dest, Address src, java.util.List<Message> msgs, java.io.DataOutputStream dos, boolean multicast)` Write a lits of messages with the same destination and *mostly* the same src addresses.

Uses of Message in org.jgroups.stack

Fields in org.jgroups.stack declared as Message
`static Message` `AckReceiverWindow.TOMBSTONE`

Methods in org.jgroups.stack that return Message
`Message` `NakReceiverWindow.get(long seqno)` Returns the message from xmit_table
`Message` `AckSenderWindow.get(long seqno)`
`Message` `AckSenderWindow.getLowestMessage()` Returns the message with the lowest seqno
`Message` `NakReceiverWindow.remove()`
`Message` `AckReceiverWindow.remove()` Removes a message whose seqno is equal to `next_to_remove`, increments the latter.
`Message` `NakReceiverWindow.remove(boolean acquire_lock, boolean remove_msg)`

Methods in org.jgroups.stack that return types with arguments of type Message
`java.util.List<Message>` `NakReceiverWindow.get(long from, long to)` Returns a list of messages in the range [from ..
`java.util.List<Message>` `NakReceiverWindow.removeMany(java.util.concurrent.atomic.AtomicBoolean processing)` Removes as many messages as possible
`java.util.List<Message>` `NakReceiverWindow.removeMany(java.util.concurrent.atomic.AtomicBoolean processing, boolean remove_msgs, int max_results)` Removes as many messages as possible
`Tuple<java.util.List<Message>,java.lang.Long>` `AckReceiverWindow.removeMany(int max)` Removes as many messages as possible (in sequence, without gaps)
`java.util.List<Message>` `AckReceiverWindow.removeManyAsList(int max)`

Methods in org.jgroups.stack with parameters of type Message
`boolean` `NakReceiverWindow.add(long seqno, Message msg)` Adds a message according to its seqno (sequence number).
`void` `AckSenderWindow.add(long seqno, Message msg)` Adds a new message to the retransmission table.
`boolean` `AckReceiverWindow.add(long seqno, Message msg)` Adds a new message.
`void` `AckMcastSenderWindow.add(long seqno, Message msg, java.util.Vector receivers)` Adds a new message to the hash table.
`byte` `AckReceiverWindow.add2(long seqno, Message msg)` Adds a message if not yet received
`void` `AckSenderWindow.addToMessages(long seqno, Message msg)`
`void` `AckSenderWindow.addToRetransmitter(long seqno, Message msg)`
`void` `AckSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg)`
`void` `AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest)` Retranmit the given msg
`void` `ProtocolStack.send(Message msg)`

Uses of Message in org.jgroups.util

Fields in org.jgroups.util declared as Message
`protected Message[][]` `RetransmitTable.matrix`

Fields in org.jgroups.util with type parameters of type Message
`protected java.util.Collection<Message>` `MyReceiver.msgs`

Methods in org.jgroups.util that return Message
`static Message` `Util.byteBufferToMessage(byte[] buffer, int offset, int length)`
`Message` `RetransmitTable.get(long seqno)`
`protected Message[]` `RetransmitTable.getRow(int index)` Returns a row.
`Message` `RetransmitTable.putIfAbsent(long seqno, Message msg)` Adds a message if the element at the given index is null.
`Message` `RetransmitTable.remove(long seqno)` Removes the message with seqno from the table, nulls the index

Methods in org.jgroups.util that return types with arguments of type Message
`static java.util.List<Message>` `Util.byteBufferToMessageList(byte[] buffer, int offset, int length)`
`java.util.List<Message>` `RetransmitTable.get(long from, long to)`
`java.util.Collection<Message>` `MyReceiver.getMsgs()`

Methods in org.jgroups.util with parameters of type Message
`static short` `Util.getScope(Message msg)`
`static SCOPE.ScopeHeader` `Util.getScopeHeader(Message msg)`
`static Buffer` `Util.messageToByteBuffer(Message msg)`
`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.
`boolean` `RetransmitTable.put(long seqno, Message msg)` Adds a new message to the index computed as a function of seqno
`Message` `RetransmitTable.putIfAbsent(long seqno, Message msg)` Adds a message if the element at the given index is null.
`void` `MyReceiver.receive(Message msg)`
`static void` `Util.setScope(Message msg, short scope)`

Method parameters in org.jgroups.util with type arguments of type Message
`static Buffer` `Util.msgListToByteBuffer(java.util.List<Message> xmit_list)` Marshalls a list of messages.

Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.