Uses of Class
org.jgroups.Message
Packages that use Message
Package
Description
Provides top-level public JGroups classes such as Channel, Message, etc.
Provides building blocks that are layered on top of channels.
Provides demonstrations of JGroups functionality.
A distributed whiteboard applet implemented using JGroups.
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
Support for managing protocol stacks.
Provides useful functionality which cannot be assigned to any particular other package.
-
Uses of Message in org.jgroups
Methods in org.jgroups that return MessageModifier and TypeMethodDescriptionMessage.copy()Message.copy(boolean copy_buffer) Create a copy of the message.Message.makeReply()Methods in org.jgroups with parameters of type MessageModifier and TypeMethodDescriptionvoidvoidCalled when a message is received.voidabstract voidSends a message to a (unicast) destination.voidSends a message through the protocol stack.void -
Uses of Message in org.jgroups.auth
Methods in org.jgroups.auth with parameters of type MessageModifier and TypeMethodDescriptionabstract booleanAuthToken.authenticate(AuthToken token, Message msg) This method should be implemented to perform the actual authentication of joining members.booleanFixedMembershipToken.authenticate(AuthToken token, Message msg) booleanMD5Token.authenticate(AuthToken token, Message msg) booleanSimpleToken.authenticate(AuthToken token, Message msg) booleanX509Token.authenticate(AuthToken token, Message msg) -
Uses of Message in org.jgroups.blocks
Fields in org.jgroups.blocks declared as MessageMethods in org.jgroups.blocks with parameters of type MessageModifier and TypeMethodDescriptionvoidMessageDispatcher.castMessage(Vector dests, long req_id, Message msg, RspCollector coll) Multicast a message request to all members indestsand receive responses via the RspCollector interface.MessageDispatcher.castMessage(Vector dests, Message msg, int mode, long timeout) MessageDispatcher.castMessage(Vector dests, Message msg, int mode, long timeout, boolean use_anycasting) Cast a message to all members, and wait formoderesponses.MessageDispatcher.castMessage(Vector dests, Message msg, int mode, long timeout, boolean use_anycasting, RspFilter filter) RpcDispatcher.castMessage(Vector dests, Message msg, int mode, long timeout) Message contains MethodCall.protected voidPullPushAdapter.handleMessage(Message msg) Deprecated.Check whether the message has an identifier.protected voidRequestCorrelator.handleRequest(Message req, RequestCorrelator.Header hdr) Handle a request msg for this correlatorvoidDeprecated.voidvoidvoidReceive message from group.voidvoidvoidDeprecated.voidCallback.voidReceive the message.booleanRequestCorrelator.receiveMessage(Message msg) Handles a message coming from a layer belowvoidvoidPullPushAdapter.send(Serializable identifier, Message msg) Deprecated.Sends a message to the group - listeners to this identifier will receive the messages.voidDeprecated.Sends a message with no identifier; listener member will get this message on the other group members.MessageDispatcher.sendMessage(Message msg, int mode, long timeout) Sends a message to a single member (destination = msg.dest) and returns the response.RpcDispatcher.sendMessage(Message msg, int mode, long timeout) voidRequestCorrelator.sendRequest(long id, List<Address> dest_mbrs, Message msg, RspCollector coll) voidRequestCorrelator.sendRequest(long id, List<Address> dest_mbrs, Message msg, RspCollector coll, boolean use_anycasting) Send a request to a group.voidRequestCorrelator.sendRequest(long id, Message msg, RspCollector coll) Helper method forRequestCorrelator.sendRequest(long,List,Message,RspCollector).Constructors in org.jgroups.blocks with parameters of type MessageModifierConstructorDescriptionGroupRequest(Message m, RequestCorrelator corr, Vector<Address> members, int rsp_mode) GroupRequest(Message m, RequestCorrelator corr, Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs) GroupRequest(Message m, Transport transport, Vector<Address> members, int rsp_mode) GroupRequest(Message m, Transport transport, Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs) -
Uses of Message in org.jgroups.demos
Methods in org.jgroups.demos with parameters of type Message -
Uses of Message in org.jgroups.demos.wb
Methods in org.jgroups.demos.wb with parameters of type Message -
Uses of Message in org.jgroups.jmx
Methods in org.jgroups.jmx with parameters of type Message -
Uses of Message in org.jgroups.mux
Methods in org.jgroups.mux with parameters of type Message -
Uses of Message in org.jgroups.protocols
Methods in org.jgroups.protocols that return MessageModifier and TypeMethodDescriptionTransportedVectorTime.getAssociatedMessage()Returns a message associated with this vector timestamp.Methods in org.jgroups.protocols with parameters of type MessageModifier and TypeMethodDescriptionvoidBasicTCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast) voidLOOPBACK.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast) voidSHARED_LOOPBACK.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast) abstract voidTP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast) voidTUNNEL.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast) voidUDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast) voidBasicTCP.postUnmarshallingList(Message msg, Address dest, boolean multicast) voidLOOPBACK.postUnmarshallingList(Message msg, Address dest, boolean multicast) voidSHARED_LOOPBACK.postUnmarshallingList(Message msg, Address dest, boolean multicast) abstract voidTP.postUnmarshallingList(Message msg, Address dest, boolean multicast) voidTUNNEL.postUnmarshallingList(Message msg, Address dest, boolean multicast) voidUDP.postUnmarshallingList(Message msg, Address dest, boolean multicast) voidSMACK.retransmit(long seqno, Message msg, Address dest) voidUNICAST.retransmit(long seqno, Message msg) Called by AckSenderWindow to resend messages for which no ACK has been received yetprotected voidJMS.sendMessage(Message msg) Publish message in the JMS topic.voidTransportedVectorTime.setAssociatedMessage(Message owner) Sets a message associated with this vector timestamp -
Uses of Message in org.jgroups.stack
Fields in org.jgroups.stack declared as MessageModifier and TypeFieldDescriptionstatic final MessageNakReceiverWindow.NULL_MSGdummy for null values: ConcurrentHashMap doesn't allow null valuesMethods in org.jgroups.stack that return MessageModifier and TypeMethodDescriptionNakReceiverWindow.get(long seqno) Returns the message from xmit_tableAckSenderWindow.getLowestMessage()Returns the message with the lowest seqnoAckReceiverWindow.remove()Removes a message whose seqno is equal tonext_to_remove, increments the latter.NakReceiverWindow.remove()AckReceiverWindow.removeOOBMessage()NakReceiverWindow.removeOOBMessage()Methods in org.jgroups.stack with parameters of type MessageModifier and TypeMethodDescriptionvoidAdds a new message to the hash table.booleanAdds a new message.voidAdds a new message to the retransmission table.booleanAdds a message according to its seqno (sequence number).voidAckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest) Retranmit the given msgvoidAckSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg) void -
Uses of Message in org.jgroups.util
Methods in org.jgroups.util that return MessageModifier and TypeMethodDescriptionstatic MessageUtil.byteBufferToMessage(byte[] buffer, int offset, int length) Methods in org.jgroups.util that return types with arguments of type MessageModifier and TypeMethodDescriptionUtil.byteBufferToMessageList(byte[] buffer, int offset, int length) Methods in org.jgroups.util with parameters of type MessageModifier and TypeMethodDescriptionstatic BufferUtil.messageToByteBuffer(Message msg) static StringUtil.printMessage(Message msg) Tries to read an object from the message's buffer and prints itstatic StringUtil.printMethodCall(Message msg) Tries to read aMethodCallobject from the message's buffer and prints it.Method parameters in org.jgroups.util with type arguments of type MessageModifier and TypeMethodDescriptionstatic BufferUtil.msgListToByteBuffer(List<Message> xmit_list) Marshalls a list of messages.