Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfo.deliverAfterCommit(PageSubscription cursor,
PagePosition cursorPos)
This method will hold the position to be delivered later in case this transaction is pending.
|
Modifier and Type | Method and Description |
---|---|
PagePosition |
PagedReferenceImpl.getPosition() |
PagePosition |
PagedReference.getPosition() |
PagePosition |
PagePosition.nextMessage() |
PagePosition |
PagePosition.nextPage() |
Modifier and Type | Method and Description |
---|---|
void |
PageSubscription.addPendingDelivery(PagePosition position) |
void |
PageSubscription.bookmark(PagePosition position) |
void |
PageSubscription.confirmPosition(PagePosition ref) |
void |
PageSubscription.confirmPosition(Transaction tx,
PagePosition position) |
PagedMessage |
PageCursorProvider.getMessage(PagePosition pos) |
void |
PageSubscription.lateDeliveryRollback(PagePosition position) |
PagedReference |
PageCursorProvider.newReference(PagePosition pos,
PagedMessage msg,
PageSubscription sub) |
void |
PageSubscription.positionIgnored(PagePosition position)
To be called when the cursor decided to ignore a position.
|
PagedMessage |
PageSubscription.queryMessage(PagePosition pos)
To be used to requery the reference case the Garbage Collection removed it from the PagedReference as it's using WeakReferences
|
void |
PageSubscription.redeliver(PagePosition position)
To be used on redeliveries
|
void |
PageSubscription.reloadACK(PagePosition position) |
void |
PageSubscription.reloadPageCompletion(PagePosition position) |
void |
PageSubscription.reloadPreparedACK(Transaction tx,
PagePosition position)
To be used to avoid a redelivery of a prepared ACK after load
|
Constructor and Description |
---|
PagedReferenceImpl(PagePosition position,
PagedMessage message,
PageSubscription subscription) |
Modifier and Type | Class and Description |
---|---|
class |
PagePositionImpl
A PagePosition
|
Modifier and Type | Method and Description |
---|---|
PagePosition |
PagePositionImpl.nextMessage() |
PagePosition |
PagePositionImpl.nextPage() |
Modifier and Type | Method and Description |
---|---|
int |
PagePositionImpl.compareTo(PagePosition o) |
PagedMessage |
PageCursorProviderImpl.getMessage(PagePosition pos) |
PagedReference |
PageCursorProviderImpl.newReference(PagePosition pos,
PagedMessage msg,
PageSubscription subscription) |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfoImpl.deliverAfterCommit(PageSubscription cursor,
PagePosition cursorPos) |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.storeCursorAcknowledge(long queueID,
PagePosition position) |
void |
StorageManager.storeCursorAcknowledgeTransactional(long txID,
long queueID,
PagePosition position) |
void |
StorageManager.storePageCompleteTransactional(long txID,
long queueID,
PagePosition position) |
Modifier and Type | Field and Description |
---|---|
PagePosition |
JournalStorageManager.CursorAckRecordEncoding.position |
Modifier and Type | Method and Description |
---|---|
void |
JournalStorageManager.storeCursorAcknowledge(long queueID,
PagePosition position) |
void |
JournalStorageManager.storeCursorAcknowledgeTransactional(long txID,
long queueID,
PagePosition position) |
void |
JournalStorageManager.storePageCompleteTransactional(long txID,
long queueID,
PagePosition position) |
Constructor and Description |
---|
JournalStorageManager.CursorAckRecordEncoding(long queueID,
PagePosition position) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.storeCursorAcknowledge(long queueID,
PagePosition position) |
void |
NullStorageManager.storeCursorAcknowledgeTransactional(long txID,
long queueID,
PagePosition position) |
void |
NullStorageManager.storePageCompleteTransactional(long txID,
long queueID,
PagePosition position) |
Modifier and Type | Method and Description |
---|---|
void |
HornetQServerLogger.pageNotFound(PagePosition pos) |
void |
HornetQServerLogger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.