Class LongMessage
java.lang.Object
org.jgroups.BaseMessage
org.jgroups.LongMessage
- All Implemented Interfaces:
Constructable<Message>, Message, SizeStreamable, Streamable
Message with a long as payload. Can be used to send int- or long values, without having to resort to
BytesMessage.- Since:
- 5.0.0
- Author:
- Bela Ban
-
Nested Class Summary
Nested classes/interfaces inherited from interface Message
Message.Flag, Message.TransientFlag -
Field Summary
FieldsFields inherited from class BaseMessage
dest, flags, headers, sender, transient_flagsFields inherited from interface Message
BYTES_MSG, COMPOSITE_MSG, EARLYBATCH_MSG, EMPTY_MSG, FRAG_MSG, LONG_MSG, NIO_MSG, OBJ_MSG -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected MessagecopyPayload(Message copy) Copies the payloadcreate()Creates an instance of the class implementing this interfacebyte[]getArray()Returns a reference to the payload (byte array).intReturns the length of the byte[] array payload.<T> TGets an object from the payload.intReturns the offset of the byte[] array at which user data starts.shortgetType()Returns the type of the message, e.g.longgetValue()booleanhasArray()Returns true if this message has a byte[] array as payload (even if it's null!), false otherwisebooleanReturns true if the message has a payload, e.g.protected intvoidreadPayload(DataInput in) setArray(byte[] b, int o, int l) Sets the byte array in a message.
Throws an exception if the message does not have a byte[] array payload (Message.hasArray()is false).
Note that this is a convenience method, as most messages are of typeBytesMessage.Sets the byte array in a message.
Throws an exception if the message does not have a byte[] array payload (Message.hasArray()is false).
Note that this is a convenience method, as most messages are of typeBytesMessage.Sets the valuesetValue(long v) toString()voidwritePayload(DataOutput out) Methods inherited from class BaseMessage
clearFlag, clearFlag, clearHeaders, copy, createHeaders, getDest, getFlags, getHeader, getHeaders, getNumHeaders, getPayload, getSrc, headers, headers, isFlagSet, isFlagSet, printHeaders, putHeader, putHeader, putHeaderIfAbsent, readFrom, serializedSize, setDest, setFlag, setFlag, setFlag, setFlagIfAbsent, setPayload, setSrc, size, sizeNoAddrs, writeTo, writeToNoAddrs
-
Field Details
-
value
protected long value
-
-
Constructor Details
-
LongMessage
public LongMessage() -
LongMessage
-
-
Method Details
-
getValue
public long getValue() -
setValue
-
getType
public short getType()Description copied from interface:MessageReturns the type of the message, e.g. BYTES_MSG, OBJ_MSG etc -
hasPayload
public boolean hasPayload()Description copied from interface:MessageReturns true if the message has a payload, e.g. a byte[] array in aBytesMessageor an object in anObjectMessage. This is more generic thanMessage.hasArray(), as it is not just applicable to a byte array.- Returns:
- True if the message has a payload
-
hasArray
public boolean hasArray()Description copied from interface:MessageReturns true if this message has a byte[] array as payload (even if it's null!), false otherwise -
getArray
public byte[] getArray()Description copied from interface:MessageReturns a reference to the payload (byte array). Note that this array should not be modified as we do not copy the array on copy() or clone(): the array of the copied message is simply a reference to the old array.
Even if offset and length are used: we return the entire array, not a subset.
Throws an exception if the message does not have a byte[] array payload (Message.hasArray()is false).
Note that this is a convenience method, as most messages are of typeBytesMessage. It is recommended to downcast aMessageto the correct subtype and use the methods available there to get/set the payload. -
getOffset
public int getOffset()Description copied from interface:MessageReturns the offset of the byte[] array at which user data starts. Throws an exception if the message does not have a byte[] array payload (ifMessage.hasArray()is false).
Note that this is a convenience method, as most messages are of typeBytesMessage. -
getLength
public int getLength()Description copied from interface:MessageReturns the length of the byte[] array payload. If the message does not have a byte[] array payload (Message.hasArray()is false), then the serialized size may be returned, or an implementation may choose to throw an exception -
setArray
Description copied from interface:MessageSets the byte array in a message.
Throws an exception if the message does not have a byte[] array payload (Message.hasArray()is false).
Note that this is a convenience method, as most messages are of typeBytesMessage. It is recommended to downcast aMessageto the correct subtype and use the methods available there to get/set the payload. -
setArray
Description copied from interface:MessageSets the byte array in a message.
Throws an exception if the message does not have a byte[] array payload (Message.hasArray()is false).
Note that this is a convenience method, as most messages are of typeBytesMessage. It is recommended to downcast aMessageto the correct subtype and use the methods available there to get/set the payload. -
getObject
public <T> T getObject()Description copied from interface:MessageGets an object from the payload. If the payload is a byte[] array (e.g. as inBytesMessage), an attempt to de-serialize the array into an object is made, and the object returned.
If the payload is an object (e.g. as is the case inObjectMessage), the object will be returned directly. -
setObject
Sets the value- Parameters:
obj- Has to be a Number (int or long)
-
create
Description copied from interface:ConstructableCreates an instance of the class implementing this interface- Returns:
- Supplier
-
copyPayload
Description copied from class:BaseMessageCopies the payload- Overrides:
copyPayloadin classBaseMessage
-
writePayload
- Throws:
IOException
-
readPayload
- Throws:
IOExceptionClassNotFoundException
-
payloadSize
protected int payloadSize()- Specified by:
payloadSizein classBaseMessage
-
toString
- Overrides:
toStringin classBaseMessage
-