public final class LargeServerMessageInSync extends Object implements ReplicatedLargeMessage
Constructor and Description |
---|
LargeServerMessageInSync(StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
addBytes(byte[] bytes) |
void |
deleteFile() |
long |
getPendingRecordID() |
SequentialFile |
getSyncFile() |
void |
joinSyncedData(ByteBuffer buffer) |
void |
releaseResources(boolean sync) |
Message |
setDurable(boolean durable) |
Message |
setMessageID(long id) |
void |
setPendingRecordID(long pendingRecordID) |
public LargeServerMessageInSync(StorageManager storageManager)
storageManager
- public void joinSyncedData(ByteBuffer buffer) throws Exception
Exception
public SequentialFile getSyncFile() throws ActiveMQException
ActiveMQException
public Message setDurable(boolean durable)
setDurable
in interface ReplicatedLargeMessage
ReplicatedLargeMessage.setDurable(boolean)
public Message setMessageID(long id)
setMessageID
in interface ReplicatedLargeMessage
ReplicatedLargeMessage.setMessageID(long)
public void releaseResources(boolean sync)
releaseResources
in interface ReplicatedLargeMessage
LargeServerMessage.releaseResources(boolean)
public void deleteFile() throws Exception
deleteFile
in interface ReplicatedLargeMessage
Exception
LargeServerMessage.deleteFile()
public void addBytes(byte[] bytes) throws Exception
addBytes
in interface ReplicatedLargeMessage
Exception
LargeServerMessage.addBytes(byte[])
public void setPendingRecordID(long pendingRecordID)
setPendingRecordID
in interface ReplicatedLargeMessage
public long getPendingRecordID()
getPendingRecordID
in interface ReplicatedLargeMessage
Copyright © 2019 JBoss by Red Hat. All rights reserved.