public final class MessageMetadata extends UtlListElement implements UtlPool.Item<MessageMetadata>
This class serves as helper class for provider implementations that do not possess native capabilities to transport message metadata elements (sender, flow, sno, ...) natively. The class provides facilities to serialize and deserialize metadata elements to/from a flat wire format for use by the provider implementations to transport the metadata elements across the wire.
| Modifier and Type | Field and Description |
|---|---|
static int |
FIXED_WIRE_LENGTH |
static int |
FIXED_WIRE_LENGTH_V1 |
static int |
FIXED_WIRE_LENGTH_V2 |
static int |
FIXED_WIRE_LENGTH_V3 |
static byte |
V1 |
static byte |
V2 |
static byte |
V3 |
static byte |
VERSION |
count, head, next, prev| Modifier and Type | Method and Description |
|---|---|
MessageMetadata |
acquire()
Acquires the
MessageMetadata preventing it from being
returned to the underlying pool. |
int |
deserialize(ByteBuffer serializedMetadata)
Deserialize contents from a byte buffer
|
void |
dispose()
Dispose off this
MessageMetadata |
IOElasticBuffer |
getBuffer()
Get the backing buffer
The metadata object manipulates its field in place in its backing
buffer returned by this method.
|
static short |
getLatestVersion()
Get the latest metadata version.
|
short |
getMessageChannelId()
Get the message channel id (V1 metadata Field).
|
static short |
getMessageChannelId(ByteBuffer buffer)
Get the message channel id (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageChannelId(ByteBuffer buffer,
int offset)
Get the message channel id (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageChannelId(IOBuffer buffer)
Get the message channel id (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageChannelId(IOBuffer buffer,
int offset)
Get the message channel id (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageChannelId(long addr,
int offset)
Get the message channel id (V1 metadata Field) from a native memory region.
|
static short |
getMessageChannelId(short version,
long addr,
int offset)
Get the message channel id (V1 metadata Field) from a native memory region.
|
String |
getMessageChannelName()
Get the message channel name (V1 metadata Field).
|
static String |
getMessageChannelName(ByteBuffer buffer)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
static String |
getMessageChannelName(ByteBuffer buffer,
int offset)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
static String |
getMessageChannelName(long addr,
int offset)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
XString |
getMessageChannelNameAsRaw()
Get the message channel name (V1 metadata Field).
|
static int |
getMessageChannelNameLength(long addr,
int offset)
Get the message channel name length (V1 metadata Field) in a serialized buffer.
|
static int |
getMessageChannelNameLength(short version,
long addr,
int offset)
Get the message channel name length (V1 metadata Field) in a serialized buffer.
|
static int |
getMessageChannelNamePos(long addr,
int offset)
Get the message channel name offset (V1 metadata Field) in a serialized buffer.
|
static int |
getMessageChannelNamePos(short version,
long addr,
int offset)
Get the message channel name offset (V1 metadata Field) in a serialized buffer.
|
static void |
getMessageChannelNameToRaw(ByteBuffer buffer,
int offset,
XString target)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
static void |
getMessageChannelNameToRaw(ByteBuffer buffer,
XString target)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
static void |
getMessageChannelNameToRaw(IOBuffer buffer,
int offset,
XString target)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
static void |
getMessageChannelNameToRaw(IOBuffer buffer,
XString target)
Get the message channel name (V1 metadata Field) from a serialized buffer.
|
static void |
getMessageChannelNameToRaw(long addr,
int offset,
XString target)
Get the message channel name (V1 metadata Field) from a native memory region.
|
byte |
getMessageEncodingType()
Get the message encoding type (V1 metadata Field).
|
static byte |
getMessageEncodingType(ByteBuffer buffer)
Get the message encoding type (V1 metadata Field) from a serialized buffer.
|
static byte |
getMessageEncodingType(ByteBuffer buffer,
int offset)
Get the message encoding type (V1 metadata Field) from a serialized buffer.
|
static byte |
getMessageEncodingType(long addr,
int offset)
Get the message encoding type (V1 metadata Field) from a serialized buffer.
|
static byte |
getMessageEncodingType(short version,
long addr,
int offset)
Get the message encoding type (V1 metadata Field) from a serialized buffer.
|
int |
getMessageFlow()
Get the message flow (V1 metadata Field).
|
static int |
getMessageFlow(ByteBuffer buffer)
Get the message flow (V1 metadata Field) from a serialized buffer.
|
static int |
getMessageFlow(ByteBuffer buffer,
int offset)
Get the message flow (V1 metadata Field) from a serialized buffer.
|
static int |
getMessageFlow(long addr,
int offset)
Get the message flow (V1 metadata Field) from a serialized buffer.
|
static int |
getMessageFlow(short version,
long addr,
int offset)
Get the message flow (V1 metadata Field) from a serialized buffer.
|
int |
getMessageSender()
Get the message sender (V1 metadata Field).
|
static int |
getMessageSender(ByteBuffer buffer)
Get the message sender (V1 metadata Field) from a serialized buffer
|
static int |
getMessageSender(ByteBuffer buffer,
int offset)
Get the message sender (V1 metadata Field) from a serialized buffer
|
static int |
getMessageSender(long addr,
int offset)
Get the message sender (V1 metadata Field) from a serialized buffer
|
static int |
getMessageSender(short version,
long addr,
int offset)
Get the message sender (V1 metadata Field) from a serialized buffer
|
long |
getMessageSno()
Get the message sequence number (V1 metadata Field).
|
static long |
getMessageSno(ByteBuffer buffer)
Get the message sequence number (V1 metadata Field) from a serialized buffer.
|
static long |
getMessageSno(ByteBuffer buffer,
int offset)
Get the message sequence number (V1 metadata Field) from a serialized buffer.
|
static long |
getMessageSno(long addr,
int offset)
Get the message sequence number (V1 metadata Field) from a serialized buffer.
|
static long |
getMessageSno(short version,
long addr,
int offset)
Get the message sequence number (V1 metadata Field) from a serialized buffer.
|
short |
getMessageViewFactory()
Get the message view factory (V1 metadata Field).
|
static short |
getMessageViewFactory(ByteBuffer buffer)
Get the message view factory (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageViewFactory(ByteBuffer buffer,
int offset)
Get the message view factory (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageViewFactory(long addr,
int offset)
Get the message view factory (V1 metadata Field) from a serialized buffer.
|
static short |
getMessageViewFactory(short version,
long addr,
int offset)
Get the message view factory (V1 metadata Field) from a serialized buffer.
|
short |
getMessageViewType()
Get the message view (V2 metadata Field).
|
static short |
getMessageViewType(ByteBuffer buffer)
Get the message view (V2 metadata Field) from a serialized buffer.
|
static short |
getMessageViewType(ByteBuffer buffer,
int offset)
Get the message view (V2 metadata Field) from a serialized buffer.
|
static short |
getMessageViewType(long addr,
int offset)
Get the message view (V2 metadata Field) from a serialized buffer.
|
static short |
getMessageViewType(short version,
long addr,
int offset)
Get the message view (V2 metadata Field) from a serialized buffer.
|
UtlPool<MessageMetadata> |
getPool()
Implementation of UtlPool.Item#getPool
|
long |
getRequestId()
Get the request id (V3 metadata Field).
|
static long |
getRequestId(ByteBuffer buffer)
Get the request id (V3 metadata Field) from a serialized buffer.
|
static long |
getRequestId(ByteBuffer buffer,
int offset)
Get the request id (V3 metadata Field) from a serialized buffer.
|
static long |
getRequestId(IOBuffer buffer)
Get the request id (V3 metadata Field) from a serialized buffer.
|
static long |
getRequestId(IOBuffer buffer,
int offset)
Get the request id (V3 metadata Field) from a serialized buffer.
|
static long |
getRequestId(long addr,
int offset)
Get the request id (V3 metadata Field) from a serialized buffer.
|
static long |
getRequestId(short version,
long addr,
int offset)
Get the request id (V3 metadata Field) from a serialized buffer.
|
String |
getRequestorId()
Get the requestor id (V1 metadata Field).
|
static String |
getRequestorId(ByteBuffer buffer)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static String |
getRequestorId(ByteBuffer buffer,
int offset)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static String |
getRequestorId(long addr,
int offset)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
XString |
getRequestorIdAsRaw()
Get the requestor id (V1 metadata Field).
|
static void |
getRequestorIdToRaw(ByteBuffer buffer,
int offset,
XString target)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static void |
getRequestorIdToRaw(ByteBuffer buffer,
XString target)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static void |
getRequestorIdToRaw(IOBuffer buffer,
int offset,
XString target)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static void |
getRequestorIdToRaw(IOBuffer buffer,
XString target)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static XString |
getRequestorIdToRaw(long addr,
int offset,
XString target)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
static XString |
getRequestorIdToRaw(short version,
long addr,
int offset,
XString target)
Get the requestor id (V1 metadata Field) from a serialized buffer.
|
int |
getSerializedLength()
Get the serialized length of the message metadata elements.
|
static int |
getSerializedLength(short version,
ByteBuffer buffer)
Get the serialized length of the message metadata wire format for a given wire format version.
|
static int |
getSerializedLength(short version,
ByteBuffer buffer,
int offset)
Get the serialized length of the message metadata wire format for a given wire format version.
|
static int |
getSerializedLength(short version,
long addr,
int offset)
Get the serialized length of the message metadata wire format for a given wire format version.
|
short |
getVersion()
Get the metadata version (V1 metadata Field).
|
static short |
getVersion(long addr,
int offset)
Get the metadata version from a serialized metadata wire block.
|
MessageMetadata |
init()
Implementation of UtlPool.Item#init
|
void |
serializeV1(byte encodingType,
short vfid,
int sender,
int flow,
long sno,
short channelId,
XString channelName)
Serialize version 1 metadata content
|
static int |
serializeV1(byte encodingType,
short vfid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
IOElasticBuffer buffer)
Serialize version 1 metadata content
|
void |
serializeV2(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName)
Serialize version 2 metadata content
|
static int |
serializeV2(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
ByteBuffer buffer,
int offset)
Serialize version 2 metadata content
|
static int |
serializeV2(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
IOElasticBuffer buffer)
Serialize version 2 metadata content
|
void |
serializeV3(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
long requestId,
XString requestorId)
Serialize version 2 metadata content
|
static int |
serializeV3(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
long requestId,
XString requestorId,
ByteBuffer buffer,
int offset)
Serialize version 3 metadata content
|
static int |
serializeV3(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
long requestId,
XString requestorId,
IOElasticBuffer buffer)
Serialize version 2 metadata content
|
MessageMetadata |
setPool(UtlPool<MessageMetadata> pool)
Implementation of UtlPool.Item#setPool
|
String |
toString()
Return a string representation of the object.
|
static String |
toString(long addr,
int offset)
Return a string representation of the object.
|
static void |
tryWrap(long serializedMetadata,
int serializedMetadataLength)
Try to wrap a metadata object around a memory region
|
int |
wrap(IOBuffer serializedMetadata)
Wrap a metadata object around an IO buffer.
|
int |
wrap(IOBuffer serializedMetadata,
int serializedMetadataLength)
Wrap a metadata object around an IO buffer.
|
count, insertAfter, insertBefore, isLinked, next, previous, unlink, wipepublic static final int FIXED_WIRE_LENGTH_V1
public static final int FIXED_WIRE_LENGTH_V2
public static final int FIXED_WIRE_LENGTH_V3
public static final int FIXED_WIRE_LENGTH
public static final byte V1
public static final byte V2
public static final byte V3
public static final byte VERSION
public static final short getLatestVersion()
public static final int getSerializedLength(short version,
ByteBuffer buffer,
int offset)
public static final int getSerializedLength(short version,
ByteBuffer buffer)
public static final int getSerializedLength(short version,
long addr,
int offset)
public static final short getVersion(long addr,
int offset)
public final short getVersion()
public static final byte getMessageEncodingType(ByteBuffer buffer, int offset)
public static final byte getMessageEncodingType(ByteBuffer buffer)
public static final byte getMessageEncodingType(short version,
long addr,
int offset)
public static final byte getMessageEncodingType(long addr,
int offset)
public final byte getMessageEncodingType()
public static final short getMessageViewFactory(ByteBuffer buffer, int offset)
public static final short getMessageViewFactory(ByteBuffer buffer)
public static final short getMessageViewFactory(short version,
long addr,
int offset)
public static final short getMessageViewFactory(long addr,
int offset)
public final short getMessageViewFactory()
public static final short getMessageViewType(ByteBuffer buffer, int offset)
public static final short getMessageViewType(ByteBuffer buffer)
public static final short getMessageViewType(short version,
long addr,
int offset)
public static final short getMessageViewType(long addr,
int offset)
public final short getMessageViewType()
public static final int getMessageSender(ByteBuffer buffer, int offset)
public static final int getMessageSender(ByteBuffer buffer)
public static final int getMessageSender(short version,
long addr,
int offset)
public static final int getMessageSender(long addr,
int offset)
public final int getMessageSender()
public static final int getMessageFlow(ByteBuffer buffer, int offset)
public static final int getMessageFlow(ByteBuffer buffer)
public static final int getMessageFlow(short version,
long addr,
int offset)
public static final int getMessageFlow(long addr,
int offset)
public final int getMessageFlow()
public static final long getMessageSno(ByteBuffer buffer, int offset)
public static final long getMessageSno(ByteBuffer buffer)
public static final long getMessageSno(short version,
long addr,
int offset)
public static final long getMessageSno(long addr,
int offset)
public final long getMessageSno()
public static final short getMessageChannelId(IOBuffer buffer, int offset)
public static final short getMessageChannelId(IOBuffer buffer)
public static final short getMessageChannelId(ByteBuffer buffer, int offset)
public static final short getMessageChannelId(ByteBuffer buffer)
public static final short getMessageChannelId(short version,
long addr,
int offset)
public static final short getMessageChannelId(long addr,
int offset)
public final short getMessageChannelId()
public static final long getRequestId(IOBuffer buffer, int offset)
public static final long getRequestId(IOBuffer buffer)
public static final long getRequestId(ByteBuffer buffer, int offset)
public static final long getRequestId(ByteBuffer buffer)
public static final long getRequestId(short version,
long addr,
int offset)
public static final long getRequestId(long addr,
int offset)
public final long getRequestId()
public static final String getMessageChannelName(ByteBuffer buffer, int offset)
public static final String getMessageChannelName(ByteBuffer buffer)
public static final String getMessageChannelName(long addr, int offset)
public static final void getMessageChannelNameToRaw(IOBuffer buffer, int offset, XString target)
public static final void getMessageChannelNameToRaw(IOBuffer buffer, XString target)
public static final void getMessageChannelNameToRaw(ByteBuffer buffer, int offset, XString target)
public static final void getMessageChannelNameToRaw(ByteBuffer buffer, XString target)
public static final void getMessageChannelNameToRaw(long addr,
int offset,
XString target)
public static final int getMessageChannelNamePos(short version,
long addr,
int offset)
public static final int getMessageChannelNamePos(long addr,
int offset)
public static final int getMessageChannelNameLength(short version,
long addr,
int offset)
public static final int getMessageChannelNameLength(long addr,
int offset)
public final XString getMessageChannelNameAsRaw()
public final String getMessageChannelName()
public static final String getRequestorId(ByteBuffer buffer, int offset)
public static final String getRequestorId(ByteBuffer buffer)
public static final String getRequestorId(long addr, int offset)
public static final void getRequestorIdToRaw(IOBuffer buffer, int offset, XString target)
public static final void getRequestorIdToRaw(IOBuffer buffer, XString target)
public static final void getRequestorIdToRaw(ByteBuffer buffer, int offset, XString target)
public static final void getRequestorIdToRaw(ByteBuffer buffer, XString target)
public static final XString getRequestorIdToRaw(short version, long addr, int offset, XString target)
public static final XString getRequestorIdToRaw(long addr, int offset, XString target)
public final XString getRequestorIdAsRaw()
public final String getRequestorId()
public final IOElasticBuffer getBuffer()
The metadata object manipulates its field in place in its backing buffer returned by this method. The caller can call this method to get the buffer with the latest copy of its contents at any time during the lifecycle of the metadata object.
public static final int serializeV1(byte encodingType,
short vfid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
IOElasticBuffer buffer)
public final void serializeV1(byte encodingType,
short vfid,
int sender,
int flow,
long sno,
short channelId,
XString channelName)
public static final int serializeV2(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
ByteBuffer buffer,
int offset)
public static final int serializeV2(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
IOElasticBuffer buffer)
public final void serializeV2(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName)
public static final int serializeV3(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
long requestId,
XString requestorId,
ByteBuffer buffer,
int offset)
public static final int serializeV3(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
long requestId,
XString requestorId,
IOElasticBuffer buffer)
public final void serializeV3(byte encodingType,
short vfid,
short vid,
int sender,
int flow,
long sno,
short channelId,
XString channelName,
long requestId,
XString requestorId)
public static final void tryWrap(long serializedMetadata,
int serializedMetadataLength)
throws SmaException
serializedMetadata - Contains the serialized form of the metadataserializedMetadataLength - The length to wrapSmaExceptionpublic final int wrap(IOBuffer serializedMetadata, int serializedMetadataLength) throws SmaException
serializedMetadata - Contains the serialized form of the metadataserializedMetadataLength - The length to wrap
This method wraps a message metadata object around a supplied IO buffer. The method assumes that the serialized form of the metadata starts at the beginning of the IO buffer and the number of valid bytes in the buffer is equal to the length of the IO buffer.
SmaExceptionpublic final int wrap(IOBuffer serializedMetadata) throws SmaException
serializedMetadata - Contains the serialized form of the metadata
This method wraps a message metadata object around a supplied IO buffer. The method assumes that the serialized form of the metadata starts at the beginning of the IO buffer and the number of valid bytes in the buffer is equal to the length of the IO buffer.
SmaExceptionpublic final int deserialize(ByteBuffer serializedMetadata) throws SmaException
SmaExceptionpublic final int getSerializedLength()
This method returns the serialized length of the message metadata elements. This length is governed by the metadata wire format version. /P>
public final MessageMetadata acquire()
MessageMetadata preventing it from being
returned to the underlying pool.MessageMetadata for invocation chaining.public final void dispose()
MessageMetadatapublic final MessageMetadata init()
init in interface UtlPool.Item<MessageMetadata>public final MessageMetadata setPool(UtlPool<MessageMetadata> pool)
setPool in interface UtlPool.Item<MessageMetadata>public final UtlPool<MessageMetadata> getPool()
getPool in interface UtlPool.Item<MessageMetadata>UtlPool.Item.setPool(com.neeve.util.UtlPool<T>)public static final String toString(long addr, int offset)
Copyright © 2019 N5 Technologies, Inc. All Rights Reserved.