com.neeve.rog
Interface IRogRawMessage

All Superinterfaces:

IRogMessage, IRogMetadata, IRogNode, IStoreObject, MapMessageView, MessageView, com.neeve.util.UtlReferenceTracker.HasReferenceTracker

public interface IRogRawMessage
extends IRogMessage

An IRogRawMessage encapsulates an opaque payload.

Nested Class Summary

Nested classes/interfaces inherited from interface com.neeve.rog.IRogNode

IRogNode.PoolingListener

Nested classes/interfaces inherited from interface com.neeve.ods.IStoreObject

IStoreObject.EncodingType

Field Summary

Fields inherited from interface com.neeve.sma.MessageView

ENCODING_TYPE_CUSTOM, ENCODING_TYPE_JSON, ENCODING_TYPE_PROTOBUF, ENCODING_TYPE_XBUF, NEXT_FREE_ENCODING_TYPE

Method Summary

ByteBuffer	getRawMessage() Returns the raw message wrapped by this message.
void	setRawMessage(ByteBuffer message) Set the underlying raw message as an opaque blob.

Methods inherited from interface com.neeve.rog.IRogNode

deserializeFromJson, deserializeFromProtobuf, dispose, dump, getAttachment, getIsPriority, getIsReadOnly, getMetadata, getParent, getPoolingListener, getType, metadataToJsonString, serializeToJson, serializeToProtobuf, setAsInboundMessage, setAsInternal, setAsLastTransaction, setAsMessage, setAsOutboundMessage, setAsPriority, setAsReadOnly, setAsReplayedMessage, setAttachment, setInMsgsInTransaction, setOutMsgsInTransaction, setParentId, setPoolingListener, setTransactionInSequenceNumber, setTransactionOutSequenceNumber

Methods inherited from interface com.neeve.ods.IStoreObject

acquire, deserialize, deserializeMetadata, deserializeMetadata, ensureId, getBinding, getCheckpointVersion, getContentEncodingType, getId, getOfid, getOwnershipCount, getStableTransactionId, getTransactionId, serialize, serializeMetadata, setBinding, setCheckpointVersion, setFieldValue, setId, setStableTransactionId, setTransactionId

Methods inherited from interface com.neeve.sma.MapMessageView

getMessageReflector

Methods inherited from interface com.neeve.sma.MessageView

acquire, deserializeFromByteArray, deserializeFromByteBuffer, deserializeFromPacket, getCreateTs, getMessage, getMessageBus, getMessageBusAsRaw, getMessageChannel, getMessageChannelAsRaw, getMessageEncodingType, getMessageFlow, getMessageKey, getMessageKeyAsRaw, getMessageSender, getMessageSequenceNumber, getOriginTs, getOutTs, getOwnershipCount, getPostDeserializeTs, getPostProcessingTs, getPostSerializeTs, getPostWireTs, getPreDeserializeTs, getPreProcessingTs, getPreSerializeTs, getPreWireTs, getReceiveTs, getSendTs, getTag, getVfid, isPossibleDuplicate, serializeToByteArray, serializeToByteBuffer, serializeToPacket, setCreateTs, setMessageBus, setMessageBusAsRaw, setMessageChannel, setMessageChannelAsRaw, setMessageFlow, setMessageKey, setMessageKeyAsRaw, setMessageSender, setMessageSequenceNumber, setOriginTs, setOutTs, setPossibleDuplicate, setPostDeserializeTs, setPostProcessingTs, setPostSerializeTs, setPostWireTs, setPreDeserializeTs, setPreProcessingTs, setPreSerializeTs, setPreWireTs, setReceiveTs, setSendTs, setTag, sync

Methods inherited from interface com.neeve.util.UtlReferenceTracker.HasReferenceTracker

referenceTracker

Methods inherited from interface com.neeve.rog.IRogMetadata

getGraphId, getInMsgsInTransaction, getIsInboundMessage, getIsInternal, getIsLastTransaction, getIsMessage, getIsOutboundMessage, getIsReplayedMessage, getMessageBus, getMessageChannel, getMessageFlow, getMessageKey, getMessageSender, getMessageSequenceNumber, getOutMsgsInTransaction, getOutTs, getParentId, getPreProcessingTs, getTransactionInSequenceNumber, getTransactionOutSequenceNumber, isPossibleDuplicate, metadataToJsonString, metadataToString

Method Detail

setRawMessage

void setRawMessage(ByteBuffer message)

Set the underlying raw message as an opaque blob. The entire contents of the buffer are considered the payload, i.e. the caller should assume that Buffer.clear() will be called on the passed in buffer.

Parameters:

message - The raw message bytes.

getRawMessage

ByteBuffer getRawMessage()

Returns the raw message wrapped by this message.

Returns:

The raw message wrapped by this message.