Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfo.deliverAfterCommit(PageIterator pageIterator,
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 |
PagedReference.getPosition() |
PagePosition |
PagedReferenceImpl.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 |
PageCache.getMessage(PagePosition pagePosition) |
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(PageIterator iterator,
PagePosition position)
To be used on redeliveries
|
void |
PageIterator.redeliver(PagePosition reference) |
void |
PageSubscription.reloadACK(PagePosition position) |
boolean |
PageSubscription.reloadPageCompletion(PagePosition position) |
void |
PageSubscription.reloadPreparedACK(Transaction tx,
PagePosition position)
To be used to avoid a redelivery of a prepared ACK after load
|
void |
PageSubscription.removePendingDelivery(PagePosition position) |
Constructor and Description |
---|
PagedReferenceImpl(PagePosition position,
PagedMessage message,
PageSubscription subscription) |
Modifier and Type | Class and Description |
---|---|
class |
PagePositionImpl |
Modifier and Type | Method and Description |
---|---|
PagePosition |
PageSubscriptionImpl.PageCursorInfo.getCompleteInfo() |
PagePosition |
PagePositionImpl.nextMessage() |
PagePosition |
PagePositionImpl.nextPage() |
Modifier and Type | Method and Description |
---|---|
void |
PageSubscriptionImpl.PageCursorInfo.addACK(PagePosition posACK) |
void |
PageSubscriptionImpl.addPendingDelivery(PagePosition position) |
void |
PageSubscriptionImpl.bookmark(PagePosition position) |
int |
PagePositionImpl.compareTo(PagePosition o) |
void |
PageSubscriptionImpl.confirmPosition(PagePosition position) |
void |
PageSubscriptionImpl.confirmPosition(Transaction tx,
PagePosition position) |
PagedMessage |
LivePageCacheImpl.getMessage(PagePosition pagePosition) |
PagedMessage |
PageCursorProviderImpl.getMessage(PagePosition pos) |
PagedMessage |
PageReader.getMessage(PagePosition pagePosition) |
PagedMessage |
PageReader.getMessage(PagePosition pagePosition,
boolean throwException,
boolean keepOpen) |
boolean |
PageSubscriptionImpl.PageCursorInfo.isAck(PagePosition position) |
boolean |
PageSubscriptionImpl.PageCursorInfo.isRemoved(PagePosition pos) |
void |
PageSubscriptionImpl.lateDeliveryRollback(PagePosition position) |
void |
PageSubscriptionImpl.PageCursorInfo.loadACK(PagePosition posACK) |
PagedReference |
PageCursorProviderImpl.newReference(PagePosition pos,
PagedMessage msg,
PageSubscription subscription) |
void |
PageSubscriptionImpl.positionIgnored(PagePosition position) |
PagedMessage |
PageSubscriptionImpl.queryMessage(PagePosition pos) |
void |
PageSubscriptionImpl.redeliver(PageIterator iterator,
PagePosition position) |
void |
PageSubscriptionImpl.reloadACK(PagePosition position)
Theres no need to synchronize this method as it's only called from journal load on startup
|
boolean |
PageSubscriptionImpl.reloadPageCompletion(PagePosition position)
A page marked as complete will be ignored until it's cleared.
|
void |
PageSubscriptionImpl.reloadPreparedACK(Transaction tx,
PagePosition position) |
void |
PageSubscriptionImpl.PageCursorInfo.remove(PagePosition position) |
void |
PageSubscriptionImpl.removePendingDelivery(PagePosition position) |
void |
PageSubscriptionImpl.PageCursorInfo.setCompleteInfo(PagePosition completePage) |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfoImpl.deliverAfterCommit(PageIterator iterator,
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 | Method and Description |
---|---|
void |
AbstractJournalStorageManager.storeCursorAcknowledge(long queueID,
PagePosition position) |
void |
AbstractJournalStorageManager.storeCursorAcknowledgeTransactional(long txID,
long queueID,
PagePosition position) |
void |
AbstractJournalStorageManager.storePageCompleteTransactional(long txID,
long queueID,
PagePosition position) |
Modifier and Type | Field and Description |
---|---|
PagePosition |
CursorAckRecordEncoding.position |
Constructor and Description |
---|
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 |
ActiveMQServerLogger.pageNotFound(PagePosition pos) |
void |
ActiveMQServerLogger_$logger.pageNotFound(PagePosition pos) |
void |
ActiveMQServerLogger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
void |
ActiveMQServerLogger_$logger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.