Modifier and Type | Method and Description |
---|---|
void |
XMLMessageExporter.printLargeMessageBody(LargeServerMessage message) |
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
StorageManager.createLargeMessage() |
LargeServerMessage |
StorageManager.createLargeMessage(long id,
Message message)
Creates a new LargeMessage with the given id.
|
LargeServerMessage |
StorageManager.largeMessageCreated(long id,
LargeServerMessage largeMessage) |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage) |
LargeServerMessage |
StorageManager.largeMessageCreated(long id,
LargeServerMessage largeMessage) |
Modifier and Type | Class and Description |
---|---|
class |
LargeServerMessageImpl |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentLongHashMap<LargeServerMessage> |
AbstractJournalStorageManager.largeMessagesToDelete |
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
JournalStorageManager.createLargeMessage() |
LargeServerMessage |
JournalStorageManager.createLargeMessage(long id,
Message message) |
LargeServerMessage |
JournalStorageManager.largeMessageCreated(long id,
LargeServerMessage largeMessage) |
protected abstract LargeServerMessage |
AbstractJournalStorageManager.parseLargeMessage(ActiveMQBuffer buff) |
protected LargeServerMessage |
JournalStorageManager.parseLargeMessage(ActiveMQBuffer buff) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractJournalStorageManager.confirmLargeMessage(LargeServerMessage largeServerMessage) |
void |
LargeBody.copyInto(LargeServerMessage newMessage) |
void |
LargeBody.copyInto(LargeServerMessage newMessage,
io.netty.buffer.ByteBuf newHeader,
int skipBytes) |
void |
JournalStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage) |
LargeServerMessage |
JournalStorageManager.largeMessageCreated(long id,
LargeServerMessage largeMessage) |
void |
LargeBody.setMessage(LargeServerMessage message) |
Constructor and Description |
---|
LargeBody(LargeServerMessage message,
StorageManager storageManager) |
LargeBody(LargeServerMessage message,
StorageManager storageManager,
SequentialFile file) |
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
LargeMessagePersister.decode(ActiveMQBuffer buffer,
LargeServerMessage message,
CoreMessageObjectPools objectPools) |
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
LargeMessagePersister.decode(ActiveMQBuffer buffer,
LargeServerMessage message,
CoreMessageObjectPools objectPools) |
void |
LargeMessagePersister.encode(ActiveMQBuffer buffer,
LargeServerMessage message) |
int |
LargeMessagePersister.getEncodeSize(LargeServerMessage message) |
Modifier and Type | Method and Description |
---|---|
LargeServerMessage |
NullStorageManager.createLargeMessage() |
LargeServerMessage |
NullStorageManager.createLargeMessage(long id,
Message message) |
LargeServerMessage |
NullStorageManager.largeMessageCreated(long id,
LargeServerMessage largeMessage) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage) |
LargeServerMessage |
NullStorageManager.largeMessageCreated(long id,
LargeServerMessage largeMessage) |
Modifier and Type | Interface and Description |
---|---|
interface |
CoreLargeServerMessage
This is a tagging interface,
as we need to make sure the LargeMessage is a core large message is certain places.
|
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerLogger.lareMessageErrorCopying(Exception e,
LargeServerMessage largeServerMessage) |
void |
ActiveMQServerLogger_$logger.lareMessageErrorCopying(Exception e,
LargeServerMessage largeServerMessage) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.