org.apache.activemq.artemis.core.persistence.impl.journal

Class LargeBody

java.lang.Object

org.apache.activemq.artemis.core.persistence.impl.journal.LargeBody

public class LargeBody
extends Object

Constructor Summary

Constructors

Constructor and Description
LargeBody(LargeServerMessage message, StorageManager storageManager)
LargeBody(LargeServerMessage message, StorageManager storageManager, SequentialFile file)
LargeBody(long messageID, JournalStorageManager storageManager)

Method Summary

Modifier and Type	Method and Description
void	addBytes(ActiveMQBuffer bytes)
void	addBytes(byte[] bytes)
void	checkDelete()
void	clearFile()
void	clearPendingRecordID()
void	copyInto(LargeServerMessage newMessage)
void	copyInto(LargeServerMessage newMessage, io.netty.buffer.ByteBuf newHeader, int skipBytes)
SequentialFile	createFile()
void	deleteFile()
void	ensureFileExists(boolean toOpen)
SequentialFile	getAppendFile()
int	getBodyBufferSize()
long	getBodySize()
LargeBodyReader	getLargeBodyReader()
long	getMessageID()
long	getPendingRecordID()
SequentialFile	getReadingFile() This will return its own File useful for reading the file on the large message while delivering, browsing..
ActiveMQBuffer	getReadOnlyBodyBuffer()
StorageManager	getStorageManager()
long	getStoredBodySize() This will return the bodySize without trying to open the file, just returning what's currently stored
boolean	hasPendingRecord()
boolean	isPaged()
ByteBuffer	map()
protected void	openFile()
void	referenceOriginalMessage(LargeBody original)
void	releaseResources(boolean sync)
void	replaceFile(SequentialFile file) Meant for test-ability, be careful if you decide to use it.
void	setBodySize(long size)
void	setMessage(LargeServerMessage message)
void	setPaged()
void	setPendingRecordID(long pendingRecordID)
void	setStorageManager(StorageManager storageManager)
void	validateFile()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LargeBody

public LargeBody(LargeServerMessage message,
                 StorageManager storageManager)

LargeBody

public LargeBody(LargeServerMessage message,
                 StorageManager storageManager,
                 SequentialFile file)

LargeBody

public LargeBody(long messageID,
                 JournalStorageManager storageManager)

Method Detail

getStorageManager

public StorageManager getStorageManager()

setStorageManager

public void setStorageManager(StorageManager storageManager)

map

public ByteBuffer map()
               throws Exception

Throws:

Exception

setMessage

public void setMessage(LargeServerMessage message)

setPaged

public void setPaged()

isPaged

public boolean isPaged()

clearFile

public void clearFile()

deleteFile

public void deleteFile()

getMessageID

public long getMessageID()

addBytes

public void addBytes(byte[] bytes)
              throws Exception

Throws:

Exception

addBytes

public void addBytes(ActiveMQBuffer bytes)
              throws Exception

Throws:

Exception

validateFile

public void validateFile()
                  throws ActiveMQException

Throws:

ActiveMQException

ensureFileExists

public void ensureFileExists(boolean toOpen)
                      throws ActiveMQException

Throws:

ActiveMQException

getStoredBodySize

public long getStoredBodySize()

This will return the bodySize without trying to open the file, just returning what's currently stored

setBodySize

public void setBodySize(long size)

getBodySize

public long getBodySize()
                 throws ActiveMQException

Throws:

ActiveMQException

getLargeBodyReader

public LargeBodyReader getLargeBodyReader()

getReadingFile

public SequentialFile getReadingFile()
                              throws ActiveMQException

This will return its own File useful for reading the file on the large message while delivering, browsing.. etc

Throws:

ActiveMQException

replaceFile

public void replaceFile(SequentialFile file)

Meant for test-ability, be careful if you decide to use it. and in case you use it for a real reason, please change the documentation here.

Parameters:

file -

getAppendFile

public SequentialFile getAppendFile()
                             throws ActiveMQException

Throws:

ActiveMQException

checkDelete

public void checkDelete()

referenceOriginalMessage

public void referenceOriginalMessage(LargeBody original)

getReadOnlyBodyBuffer

public ActiveMQBuffer getReadOnlyBodyBuffer()

getBodyBufferSize

public int getBodyBufferSize()

releaseResources

public void releaseResources(boolean sync)

copyInto

public void copyInto(LargeServerMessage newMessage)
              throws Exception

Throws:

Exception

copyInto

public void copyInto(LargeServerMessage newMessage,
                     io.netty.buffer.ByteBuf newHeader,
                     int skipBytes)
              throws Exception

Throws:

Exception

createFile

public SequentialFile createFile()

openFile

protected void openFile()
                 throws Exception

Throws:

Exception

hasPendingRecord

public boolean hasPendingRecord()

clearPendingRecordID

public void clearPendingRecordID()

getPendingRecordID

public long getPendingRecordID()

setPendingRecordID

public void setPendingRecordID(long pendingRecordID)