Uses of Interface
org.apache.activemq.artemis.core.persistence.StorageManager
Packages that use StorageManager
Package
Description
-
Uses of StorageManager in org.apache.activemq.artemis.core.management.impl
Fields in org.apache.activemq.artemis.core.management.impl declared as StorageManagerConstructors in org.apache.activemq.artemis.core.management.impl with parameters of type StorageManagerModifierConstructorDescriptionAbstractControl(Class<?> clazz, StorageManager storageManager) AcceptorControlImpl(Acceptor acceptor, StorageManager storageManager, TransportConfiguration configuration) ActiveMQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster) AddressControlImpl(AddressInfo addressInfo, ActiveMQServer server, PagingManager pagingManager, StorageManager storageManager, HierarchicalRepository<Set<Role>> securityRepository, SecurityStore securityStore, ManagementService managementService) BaseBroadcastGroupControlImpl(Class broadcastGroupControlClass, BroadcastGroup broadcastGroup, StorageManager storageManager, BroadcastGroupConfiguration configuration) BaseBroadcastGroupControlImpl(BroadcastGroup broadcastGroup, StorageManager storageManager, BroadcastGroupConfiguration configuration) BridgeControlImpl(Bridge bridge, StorageManager storageManager) BroadcastGroupControlImpl(BroadcastGroup broadcastGroup, StorageManager storageManager, BroadcastGroupConfiguration configuration, UDPBroadcastEndpointFactory endpointFactory) BrokerConnectionControlImpl(BrokerConnection brokerConnection, StorageManager storageManager) ClusterConnectionControlImpl(ClusterConnection clusterConnection, StorageManager storageManager, ClusterConnectionConfiguration configuration) ConnectionRouterControlImpl(ConnectionRouter connectionRouter, StorageManager storageManager) DivertControlImpl(Divert divert, StorageManager storageManager, String internalNamingPrefix) JGroupsChannelBroadcastGroupControlImpl(BroadcastGroup broadcastGroup, StorageManager storageManager, BroadcastGroupConfiguration configuration, ChannelBroadcastEndpointFactory endpointFactory) JGroupsFileBroadcastGroupControlImpl(BroadcastGroup broadcastGroup, StorageManager storageManager, BroadcastGroupConfiguration configuration, JGroupsFileBroadcastEndpointFactory endpointFactory) QueueControlImpl(Queue queue, String address, ActiveMQServer server, StorageManager storageManager, SecurityStore securityStore, HierarchicalRepository<AddressSettings> addressSettingsRepository) RemoteBrokerConnectionControlImpl(RemoteBrokerConnection connection, StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return StorageManagerMethods in org.apache.activemq.artemis.core.paging with parameters of type StorageManagerModifier and TypeMethodDescriptionbooleanPageTransactionInfo.checkSize(StorageManager storageManager, PagingManager pagingManager) voidPagedMessage.initMessage(StorageManager storageManager) PagingStoreFactory.newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor) booleanPageTransactionInfo.onUpdate(int update, StorageManager storageManager, PagingManager pagingManager) voidPageTransactionInfo.reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) voidPageTransactionInfo.store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) voidPageTransactionInfo.storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) -
Uses of StorageManager in org.apache.activemq.artemis.core.paging.cursor.impl
Fields in org.apache.activemq.artemis.core.paging.cursor.impl declared as StorageManagerModifier and TypeFieldDescriptionprotected final StorageManagerPageCursorProviderImpl.storageManagerConstructors in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type StorageManagerModifierConstructorDescriptionPageCursorProviderImpl(PagingStore pagingStore, StorageManager storageManager) PageSubscriptionCounterImpl(StorageManager storage, long subscriptionID) -
Uses of StorageManager in org.apache.activemq.artemis.core.paging.impl
Fields in org.apache.activemq.artemis.core.paging.impl declared as StorageManagerModifier and TypeFieldDescriptionprotected final StorageManagerPagingStoreFactoryDatabase.storageManagerMethods in org.apache.activemq.artemis.core.paging.impl that return StorageManagerModifier and TypeMethodDescriptionPagingStoreFactoryNIO.getStorageManager()PagingStoreImpl.getStorageManager()Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type StorageManagerModifier and TypeMethodDescriptionbooleanPageTransactionInfoImpl.checkSize(StorageManager storageManager, PagingManager pagingManager) voidPagedMessageImpl.initMessage(StorageManager storage) booleanPageTransactionInfoImpl.internalCheckSize(StorageManager storageManager, PagingManager pagingManager, int size) protected org.apache.activemq.artemis.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperationPageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) PagingStoreFactoryDatabase.newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor) PagingStoreFactoryNIO.newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor) booleanPageTransactionInfoImpl.onUpdate(int update, StorageManager storageManager, PagingManager pagingManager) Page.read(StorageManager storage) Page.read(StorageManager storage, boolean onlyLargeMessages) static intPageReadWriter.readFromSequentialFile(StorageManager storage, SimpleString storeName, SequentialFileFactory fileFactory, SequentialFile file, long pageId, Consumer<PagedMessage> messages, PageReadWriter.PageRecordFilter skipRecord, PageReadWriter.SuspectFileCallback suspectFileCallback, PageReadWriter.ReadCallback readCallback) voidPageTransactionInfoImpl.reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) voidPageTransactionInfoImpl.store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) voidPageTransactionInfoImpl.storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) Constructors in org.apache.activemq.artemis.core.paging.impl with parameters of type StorageManagerModifierConstructorDescriptionPage(SimpleString storeName, StorageManager storageManager, SequentialFileFactory factory, SequentialFile file, long pageId) PagedMessageImpl(int storedSize, StorageManager storageManager) PageTimedWriter(int writeCredits, StorageManager storageManager, PagingStoreImpl pagingStore, ScheduledExecutorService scheduledExecutor, Executor executor, boolean syncNonTX, long timeSync) PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf, StorageManager storageManager, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional, IOCriticalErrorListener criticalErrorListener) PagingStoreFactoryNIO(StorageManager storageManager, File directory, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional, IOCriticalErrorListener critialErrorListener) PagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, ArtemisExecutor executor, boolean syncNonTransactional) -
Uses of StorageManager in org.apache.activemq.artemis.core.persistence.impl.journal
Classes in org.apache.activemq.artemis.core.persistence.impl.journal that implement StorageManagerModifier and TypeClassDescriptionclassControls access to the journals and other storage files such as the ones used to store pages and large messages.classclassMethods in org.apache.activemq.artemis.core.persistence.impl.journal that return StorageManagerModifier and TypeMethodDescriptionLargeBody.getStorageManager()LargeServerMessageImpl.getStorageManager()Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type StorageManagerModifier and TypeMethodDescriptionstatic MessageLargeServerMessageImpl.checkLargeMessage(Message message, StorageManager storageManager) This will check if a regular message needs to be converted as large messagevoidLargeBody.setStorageManager(StorageManager storageManager) voidLargeServerMessageImpl.setStorageManager(StorageManager storageManager) Constructors in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type StorageManagerModifierConstructorDescriptionBatchingIDGenerator(long start, long checkpointSize, StorageManager storageManager) LargeBody(LargeServerMessage message, StorageManager storageManager) LargeBody(LargeServerMessage message, StorageManager storageManager, SequentialFile file) LargeServerMessageImpl(byte type, long id, StorageManager storageManager, SequentialFile fileCopy) LargeServerMessageImpl(StorageManager storageManager) LargeServerMessageInSync(StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.persistence.impl.nullpm
Classes in org.apache.activemq.artemis.core.persistence.impl.nullpm that implement StorageManager -
Uses of StorageManager in org.apache.activemq.artemis.core.postoffice.impl
Methods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type StorageManagerModifier and TypeMethodDescriptionstatic DuplicateIDCacheDuplicateIDCaches.persistent(SimpleString address, int size, StorageManager storageManager) static voidPostOfficeImpl.storeDurableReference(StorageManager storageManager, Message message, Transaction tx, Queue queue, boolean sync) Constructors in org.apache.activemq.artemis.core.postoffice.impl with parameters of type StorageManagerModifierConstructorDescriptionBindingsImpl(SimpleString name, GroupingHandler groupingHandler, StorageManager storageManager) PostOfficeImpl(ActiveMQServer server, StorageManager storageManager, PagingManager pagingManager, QueueFactory bindableFactory, ManagementService managementService, long expiryReaperPeriod, long addressQueueReaperPeriod, WildcardConfiguration wildcardConfiguration, int idCacheSize, boolean persistIDCache, HierarchicalRepository<AddressSettings> addressSettingsRepository) SimpleAddressManager(BindingsFactory bindingsFactory, WildcardConfiguration wildcardConfiguration, StorageManager storageManager, MetricsManager metricsManager) SimpleAddressManager(BindingsFactory bindingsFactory, StorageManager storageManager, MetricsManager metricsManager) WildcardAddressManager(BindingsFactory bindingsFactory, WildcardConfiguration wildcardConfiguration, StorageManager storageManager, MetricsManager metricsManager) WildcardAddressManager(BindingsFactory bindingsFactory, StorageManager storageManager, MetricsManager metricsManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.protocol
Constructors in org.apache.activemq.artemis.core.protocol with parameters of type StorageManager -
Uses of StorageManager in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return StorageManagerModifier and TypeMethodDescriptionActiveMQServer.getStorageManager()LargeServerMessage.getStorageManager()Methods in org.apache.activemq.artemis.core.server with parameters of type StorageManagerModifier and TypeMethodDescriptionConnectorServiceFactory.createConnectorService(String connectorName, Map<String, Object> configuration, StorageManager storageManager, PostOffice postOffice, ScheduledExecutorService scheduledThreadPool) voidLargeServerMessage.setStorageManager(StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type StorageManagerModifier and TypeMethodDescriptionActiveMQServerSideProtocolManagerFactory.getInstance(ServerLocator locator, StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.cluster.impl
Constructors in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type StorageManagerModifierConstructorDescriptionClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManager clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int initialConnectAttempts, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, long targetNodeEventUID, String targetNodeID, SimpleString name, Queue queue, Executor executor, Filter filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager, String clientId) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.group.impl
Constructors in org.apache.activemq.artemis.core.server.group.impl with parameters of type StorageManagerModifierConstructorDescriptionLocalGroupingHandler(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, ManagementService managementService, SimpleString name, SimpleString address, StorageManager storageManager, long timeout, long groupTimeout, long reaperPeriod) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.impl
Fields in org.apache.activemq.artemis.core.server.impl declared as StorageManagerModifier and TypeFieldDescriptionprotected final StorageManagerQueueFactoryImpl.storageManagerprotected final StorageManagerServerSessionImpl.storageManagerMethods in org.apache.activemq.artemis.core.server.impl that return StorageManagerModifier and TypeMethodDescriptionprotected StorageManagerActiveMQServerImpl.createStorageManager()This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)ActiveMQServerImpl.getStorageManager()ServerSessionImpl.getStorageManager()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type StorageManagerModifier and TypeMethodDescriptionActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) create the Journal loader needed for this Activation.SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) voidAddressInfo.setStorageManager(StorageManager storageManager) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type StorageManagerModifierConstructorDescriptionBackupRecoveryJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer, ServerLocatorInternal locator, ClusterController clusterController) ConnectorsService(Configuration configuration, StorageManager storageManager, ScheduledExecutorService scheduledPool, PostOffice postOffice, ServiceRegistry serviceRegistry) DivertImpl(SimpleString uniqueName, SimpleString address, SimpleString forwardAddress, SimpleString routingName, boolean exclusive, Filter filter, Transformer transformer, PostOffice postOffice, StorageManager storageManager, ComponentConfigurationRoutingType routingType) LastValueQueue(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration) PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, Map<Long, Queue> queues) QueueFactoryImpl(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, HierarchicalRepository<AddressSettings> addressSettingsRepository, StorageManager storageManager, ActiveMQServer server) QueueImpl(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) RefsOperation(Queue queue, AckReason reason, StorageManager storageManager) ScaleDownHandler(PagingManager pagingManager, PostOffice postOffice, NodeManager nodeManager, ClusterController clusterController, StorageManager storageManager, int commitInterval) ServerConsumerImpl(long id, ServerSession session, QueueBinding binding, Filter filter, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService, boolean supportLargeMessage, Integer credits, ActiveMQServer server) ServerConsumerImpl(long id, ServerSession session, QueueBinding binding, Filter filter, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService, ActiveMQServer server) ServerConsumerImpl(long id, ServerSession session, QueueBinding binding, Filter filter, int priority, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService, boolean supportLargeMessage, Integer credits, ActiveMQServer server) ServerSessionImpl(String name, String username, String password, String validatedUser, int minLargeMessageSize, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean strictUpdateDeliveryCount, boolean xa, RemotingConnection remotingConnection, StorageManager storageManager, PostOffice postOffice, ResourceManager resourceManager, SecurityStore securityStore, ManagementService managementService, ActiveMQServer server, SimpleString managementAddress, SimpleString defaultAddress, SessionCallback callback, OperationContext context, PagingManager pagingManager, Map<SimpleString, RoutingType> prefixes, String securityDomain, boolean isLegacyProducer) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.management
Methods in org.apache.activemq.artemis.core.server.management with parameters of type StorageManagerModifier and TypeMethodDescriptionvoidManagementService.registerQueue(Queue queue, SimpleString address, StorageManager storageManager) ManagementService.registerServer(PostOffice postOffice, SecurityStore securityStore, StorageManager storageManager, Configuration configuration, HierarchicalRepository<AddressSettings> addressSettingsRepository, HierarchicalRepository<Set<Role>> securityRepository, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, QueueFactory queueFactory, ScheduledExecutorService scheduledThreadPool, PagingManager pagingManager, boolean backup) voidManagementService.setStorageManager(StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.management.impl
Methods in org.apache.activemq.artemis.core.server.management.impl with parameters of type StorageManagerModifier and TypeMethodDescriptionvoidManagementServiceImpl.registerQueue(Queue queue, SimpleString address, StorageManager storageManager) ManagementServiceImpl.registerServer(PostOffice postOffice, SecurityStore securityStore, StorageManager storageManager1, Configuration configuration, HierarchicalRepository<AddressSettings> addressSettingsRepository, HierarchicalRepository<Set<Role>> securityRepository, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, QueueFactory queueFactory, ScheduledExecutorService scheduledThreadPool, PagingManager pagingManager, boolean backup) voidManagementServiceImpl.setStorageManager(StorageManager storageManager) Constructors in org.apache.activemq.artemis.core.server.management.impl with parameters of type StorageManagerModifierConstructorDescriptionHawtioSecurityControlImpl(GuardInvocationHandler mBeanServerGuard, StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.server.routing.caches
Constructors in org.apache.activemq.artemis.core.server.routing.caches with parameters of type StorageManagerModifierConstructorDescriptionLocalCache(String id, boolean persisted, int timeout, StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.core.transaction.impl
Fields in org.apache.activemq.artemis.core.transaction.impl declared as StorageManagerConstructors in org.apache.activemq.artemis.core.transaction.impl with parameters of type StorageManagerModifierConstructorDescriptionBindingsTransactionImpl(StorageManager storage) TransactionImpl(long id, Xid xid, StorageManager storageManager) TransactionImpl(Xid xid, StorageManager storageManager, int timeoutSeconds) TransactionImpl(StorageManager storageManager) TransactionImpl(StorageManager storageManager, int timeoutSeconds) -
Uses of StorageManager in org.apache.activemq.artemis.spi.core.protocol
Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type StorageManagerModifier and TypeMethodDescriptionMessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager) static MessageEmbedMessageUtil.extractEmbedded(ICoreMessage message, StorageManager storageManager) MessageConverter.fromCore(ICoreMessage coreMessage, StorageManager storageManager) -
Uses of StorageManager in org.apache.activemq.artemis.spi.core.security
Methods in org.apache.activemq.artemis.spi.core.security with parameters of type StorageManagerModifier and TypeMethodDescriptionvoidActiveMQBasicSecurityManager.completeInit(StorageManager storageManager)