Modifier and Type | Field and Description |
---|---|
protected StorageManager |
AbstractControl.storageManager |
Modifier and Type | Method and Description |
---|---|
void |
PagedMessage.initMessage(StorageManager storageManager) |
void |
PageTransactionInfo.onUpdate(int update,
StorageManager storageManager,
PagingManager pagingManager) |
void |
PageTransactionInfo.reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfo.store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
PageTransactionInfo.storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
Modifier and Type | Field and Description |
---|---|
protected StorageManager |
PageCursorProviderImpl.storageManager |
Constructor and Description |
---|
PageCursorProviderImpl(PagingStore pagingStore,
StorageManager storageManager,
Executor executor,
int maxCacheSize) |
PageSubscriptionCounterImpl(StorageManager storage,
PageSubscription subscription,
Executor executor,
boolean persistent,
long subscriptionID) |
Modifier and Type | Method and Description |
---|---|
void |
PagedMessageImpl.initMessage(StorageManager storage) |
protected org.hornetq.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation |
PageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfoImpl.onUpdate(int update,
StorageManager storageManager,
PagingManager pagingManager) |
List<PagedMessage> |
Page.read(StorageManager storage) |
void |
PageTransactionInfoImpl.reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfoImpl.store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
PageTransactionInfoImpl.storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
Constructor and Description |
---|
Page(SimpleString storeName,
StorageManager storageManager,
SequentialFileFactory factory,
SequentialFile file,
int pageId) |
PagingStoreFactoryNIO(StorageManager storageManager,
String 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,
Executor executor,
boolean syncNonTransactional) |
Modifier and Type | Class and Description |
---|---|
class |
JournalStorageManager
Controls access to the journals and other storage files such as the ones used to store pages and
large messages.
|
Constructor and Description |
---|
BatchingIDGenerator(long start,
long checkpointSize,
StorageManager storageManager) |
LargeServerMessageInSync(StorageManager storageManager) |
Modifier and Type | Class and Description |
---|---|
class |
NullStorageManager
A NullStorageManager
|
Constructor and Description |
---|
DuplicateIDCacheImpl(SimpleString address,
int size,
StorageManager storageManager,
boolean persist) |
PostOfficeImpl(HornetQServer server,
StorageManager storageManager,
PagingManager pagingManager,
QueueFactory bindableFactory,
ManagementService managementService,
long reaperPeriod,
int reaperPriority,
boolean enableWildCardRouting,
int idCacheSize,
boolean persistIDCache,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
Constructor and Description |
---|
ServerSessionPacketHandler(ServerSession session,
StorageManager storageManager,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
StorageManager |
HornetQServer.getStorageManager() |
Modifier and Type | Method and Description |
---|---|
ConnectorService |
ConnectorServiceFactory.createConnectorService(String connectorName,
Map<String,Object> configuration,
StorageManager storageManager,
PostOffice postOffice,
ScheduledExecutorService scheduledThreadPool) |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int reconnectAttempts,
int initialConnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager) |
BridgeImpl(ServerLocatorInternal serverLocator,
int reconnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
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,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
Redistributor(Queue queue,
StorageManager storageManager,
PostOffice postOffice,
Executor executor,
int batchSize) |
Constructor and Description |
---|
LocalGroupingHandler(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
long timeout,
long groupTimeout,
long reaperPeriod) |
Modifier and Type | Field and Description |
---|---|
protected StorageManager |
QueueFactoryImpl.storageManager |
Modifier and Type | Method and Description |
---|---|
protected StorageManager |
HornetQServerImpl.createStorageManager()
This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)
|
StorageManager |
ServerSessionImpl.getStorageManager() |
StorageManager |
HornetQServerImpl.getStorageManager() |
Constructor and Description |
---|
ConnectorsService(Configuration configuration,
StorageManager storageManager,
ScheduledExecutorService scheduledPool,
PostOffice postOffice) |
DivertImpl(SimpleString forwardAddress,
SimpleString uniqueName,
SimpleString routingName,
boolean exclusive,
Filter filter,
Transformer transformer,
PostOffice postOffice,
StorageManager storageManager) |
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,
QueueFactory factory,
CriticalAnalyzer analyzer) |
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager,
CriticalAnalyzer analyzer) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor,
QueueFactory factory,
CriticalAnalyzer analyzer) |
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) |
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,
QueueFactory factory,
CriticalAnalyzer analyzer) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService) |
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) |
ServerSessionImpl(String name,
String username,
String password,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
HornetQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementService.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
HornetQServerControlImpl |
ManagementService.registerServer(PostOffice postOffice,
StorageManager storageManager,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
void |
ManagementService.setStorageManager(StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
HornetQServerControlImpl |
ManagementServiceImpl.registerServer(PostOffice postOffice,
StorageManager storageManager1,
Configuration configuration,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
HierarchicalRepository<Set<Role>> securityRepository,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
QueueFactory queueFactory,
ScheduledExecutorService scheduledThreadPool,
PagingManager pagingManager,
boolean backup) |
void |
ManagementServiceImpl.setStorageManager(StorageManager storageManager) |
Modifier and Type | Field and Description |
---|---|
protected StorageManager |
TransactionImpl.storageManager |
Constructor and Description |
---|
BindingsTransactionImpl(StorageManager storage) |
TransactionImpl(long id,
Xid xid,
StorageManager storageManager) |
TransactionImpl(StorageManager storageManager) |
TransactionImpl(StorageManager storageManager,
int timeoutSeconds) |
TransactionImpl(Xid xid,
StorageManager storageManager,
int timeoutSeconds) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.