|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.core.message.impl.MessageImpl
org.jboss.messaging.core.client.impl.ClientMessageImpl
public class ClientMessageImpl
A ClientMessageImpl
Field Summary | |
---|---|
static SimpleString |
REPLYTO_HEADER_NAME
|
Fields inherited from class org.jboss.messaging.core.message.impl.MessageImpl |
---|
durable, HDR_ACTUAL_EXPIRY_TIME, HDR_DUPLICATE_DETECTION_ID, HDR_FROM_CLUSTER, HDR_GROUP_ID, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_DESTINATION, HDR_ROUTE_TO_IDS, HDR_SCHEDULED_DELIVERY_TIME, messageID, type |
Constructor Summary | |
---|---|
ClientMessageImpl()
|
|
ClientMessageImpl(boolean durable,
MessagingBuffer body)
|
|
ClientMessageImpl(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority,
MessagingBuffer body)
|
|
ClientMessageImpl(byte type,
boolean durable,
MessagingBuffer body)
|
|
ClientMessageImpl(int deliveryCount)
|
Method Summary | |
---|---|
void |
acknowledge()
|
void |
discardLargeBody()
Discard unused packets (used on large-message) |
int |
getDeliveryCount()
|
int |
getFlowControlSize()
Size used for FlowControl |
long |
getLargeBodySize()
|
boolean |
isLargeMessage()
|
void |
onReceipt(ClientConsumerInternal consumer)
|
void |
saveToOutputStream(java.io.OutputStream out)
Save the content of the message to the OutputStream. |
void |
setDeliveryCount(int deliveryCount)
|
void |
setFlowControlSize(int flowControlSize)
Size used for FlowControl |
void |
setLargeMessage(boolean largeMessage)
|
void |
setOutputStream(java.io.OutputStream out)
Sets the OutputStream that will receive the content of a message received in a non blocking way |
boolean |
waitOutputStreamCompletion(long timeMilliseconds)
Wait the outputStream completion of the message. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final SimpleString REPLYTO_HEADER_NAME
Constructor Detail |
---|
public ClientMessageImpl(int deliveryCount)
public ClientMessageImpl(byte type, boolean durable, long expiration, long timestamp, byte priority, MessagingBuffer body)
public ClientMessageImpl(byte type, boolean durable, MessagingBuffer body)
public ClientMessageImpl(boolean durable, MessagingBuffer body)
public ClientMessageImpl()
Method Detail |
---|
public void onReceipt(ClientConsumerInternal consumer)
onReceipt
in interface ClientMessageInternal
public void setDeliveryCount(int deliveryCount)
setDeliveryCount
in interface ClientMessage
public int getDeliveryCount()
getDeliveryCount
in interface ClientMessage
public void acknowledge() throws MessagingException
acknowledge
in interface ClientMessage
MessagingException
public long getLargeBodySize()
getLargeBodySize
in interface Message
public int getFlowControlSize()
ClientMessageInternal
getFlowControlSize
in interface ClientMessageInternal
public void setFlowControlSize(int flowControlSize)
ClientMessageInternal
setFlowControlSize
in interface ClientMessageInternal
public boolean isLargeMessage()
isLargeMessage
in interface Message
public void setLargeMessage(boolean largeMessage)
setLargeMessage
in interface ClientMessageInternal
largeMessage
- the largeMessage to setpublic void discardLargeBody()
ClientMessageInternal
discardLargeBody
in interface ClientMessageInternal
public void saveToOutputStream(java.io.OutputStream out) throws MessagingException
ClientMessage
saveToOutputStream
in interface ClientMessage
MessagingException
public void setOutputStream(java.io.OutputStream out) throws MessagingException
ClientMessage
setOutputStream
in interface ClientMessage
MessagingException
public boolean waitOutputStreamCompletion(long timeMilliseconds) throws MessagingException
ClientMessage
waitOutputStreamCompletion
in interface ClientMessage
timeMilliseconds
- - 0 means wait forever
MessagingException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |