Modifier and Type | Method and Description |
---|---|
void |
ResetLimitWrappedActiveMQBuffer.setMessage(MessageInternal message)
We need to turn of notifications of body changes on reset on the server side when dealing with AMQP conversions,
for that reason this method will set the message to null here
|
Constructor and Description |
---|
ResetLimitWrappedActiveMQBuffer(int limit,
ActiveMQBuffer buffer,
MessageInternal message) |
ResetLimitWrappedActiveMQBuffer(int limit,
io.netty.buffer.ByteBuf buffer,
MessageInternal message) |
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
|
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 |
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 | Method and Description |
---|---|
int |
ActiveMQSessionContext.getCreditsOnSendingFull(MessageInternal msgI) |
void |
ActiveMQSessionContext.sendFullMessage(MessageInternal msgI,
boolean sendBlocking,
SendAcknowledgementHandler handler,
SimpleString defaultAddress) |
int |
ActiveMQSessionContext.sendInitialChunkOnLargeMessage(MessageInternal msgI) |
int |
ActiveMQSessionContext.sendLargeMessageChunk(MessageInternal msgI,
long messageBodySize,
boolean sendBlocking,
boolean lastChunk,
byte[] chunk,
int reconnectID,
SendAcknowledgementHandler messageHandler) |
int |
ActiveMQSessionContext.sendServerLargeMessageChunk(MessageInternal msgI,
long messageBodySize,
boolean sendBlocking,
boolean lastChunk,
byte[] chunk,
SendAcknowledgementHandler messageHandler) |
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,
long messageBodySize,
SendAcknowledgementHandler handler) |
SessionSendLargeMessage(MessageInternal largeMessage) |
SessionSendMessage(MessageInternal message) |
SessionSendMessage(MessageInternal message,
boolean requiresResponse,
SendAcknowledgementHandler handler) |
Modifier and Type | Interface and Description |
---|---|
interface |
LargeServerMessage |
interface |
ServerMessage
A ServerMessage
|
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.sendLarge(MessageInternal msg) |
Modifier and Type | Class and Description |
---|---|
class |
ServerMessageImpl |
Modifier and Type | Method and Description |
---|---|
void |
ServerSessionImpl.sendLarge(MessageInternal message) |
Modifier and Type | Method and Description |
---|---|
abstract int |
SessionContext.getCreditsOnSendingFull(MessageInternal msgI) |
abstract void |
SessionContext.sendFullMessage(MessageInternal msgI,
boolean sendBlocking,
SendAcknowledgementHandler handler,
SimpleString defaultAddress) |
abstract int |
SessionContext.sendInitialChunkOnLargeMessage(MessageInternal msgI)
it should return the number of credits (or bytes) used to send this packet
|
abstract int |
SessionContext.sendLargeMessageChunk(MessageInternal msgI,
long messageBodySize,
boolean sendBlocking,
boolean lastChunk,
byte[] chunk,
int reconnectID,
SendAcknowledgementHandler messageHandler) |
abstract int |
SessionContext.sendServerLargeMessageChunk(MessageInternal msgI,
long messageBodySize,
boolean sendBlocking,
boolean lastChunk,
byte[] chunk,
SendAcknowledgementHandler messageHandler) |
Copyright © 2017 JBoss by Red Hat. All rights reserved.