| Modifier and Type | Method and Description |
|---|---|
PagingStore |
PagingManager.getPageStore(SimpleString address)
Returns the PageStore associated with the address.
|
PagingStore |
PagingStoreFactory.newStore(SimpleString address,
AddressSettings addressSettings) |
| Modifier and Type | Method and Description |
|---|---|
List<PagingStore> |
PagingStoreFactory.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
| Modifier and Type | Method and Description |
|---|---|
void |
PagingManager.addBlockedStore(PagingStore store) |
PageCursorProvider |
PagingStoreFactory.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
| Modifier and Type | Method and Description |
|---|---|
PagingStore |
PagedReferenceImpl.getOwner() |
PagingStore |
PageSubscription.getPagingStore() |
| Modifier and Type | Method and Description |
|---|---|
void |
PagedReferenceImpl.setOwner(PagingStore owner) |
| Modifier and Type | Field and Description |
|---|---|
protected PagingStore |
PageCursorProviderImpl.pagingStore |
| Modifier and Type | Method and Description |
|---|---|
PagingStore |
PageSubscriptionImpl.getPagingStore() |
| Constructor and Description |
|---|
PageCursorProviderImpl(PagingStore pagingStore,
StorageManager storageManager,
ArtemisExecutor executor,
int maxCacheSize) |
PageCursorProviderImpl(PagingStore pagingStore,
StorageManager storageManager,
ArtemisExecutor executor,
int maxCacheSize,
boolean readWholePage) |
| Modifier and Type | Class and Description |
|---|---|
class |
PagingStoreImpl |
| Modifier and Type | Method and Description |
|---|---|
PagingStore |
PagingManagerImpl.getPageStore(SimpleString storeName)
This method creates a new store if not exist.
|
PagingStore |
PagingStoreFactoryDatabase.newStore(SimpleString address,
AddressSettings settings) |
PagingStore |
PagingStoreFactoryNIO.newStore(SimpleString address,
AddressSettings settings) |
| Modifier and Type | Method and Description |
|---|---|
List<PagingStore> |
PagingStoreFactoryDatabase.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
List<PagingStore> |
PagingStoreFactoryNIO.reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
| Modifier and Type | Method and Description |
|---|---|
void |
PagingManagerImpl.addBlockedStore(PagingStore store) |
PageCursorProvider |
PagingStoreFactoryDatabase.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
PageCursorProvider |
PagingStoreFactoryNIO.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
StorageManager.addToPage(PagingStore store,
Message msg,
Transaction tx,
RouteContextList listCtx)
Write message to page if we are paging.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
AbstractJournalStorageManager.addToPage(PagingStore store,
Message msg,
Transaction tx,
RouteContextList listCtx) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
NullStorageManager.addToPage(PagingStore store,
Message msg,
Transaction tx,
RouteContextList listCtx) |
| Modifier and Type | Method and Description |
|---|---|
PagingStore |
MessageReference.getOwner() |
PagingStore |
Queue.getPagingStore() |
PagingStore |
QueueConfig.getPagingStore()
Deprecated.
|
PagingStore |
ServerMessage.getPagingStore()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static MessageReference |
MessageReference.Factory.createReference(Message encode,
Queue queue,
PagingStore pageStore) |
void |
MessageReference.setOwner(PagingStore owner) |
void |
ServerMessage.setPagingStore(PagingStore store)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
PagingStore |
GroupFirstMessageReference.getOwner() |
PagingStore |
MessageReferenceImpl.getOwner() |
PagingStore |
QueueImpl.getPagingStore() |
| Modifier and Type | Method and Description |
|---|---|
void |
GroupFirstMessageReference.setOwner(PagingStore owner) |
void |
MessageReferenceImpl.setOwner(PagingStore owner) |
| Constructor and Description |
|---|
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
SimpleString lastValueKey,
Boolean nonDestructive,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
LastValueQueue(QueueConfiguration queueConfiguration,
PagingStore pagingStore,
PageSubscription pageSubscription,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
MessageReferenceImpl(Message message,
Queue queue,
PagingStore owner) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
Long ringSize,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean purgeOnNoConsumers,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean configurationManaged,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PagingStore pagingStore,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory)
Deprecated.
|
QueueImpl(QueueConfiguration queueConfiguration,
PagingStore pagingStore,
PageSubscription pageSubscription,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
PagingStore |
ServerMessageImpl.getPagingStore()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ServerMessageImpl.setPagingStore(PagingStore store)
Deprecated.
|
Copyright © 2022 JBoss by Red Hat. All rights reserved.