com.neeve.sma
Class RawMessageViewImpl

java.lang.Object
  com.neeve.util.UtlListElement
      com.neeve.sma.MessageViewImpl
          com.neeve.sma.RawMessageViewImpl

All Implemented Interfaces:

MessageView, com.neeve.util.UtlReferenceTracker.HasReferenceTracker

public final class RawMessageViewImpl
extends MessageViewImpl

Implements the raw message view.

Field Summary

Fields inherited from class com.neeve.util.UtlListElement

count, head, next, prev

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

RawMessageViewImpl	deserializeFromByteArray(byte[] array) Implementation of MessageView.deserializeFromByteArray(byte[])
RawMessageViewImpl	deserializeFromByteBuffer(ByteBuffer buffer) Implementation of MessageView.deserializeFromByteBuffer(java.nio.ByteBuffer)
RawMessageViewImpl	deserializeFromPacket(PktPacket packet) Implementation of MessageView.deserializeFromPacket(com.neeve.pkt.PktPacket)
long	getCreateTs() Implementation of MessageView.getCreateTs()
String	getMessageBus() Implementation of MessageView.getMessageBus()
com.neeve.raw.RawString	getMessageBusAsRaw() Implementation of MessageView.getMessageBusAsRaw()
String	getMessageChannel() Implementation of MessageView.getMessageChannel()
com.neeve.raw.RawString	getMessageChannelAsRaw() Implementation of MessageView.getMessageChannelAsRaw()
int	getMessageFlow() Implementation of MessageView.getMessageFlow()
String	getMessageKey() Implementation of MessageView.getMessageKey()
com.neeve.raw.RawString	getMessageKeyAsRaw() Implementation of MessageView.getMessageKeyAsRaw()
int	getMessageSender() Implementation of MessageView.getMessageSender()
long	getMessageSequenceNumber() Implementation of MessageView.getMessageSequenceNumber()
long	getOriginTs() Implementation of MessageView.getOriginTs()
long	getOutTs() Implementation of MessageView.getOutTs()
long	getPostDeserializeTs() Implementation of MessageView.getPostDeserializeTs()
long	getPostProcessingTs() Implementation of MessageView.getPostProcessingTs()
long	getPostSerializeTs() Implementation of MessageView.getPostSerializeTs()
long	getPostWireTs() Implementation of MessageView.getPostWireTs()
long	getPreDeserializeTs() Implementation of MessageView.getPreDeserializeTs()
long	getPreProcessingTs() Implementation of MessageView.getPreProcessingTs()
long	getPreSerializeTs() Implementation of MessageView.getPreSerializeTs()
long	getPreWireTs() Implementation of MessageView.getPreWireTs()
long	getReceiveTs() Implementation of MessageView.getReceiveTs()
long	getSendTs() Implementation of MessageView.getSendTs()
boolean	isPossibleDuplicate() Implementation of MessageView.isPossibleDuplicate()
byte[]	serializeToByteArray() Implementation of MessageView.serializeToByteArray()
ByteBuffer	serializeToByteBuffer() Implementation of MessageView.serializeToByteBuffer()
PktPacket	serializeToPacket() Implementation of MessageView.serializeToPacket()
MessageView	setCreateTs(long ts) Implementation of MessageView.setCreateTs(long)
MessageView	setMessageBus(String name) Implementation of MessageView.setMessageBus(java.lang.String)
MessageView	setMessageBusAsRaw(com.neeve.raw.RawString bus) Implementation of MessageView.setMessageBusAsRaw(com.neeve.raw.RawString)
MessageView	setMessageChannel(String name) Implementation of MessageView.setMessageChannel(java.lang.String)
MessageView	setMessageChannelAsRaw(com.neeve.raw.RawString channel) Implementation of MessageView.setMessageChannelAsRaw(com.neeve.raw.RawString)
MessageView	setMessageFlow(int flow) Implementation of MessageView.setMessageFlow(int)
MessageView	setMessageKey(String key) Implementation of MessageView.setMessageKey(java.lang.String)
MessageView	setMessageKeyAsRaw(com.neeve.raw.RawString key) Implementation of MessageView.setMessageKey(java.lang.String)
MessageView	setMessageSender(int sender) Implementation of MessageView.setMessageSender(int)
MessageView	setMessageSequenceNumber(long sno) Implementation of MessageView.setMessageSequenceNumber(long)
MessageView	setOriginTs(long ts) Implementation of MessageView.setOriginTs(long)
MessageView	setOutTs(long ts) Implementation of MessageView.setOutTs(long)
MessageView	setPossibleDuplicate() Implementation of MessageView.setPossibleDuplicate()
MessageView	setPostDeserializeTs(long ts) Implementation of MessageView.setPostDeserializeTs(long)
MessageView	setPostProcessingTs(long ts) Implementation of MessageView.setPostProcessingTs(long)
MessageView	setPostSerializeTs(long ts) Implementation of MessageView.setPostSerializeTs(long)
MessageView	setPostWireTs(long ts) Implementation of MessageView.setPostWireTs(long)
MessageView	setPreDeserializeTs(long ts) Implementation of MessageView.setPreDeserializeTs(long)
MessageView	setPreProcessingTs(long ts) Implementation of MessageView.setPreProcessingTs(long)
MessageView	setPreSerializeTs(long ts) Implementation of MessageView.setPreSerializeTs(long)
MessageView	setPreWireTs(long ts) Implementation of MessageView.setPreWireTs(long)
MessageView	setReceiveTs(long ts) Implementation of MessageView.setReceiveTs(long)
MessageView	setSendTs(long ts) Implementation of MessageView.setSendTs(long)
void	sync() Implementation of MessageView.sync()

