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 |
---|---|
PageSubscription |
PageCursorProvider.createSubscription(long queueId,
Filter filter,
boolean durable) |
PageSubscription |
PageCursorProvider.getSubscription(long queueId) |
Modifier and Type | Method and Description |
---|---|
void |
PageCursorProvider.close(PageSubscription pageCursorImpl) |
PagedReference |
PageCursorProvider.newReference(PagePosition pos,
PagedMessage msg,
PageSubscription sub) |
Constructor and Description |
---|
PagedReferenceImpl(PagePosition position,
PagedMessage message,
PageSubscription subscription) |
Modifier and Type | Method and Description |
---|---|
PageSubscription |
PageCursorProviderImpl.createSubscription(long cursorID,
Filter filter,
boolean persistent) |
PageSubscription |
PageCursorProviderImpl.getSubscription(long cursorID) |
Modifier and Type | Method and Description |
---|---|
void |
PageCursorProviderImpl.close(PageSubscription cursor) |
PagedReference |
PageCursorProviderImpl.newReference(PagePosition pos,
PagedMessage msg,
PageSubscription subscription) |
Modifier and Type | Method and Description |
---|---|
protected void |
PageCursorProviderImpl.storeBookmark(ArrayList<PageSubscription> cursorList,
Page currentPage) |
Constructor and Description |
---|
PageSubscriptionCounterImpl(StorageManager storage,
PageSubscription subscription,
Executor executor,
boolean persistent,
long subscriptionID) |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfoImpl.deliverAfterCommit(PageSubscription cursor,
PagePosition cursorPos) |
Modifier and Type | Method and Description |
---|---|
PageSubscription |
Queue.getPageSubscription() |
Modifier and Type | Method and Description |
---|---|
Queue |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary) |
void |
HornetQServerLogger.timedOutFlushingExecutorsPagingCursor(PageSubscription pageSubscription) |
Modifier and Type | Method and Description |
---|---|
PageSubscription |
QueueImpl.getPageSubscription() |
Modifier and Type | Method and Description |
---|---|
Queue |
QueueFactoryImpl.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary) |
Constructor and Description |
---|
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.