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 | Method and Description |
---|---|
LargeServerMessage |
StorageManager.createLargeMessage(long id,
MessageInternal message)
Creates a new LargeMessage with the given id.
|
Modifier and Type | Class and Description |
---|---|
class |
LargeServerMessageImpl
A LargeServerMessageImpl
|
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
JournalStorageManager.createLargeMessage(long id,
MessageInternal message) |
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
NullStorageManager.createLargeMessage(long id,
MessageInternal message) |
Modifier and Type | Field and Description |
---|---|
protected MessageInternal |
MessagePacket.message |
Modifier and Type | Method and Description |
---|---|
MessageInternal |
SessionSendLargeMessage.getLargeMessage() |
MessageInternal |
SessionReceiveLargeMessage.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) |
Modifier and Type | Method and Description |
---|---|
static void |
StompUtils.copyStandardHeadersFromMessageToFrame(MessageInternal message,
StompFrame command,
int deliveryCount) |
Modifier and Type | Interface and Description |
---|---|
interface |
LargeServerMessage
A LargeMessage
|
interface |
ServerMessage
A ServerMessage
|
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.sendLarge(MessageInternal msg) |
Modifier and Type | Class and Description |
---|---|
class |
ServerMessageImpl
A ServerMessageImpl
|
Modifier and Type | Method and Description |
---|---|
void |
ServerSessionImpl.sendLarge(MessageInternal message) |
Copyright © 2013 JBoss by Red Hat. All Rights Reserved.