Methods inherited from class com.neeve.sma.MessageViewImpl

acquire, dispose, getMessage, getMessageEncodingType, getOwnershipCount, getTag, getType, getVfid, referenceTracker, setTag, toString

Methods inherited from class com.neeve.util.UtlListElement

count, insertAfter, insertBefore, isLinked, next, previous, unlink, wipe

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

setMessageBus

public final MessageView setMessageBus(String name)

Implementation of MessageView.setMessageBus(java.lang.String)

Parameters:

name - The message bus name to set.

Returns:

Returns this for invocation chaining.

getMessageBus

public final String getMessageBus()

Implementation of MessageView.getMessageBus()

setMessageBusAsRaw

public final MessageView setMessageBusAsRaw(com.neeve.raw.RawString bus)

Implementation of MessageView.setMessageBusAsRaw(com.neeve.raw.RawString)

Parameters:

bus - The message bus to set.

Returns:

Returns this for invocation chaining.

getMessageBusAsRaw

public final com.neeve.raw.RawString getMessageBusAsRaw()

Implementation of MessageView.getMessageBusAsRaw()

setMessageChannel

public final MessageView setMessageChannel(String name)

Implementation of MessageView.setMessageChannel(java.lang.String)

Parameters:

name - The message channel name to set.

Returns:

Returns this for invocation chaining.

getMessageChannel

public final String getMessageChannel()

Implementation of MessageView.getMessageChannel()

setMessageChannelAsRaw

public final MessageView setMessageChannelAsRaw(com.neeve.raw.RawString channel)

Implementation of MessageView.setMessageChannelAsRaw(com.neeve.raw.RawString)

Parameters:

channel - The message channel to set.

Returns:

Returns this for invocation chaining.

getMessageChannelAsRaw

public final com.neeve.raw.RawString getMessageChannelAsRaw()

Implementation of MessageView.getMessageChannelAsRaw()

setMessageKey

public final MessageView setMessageKey(String key)

Implementation of MessageView.setMessageKey(java.lang.String)

Parameters:

key - The message key to set.

Returns:

Returns this for invocation chaining.

getMessageKey

public final String getMessageKey()

Implementation of MessageView.getMessageKey()

setMessageKeyAsRaw

public final MessageView setMessageKeyAsRaw(com.neeve.raw.RawString key)

Implementation of MessageView.setMessageKey(java.lang.String)

Parameters:

key - The message key to set.

Returns:

Returns this for invocation chaining.

getMessageKeyAsRaw

public final com.neeve.raw.RawString getMessageKeyAsRaw()

Implementation of MessageView.getMessageKeyAsRaw()

setMessageSender

public final MessageView setMessageSender(int sender)

Implementation of MessageView.setMessageSender(int)

Parameters:

sender - The message sender to set

Returns:

Returns this for invocation chaining.

getMessageSender

public final int getMessageSender()

Implementation of MessageView.getMessageSender()

setMessageFlow

public final MessageView setMessageFlow(int flow)

Implementation of MessageView.setMessageFlow(int)

Parameters:

flow - The message flow to set.

Returns:

Returns this for invocation chaining.

getMessageFlow

public final int getMessageFlow()

Implementation of MessageView.getMessageFlow()

setMessageSequenceNumber

public final MessageView setMessageSequenceNumber(long sno)

Implementation of MessageView.setMessageSequenceNumber(long)

Parameters:

sno - The sequence number to set.

Returns:

Returns this for invocation chaining.

getMessageSequenceNumber

public final long getMessageSequenceNumber()

Implementation of MessageView.getMessageSequenceNumber()

setPossibleDuplicate

public final MessageView setPossibleDuplicate()

Implementation of MessageView.setPossibleDuplicate()

Returns:

Returns this for invocation chaining.

isPossibleDuplicate

public final boolean isPossibleDuplicate()

Implementation of MessageView.isPossibleDuplicate()

setOriginTs

public final MessageView setOriginTs(long ts)

Implementation of MessageView.setOriginTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getOriginTs

public final long getOriginTs()

Implementation of MessageView.getOriginTs()

Returns:

Returns the origin timestamp. A value of zero indicates that the origin timestamp was not recorded.

This timestamp, in microseconds, specifies the time at which the first message in this message's flow originated.

setCreateTs

public final MessageView setCreateTs(long ts)

Implementation of MessageView.setCreateTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getCreateTs

public final long getCreateTs()

Implementation of MessageView.getCreateTs()

Returns:

Returns the create timestamp. A value of zero indicates that the create timestamp was not recorded.

This timestamp, in microseconds, specifies the time at which the message was created.

setSendTs

public final MessageView setSendTs(long ts)

Implementation of MessageView.setSendTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getSendTs

public final long getSendTs()

Implementation of MessageView.getSendTs()

Returns:

Returns the send timestamp. A value of zero indicates that the outbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time at which the message was sent by the application.

setOutTs

public final MessageView setOutTs(long ts)

Implementation of MessageView.setOutTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getOutTs

public final long getOutTs()

Implementation of MessageView.getOutTs()

Returns:

Returns the out timestamp. A value of zero indicates that the outbound timestamp was not recorded.

This timestamp is the same timestamp as the 'send' timestamp but in milliseconds.

setPreSerializeTs

public final MessageView setPreSerializeTs(long ts)

Implementation of MessageView.setPreSerializeTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPreSerializeTs

public final long getPreSerializeTs()

Implementation of MessageView.getPreSerializeTs()

Returns:

Returns the timestamp. A value of zero indicates that the inbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time just before a message was serialized for transport.

setPostSerializeTs

public final MessageView setPostSerializeTs(long ts)

Implementation of MessageView.setPostSerializeTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPostSerializeTs

public final long getPostSerializeTs()

Implementation of MessageView.getPostSerializeTs()

Returns:

Returns the timestamp. A value of zero indicates that the inbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time just after a message was serialized for transport.

setPreWireTs

public final MessageView setPreWireTs(long ts)

Implementation of MessageView.setPreWireTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

This timestamp, in microseconds, specifies the time just before a message was sent on the network (the accuracy of this depends on how close to the wire the SMA binding used can timestamp the message)

getPreWireTs

public final long getPreWireTs()

