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 |
---|---|
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.cleanupComplete(ArrayList<PageSubscription> cursorList) |
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(PageIterator iterator,
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,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
void |
ActiveMQServerLogger_$logger.timedOutFlushingExecutorsPagingCursor(PageSubscription pageSubscription) |
void |
ActiveMQServerLogger.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,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
Constructor and Description |
---|
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.