edu.iu.dsc.tws.comms.dfw

Class InMessage

java.lang.Object

edu.iu.dsc.tws.comms.dfw.InMessage

public class InMessage
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InMessage.ReceivedState

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	complete Keep whether we have all the buffers added
protected MessageHeader	header The message header

Constructor Summary

Constructors

Constructor and Description
InMessage(int originatingId, MessageType messageType, ChannelMessageReleaseCallback releaseListener, MessageHeader header)

Method Summary

Modifier and Type	Method and Description
boolean	addBufferAndCalculate(DataBuffer buffer) Add a buffer and calculate weather we have seen all the buffers for an object
void	addBuiltMessage(ChannelMessage channelMessage)
void	addCurrentKeyedObject()
void	addCurrentObject()
java.util.Queue<DataBuffer>	getBuffers()
java.util.Queue<ChannelMessage>	getBuiltMessages()
ObjectBuilderImpl	getDataBuilder()
MessageType	getDataType()
java.lang.Object	getDeserializedData()
MessageHeader	getHeader()
ObjectBuilderImpl	getKeyBuilder()
MessageType	getKeyType()
int	getOriginatingId()
InMessage.ReceivedState	getReceivedState()
ChannelMessageReleaseCallback	getReleaseListener()
int	getUnPkBuffers()
int	getUnPkCurrentKeyLength()
int	getUnPkCurrentObjectLength()
int	getUnPkNumberObjects()
void	incrementUnPkBuffers()
boolean	isKeyed()
boolean	isReadingKey()
void	setDataType(MessageType dataType)
void	setKeyType(MessageType keyType)
void	setReadingKey(boolean readingKey)
void	setReceivedState(InMessage.ReceivedState receivedState)
void	setUnPkCurrentKeyLength(int unPkCurrentKeyLength)
void	setUnPkCurrentObjectLength(int unPkCurrentObjectLength)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

header

protected MessageHeader header

The message header

complete

protected boolean complete

Keep whether we have all the buffers added

Constructor Detail

InMessage

public InMessage(int originatingId,
                 MessageType messageType,
                 ChannelMessageReleaseCallback releaseListener,
                 MessageHeader header)

Method Detail

setDataType

public void setDataType(MessageType dataType)

getDataType

public MessageType getDataType()

setKeyType

public void setKeyType(MessageType keyType)

getKeyType

public MessageType getKeyType()

getHeader

public MessageHeader getHeader()

addBufferAndCalculate

public boolean addBufferAndCalculate(DataBuffer buffer)

Add a buffer and calculate weather we have seen all the buffers for an object

Parameters:

buffer - buffer

Returns:

true if all the buffers for a message is received

addCurrentKeyedObject

public void addCurrentKeyedObject()

addCurrentObject

public void addCurrentObject()

addBuiltMessage

public void addBuiltMessage(ChannelMessage channelMessage)

getReleaseListener

public ChannelMessageReleaseCallback getReleaseListener()

getOriginatingId

public int getOriginatingId()

getBuffers

public java.util.Queue<DataBuffer> getBuffers()

getReceivedState

public InMessage.ReceivedState getReceivedState()

setReceivedState

public void setReceivedState(InMessage.ReceivedState receivedState)

getBuiltMessages

public java.util.Queue<ChannelMessage> getBuiltMessages()

getDeserializedData

public java.lang.Object getDeserializedData()

getUnPkCurrentObjectLength

public int getUnPkCurrentObjectLength()

setUnPkCurrentObjectLength

public void setUnPkCurrentObjectLength(int unPkCurrentObjectLength)

getUnPkCurrentKeyLength

public int getUnPkCurrentKeyLength()

setUnPkCurrentKeyLength

public void setUnPkCurrentKeyLength(int unPkCurrentKeyLength)

getUnPkNumberObjects

public int getUnPkNumberObjects()

getUnPkBuffers

public int getUnPkBuffers()

incrementUnPkBuffers

public void incrementUnPkBuffers()

isKeyed

public boolean isKeyed()

isReadingKey

public boolean isReadingKey()

setReadingKey

public void setReadingKey(boolean readingKey)

getDataBuilder

public ObjectBuilderImpl getDataBuilder()

getKeyBuilder

public ObjectBuilderImpl getKeyBuilder()