Implementation of MessageView.getPreWireTs()

Returns:

Returns the timestamp. A value of zero indicates that the inbound timestamp was not recorded.

The returned timestamp is in microseconds.

setPostWireTs

public final MessageView setPostWireTs(long ts)

Implementation of MessageView.setPostWireTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPostWireTs

public final long getPostWireTs()

Implementation of MessageView.getPostWireTs()

Returns:

Returns the timestamp. A value of zero indicates that the inbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time just after a message was received from the network (the accuracy of this depends on how close to the wire the SMA binding used can timestamp the message)

setPreDeserializeTs

public final MessageView setPreDeserializeTs(long ts)

Implementation of MessageView.setPreDeserializeTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPreDeserializeTs

public final long getPreDeserializeTs()

Implementation of MessageView.getPreDeserializeTs()

Returns:

Returns the timestamp. A value of zero indicates that the inbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time just before a message was de-serialized after transport.

setPostDeserializeTs

public final MessageView setPostDeserializeTs(long ts)

Implementation of MessageView.setPostDeserializeTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPostDeserializeTs

public final long getPostDeserializeTs()

Implementation of MessageView.getPostDeserializeTs()

Returns:

Returns the timestamp. A value of zero indicates that the inbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time just after a message was de-serialized after transport.

setReceiveTs

public final MessageView setReceiveTs(long ts)

Implementation of MessageView.setReceiveTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getReceiveTs

public final long getReceiveTs()

Implementation of MessageView.getReceiveTs()

Returns:

Returns the in timestamp. A value of zero indicates that the inbound timestamp was not recorded.

This timestamp, in microseconds, specifies the time just before a message was received by X's application dispatch machinery. It is the same as the pre-processing timestamp if the message is not being redelivered to the application by the in-process X runtime.

setPreProcessingTs

public final MessageView setPreProcessingTs(long ts)

Implementation of MessageView.setPreProcessingTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPreProcessingTs

public final long getPreProcessingTs()

Implementation of MessageView.getPreProcessingTs()

Returns:

Returns the timestamp just before the message was dispatched into the application for processing. A value of zero indicates that the pre-processing timestamp was not recorded.

This timestamp, in milliseconds, specifies the time just before a message was dispatched to the application for processing.

setPostProcessingTs

public final MessageView setPostProcessingTs(long ts)

Implementation of MessageView.setPostProcessingTs(long)

Parameters:

ts - The timestamp to set.

Returns:

Returns this for invocation chaining.

getPostProcessingTs

public final long getPostProcessingTs()

Implementation of MessageView.getPostProcessingTs()

Returns:

Returns the timestamp just after the message was processed by the application. A value of zero indicates that the post-processing timestamp was not recorded.

This timestamp, in milliseconds, specifies the time just after a message processing handler completes.

sync

public final void sync()

Implementation of MessageView.sync()

serializeToByteArray

public final byte[] serializeToByteArray()

Implementation of MessageView.serializeToByteArray()

serializeToByteBuffer

public final ByteBuffer serializeToByteBuffer()

Implementation of MessageView.serializeToByteBuffer()

serializeToPacket

public final PktPacket serializeToPacket()

Implementation of MessageView.serializeToPacket()

deserializeFromByteArray

public final RawMessageViewImpl deserializeFromByteArray(byte[] array)

Implementation of MessageView.deserializeFromByteArray(byte[])

Parameters:

array - The view's backing message serialized as a byte array.

deserializeFromByteBuffer

public final RawMessageViewImpl deserializeFromByteBuffer(ByteBuffer buffer)

Implementation of MessageView.deserializeFromByteBuffer(java.nio.ByteBuffer)

Parameters:

buffer - The view's backing message serialized as a byte buffer.

deserializeFromPacket

public final RawMessageViewImpl deserializeFromPacket(PktPacket packet)

Implementation of MessageView.deserializeFromPacket(com.neeve.pkt.PktPacket)

Parameters:

packet - The view's backing message serialized as a packet.