Package | Description |
---|---|
org.hornetq.core.buffers.impl | |
org.hornetq.core.client.impl | |
org.hornetq.core.message.impl | |
org.hornetq.core.protocol.core.impl.wireformat |
Constructor and Description |
---|
ResetLimitWrappedHornetQBuffer(int limit,
HornetQBuffer buffer,
MessageInternal message) |
Modifier and Type | Interface and Description |
---|---|
interface |
ClientLargeMessageInternal
A ClientLargeMessageInternal
|
interface |
ClientMessageInternal
A ClientMessageInternal
|
Modifier and Type | Class and Description |
---|---|
class |
ClientLargeMessageImpl
ClientLargeMessageImpl is only created when receiving large messages.
|
class |
ClientMessageImpl
A ClientMessageImpl
|
Modifier and Type | Class and Description |
---|---|
class |
MessageImpl
A concrete implementation of a message
All messages handled by HornetQ core are of this type
|
Modifier and Type | Method and Description |
---|---|
void |
MessageImpl.copyHeadersAndProperties(MessageInternal msg) |
Modifier and Type | Field and Description |
---|---|
protected MessageInternal |
MessagePacket.message |
Modifier and Type | Method and Description |
---|---|
MessageInternal |
SessionReceiveLargeMessage.getLargeMessage() |
MessageInternal |
SessionSendLargeMessage.getLargeMessage() |
MessageInternal |
SessionSendContinuationMessage.getMessage() |
Constructor and Description |
---|
MessagePacket(byte type,
MessageInternal message) |
SessionReceiveClientLargeMessage(MessageInternal message) |
SessionReceiveLargeMessage(long consumerID,
MessageInternal message,
long largeMessageSize,
int deliveryCount) |
SessionReceiveLargeMessage(MessageInternal message) |
SessionReceiveMessage(long consumerID,
MessageInternal message,
int deliveryCount) |
SessionReceiveMessage(MessageInternal message) |
SessionSendContinuationMessage(MessageInternal message,
byte[] body,
boolean continues,
boolean requiresResponse) |
SessionSendContinuationMessage(MessageInternal message,
byte[] body,
boolean continues,
boolean requiresResponse,
long messageBodySize) |
SessionSendLargeMessage(MessageInternal largeMessage) |
SessionSendMessage(MessageInternal message) |
SessionSendMessage(MessageInternal message,
boolean requiresResponse) |
Copyright © 2016 JBoss, a division of Red Hat. All Rights Reserved.