org.hornetq.core.client.impl

Interface ClientMessageInternal

All Superinterfaces:

ClientMessage, Message, MessageInternal

All Known Subinterfaces:

ClientLargeMessageInternal

All Known Implementing Classes:

ClientLargeMessageImpl, ClientMessageImpl

public interface ClientMessageInternal
extends ClientMessage, MessageInternal

A ClientMessageInternal

Author:

Tim Fox Created 10 Dec 2008 18:05:24

Field Summary

Fields inherited from interface org.hornetq.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_SCHEDULED_DELIVERY_TIME, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Method Summary

Methods

Modifier and Type	Method and Description
void	discardBody() Discard unused packets (used on large-message)
int	getFlowControlSize() Size used for FlowControl
boolean	isCompressed()
void	onReceipt(ClientConsumerInternal consumer)
void	setBuffer(HornetQBuffer buffer)
void	setFlowControlSize(int flowControlSize) Size used for FlowControl

Methods inherited from interface org.hornetq.api.core.client.ClientMessage

acknowledge, getBodySize, getDeliveryCount, saveToOutputStream, setBodyInputStream, setDeliveryCount, setOutputStream, waitOutputStreamCompletion

Methods inherited from interface org.hornetq.core.message.impl.MessageInternal

bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getBodyInputStream, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, isServerMessage, resetCopied, setAddressTransient

Methods inherited from interface org.hornetq.api.core.Message

containsProperty, containsProperty, getAddress, getBodyBuffer, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodeSize, getExpiration, getFloatProperty, getFloatProperty, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, isDurable, isExpired, isLargeMessage, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, removeProperty, removeProperty, setAddress, setDurable, setExpiration, setPriority, setTimestamp, setUserID, toMap

Method Detail

getFlowControlSize

int getFlowControlSize()

Size used for FlowControl

setFlowControlSize

void setFlowControlSize(int flowControlSize)

Size used for FlowControl

onReceipt

void onReceipt(ClientConsumerInternal consumer)

discardBody

void discardBody()

Discard unused packets (used on large-message)

setBuffer

void setBuffer(HornetQBuffer buffer)

isCompressed

boolean isCompressed()