Modifier and Type | Field and Description |
---|---|
protected StorageManager |
AbstractControl.storageManager |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfo.checkSize(StorageManager storageManager,
PagingManager pagingManager) |
void |
PagedMessage.initMessage(StorageManager storageManager) |
PageCursorProvider |
PagingStoreFactory.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
boolean |
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,
ArtemisExecutor executor,
int maxCacheSize) |
PageCursorProviderImpl(PagingStore pagingStore,
StorageManager storageManager,
ArtemisExecutor executor,
int maxCacheSize,
boolean readWholePage) |
PageSubscriptionCounterImpl(StorageManager storage,
PageSubscription subscription,
Executor executor,
boolean persistent,
long subscriptionID) |
Modifier and Type | Field and Description |
---|---|
protected StorageManager |
PagingStoreFactoryDatabase.storageManager |
Modifier and Type | Method and Description |
---|---|
StorageManager |
PagingStoreFactoryNIO.getStorageManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
PageTransactionInfoImpl.checkSize(StorageManager storageManager,
PagingManager pagingManager) |
void |
PagedMessageImpl.initMessage(StorageManager storage) |
boolean |
PageTransactionInfoImpl.internalCheckSize(StorageManager storageManager,
PagingManager pagingManager,
int size) |
protected org.apache.activemq.artemis.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation |
PageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
PageCursorProvider |
PagingStoreFactoryDatabase.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
PageCursorProvider |
PagingStoreFactoryNIO.newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
boolean |
PageTransactionInfoImpl.onUpdate(int update,
StorageManager storageManager,
PagingManager pagingManager) |
List<PagedMessage> |
Page.read(StorageManager storage) |
List<PagedMessage> |
Page.read(StorageManager storage,
boolean onlyLargeMessages) |
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) |
PagedMessageImpl(int storedSize,
StorageManager storageManager) |
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener criticalErrorListener) |
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener criticalErrorListener,
boolean readWholePage) |
PagingStoreFactoryNIO(StorageManager storageManager,
File directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener) |
PagingStoreFactoryNIO(StorageManager storageManager,
File directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener,
boolean readWholePage) |
PagingStoreImpl(SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
SimpleString storeName,
AddressSettings addressSettings,
ArtemisExecutor executor,
ArtemisExecutor ioExecutor,
boolean syncNonTransactional) |
PagingStoreImpl(SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
SimpleString storeName,
AddressSettings addressSettings,
ArtemisExecutor executor,
boolean syncNonTransactional) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJournalStorageManager
Controls access to the journals and other storage files such as the ones used to store pages and
large messages.
|
class |
JDBCJournalStorageManager |
class |
JournalStorageManager |
Modifier and Type | Method and Description |
---|---|
StorageManager |
LargeBody.getStorageManager() |
StorageManager |
LargeServerMessageImpl.getStorageManager() |
Modifier and Type | Method and Description |
---|---|
static Message |
LargeServerMessageImpl.checkLargeMessage(Message message,
StorageManager storageManager)
This will check if a regular message needs to be converted as large message
|
void |
LargeBody.setStorageManager(StorageManager storageManager) |
void |
LargeServerMessageImpl.setStorageManager(StorageManager storageManager) |
Constructor and Description |
---|
BatchingIDGenerator(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) |
Modifier and Type | Class and Description |
---|---|
class |
NullStorageManager |
Constructor and Description |
---|
DuplicateIDCacheImpl(SimpleString address,
int size,
StorageManager storageManager,
boolean persist) |
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,
StorageManager storageManager,
MetricsManager metricsManager) |
SimpleAddressManager(BindingsFactory bindingsFactory,
WildcardConfiguration wildcardConfiguration,
StorageManager storageManager,
MetricsManager metricsManager) |
WildcardAddressManager(BindingsFactory bindingsFactory,
StorageManager storageManager,
MetricsManager metricsManager) |
WildcardAddressManager(BindingsFactory bindingsFactory,
WildcardConfiguration wildcardConfiguration,
StorageManager storageManager,
MetricsManager metricsManager) |
Constructor and Description |
---|
ServerPacketDecoder(StorageManager storageManager) |
Constructor and Description |
---|
ServerSessionPacketHandler(ActiveMQServer server,
CoreProtocolManager manager,
ServerSession session,
StorageManager storageManager,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
StorageManager |
ActiveMQServer.getStorageManager() |
StorageManager |
LargeServerMessage.getStorageManager() |
Modifier and Type | Method and Description |
---|---|
ConnectorService |
ConnectorServiceFactory.createConnectorService(String connectorName,
Map<String,Object> configuration,
StorageManager storageManager,
PostOffice postOffice,
ScheduledExecutorService scheduledThreadPool) |
void |
LargeServerMessage.setStorageManager(StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
static ActiveMQServerSideProtocolManagerFactory |
ActiveMQServerSideProtocolManagerFactory.getInstance(ServerLocator locator,
StorageManager storageManager) |
Constructor and Description |
---|
ClusterConnectionBridge(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,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector,
String storeAndForwardPrefix,
StorageManager storageManager) |
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 |
protected StorageManager |
ServerSessionImpl.storageManager |
Modifier and Type | Method and Description |
---|---|
protected StorageManager |
ActiveMQServerImpl.createStorageManager()
This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)
|
StorageManager |
ActiveMQServerImpl.getStorageManager() |
StorageManager |
ServerSessionImpl.getStorageManager() |
Modifier and Type | Method and Description |
---|---|
JournalLoader |
Activation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
JournalLoader |
SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
QueueFactory queueFactory,
NodeManager nodeManager,
ManagementService managementService,
GroupingHandler groupingHandler,
Configuration configuration,
ActiveMQServer parentServer) |
void |
AddressInfo.setStorageManager(StorageManager storageManager) |
Constructor and Description |
---|
BackupRecoveryJournalLoader(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(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) |
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(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(long id,
SimpleString address,
SimpleString name,
Filter filter,
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) |
RefsOperation(Queue queue,
AckReason reason,
StorageManager storageManager) |
ScaleDownHandler(PagingManager pagingManager,
PostOffice postOffice,
NodeManager nodeManager,
ClusterController clusterController,
StorageManager storageManager) |
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,
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,
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) |
Modifier and Type | Method and Description |
---|---|
HawtioSecurityControl |
ManagementContext.getSecurityMBean(StorageManager storageManager) |
void |
ManagementService.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
ActiveMQServerControlImpl |
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) |
void |
ManagementService.setStorageManager(StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerQueue(Queue queue,
AddressInfo addressInfo,
StorageManager storageManager) |
void |
ManagementServiceImpl.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
ActiveMQServerControlImpl |
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) |
void |
ManagementServiceImpl.setStorageManager(StorageManager storageManager) |
Constructor and Description |
---|
HawtioSecurityControlImpl(ArtemisMBeanServerGuard mBeanServerGuard,
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(long id,
Xid xid,
StorageManager storageManager,
boolean sorted) |
TransactionImpl(StorageManager storageManager) |
TransactionImpl(StorageManager storageManager,
boolean sorted) |
TransactionImpl(StorageManager storageManager,
int timeoutSeconds) |
TransactionImpl(Xid xid,
StorageManager storageManager,
int timeoutSeconds) |
TransactionImpl(Xid xid,
StorageManager storageManager,
int timeoutSeconds,
boolean sorted) |
Modifier and Type | Method and Description |
---|---|
Message |
MessagePersister.decode(ActiveMQBuffer buffer,
Message record,
CoreMessageObjectPools pools,
StorageManager storageManager) |
static Message |
EmbedMessageUtil.extractEmbedded(ICoreMessage message,
StorageManager storageManager) |
ProtocolMessage |
MessageConverter.fromCore(ICoreMessage coreMessage,
StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQBasicSecurityManager.completeInit(StorageManager storageManager) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.