| Modifier and Type | Method and Description |
|---|---|
OperationContext |
StorageManager.getContext()
Get the context associated with the thread for later reuse
|
OperationContext |
StorageManager.newContext(Executor executor)
It just creates an OperationContext without associating it
|
OperationContext |
StorageManager.newSingleThreadContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
StorageManager.setContext(OperationContext context)
Set the context back to the thread
|
| Modifier and Type | Class and Description |
|---|---|
class |
OperationContextImpl
Each instance of OperationContextImpl is associated with an executor (usually an ordered Executor).
|
| Modifier and Type | Method and Description |
|---|---|
static OperationContext |
OperationContextImpl.getContext() |
OperationContext |
AbstractJournalStorageManager.getContext() |
static OperationContext |
OperationContextImpl.getContext(org.apache.activemq.artemis.utils.ExecutorFactory executorFactory) |
OperationContext |
AbstractJournalStorageManager.newContext(Executor executor1) |
OperationContext |
AbstractJournalStorageManager.newSingleThreadContext() |
| Modifier and Type | Method and Description |
|---|---|
static void |
OperationContextImpl.setContext(OperationContext context) |
void |
AbstractJournalStorageManager.setContext(OperationContext context) |
| Modifier and Type | Method and Description |
|---|---|
OperationContext |
NullStorageManager.getContext() |
OperationContext |
NullStorageManager.newContext(Executor executor) |
OperationContext |
NullStorageManager.newSingleThreadContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
NullStorageManager.setContext(OperationContext context) |
| Modifier and Type | Method and Description |
|---|---|
OperationContext |
ReplicationManager.sendLiveIsStopping(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage)
Notifies the backup that the live server is stopping.
|
| Modifier and Type | Method and Description |
|---|---|
Set<OperationContext> |
ReplicationManager.getActiveTokens()
A list of tokens that are still waiting for replications to be completed
|
| Modifier and Type | Method and Description |
|---|---|
OperationContext |
ServerSession.getSessionContext() |
OperationContext |
ActiveMQServer.newOperationContext() |
| Modifier and Type | Method and Description |
|---|---|
ServerSession |
ActiveMQServer.createSession(String name,
String username,
String password,
int minLargeMessageSize,
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context) |
void |
ActiveMQServerLogger.problemCompletingOperations(OperationContext e) |
| Modifier and Type | Method and Description |
|---|---|
OperationContext |
ServerSessionImpl.getSessionContext() |
OperationContext |
ActiveMQServerImpl.newOperationContext() |
| Modifier and Type | Method and Description |
|---|---|
ServerSession |
ActiveMQServerImpl.createSession(String name,
String username,
String password,
int minLargeMessageSize,
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context) |
protected ServerSessionImpl |
ActiveMQServerImpl.internalCreateSession(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
OperationContext context,
boolean autoCreateJMSQueues) |
| Constructor and Description |
|---|
ServerSessionImpl(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
org.apache.activemq.artemis.api.core.SimpleString managementAddress,
org.apache.activemq.artemis.api.core.SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
QueueCreator queueCreator,
PagingManager pagingManager) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.