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(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,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
void |
ActiveMQServerLogger.problemCompletingOperations(OperationContext e) |
void |
Queue.recheckRefCount(OperationContext context)
This is to perform a check on the counter again
|
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,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
protected ServerSessionImpl |
ActiveMQServerImpl.internalCreateSession(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
OperationContext context,
boolean autoCreateJMSQueues,
Map<SimpleString,RoutingType> prefixes) |
void |
QueueImpl.recheckRefCount(OperationContext context) |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerPlugin.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes)
Before a session is created.
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPluginLogger.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String publicAddress,
OperationContext context) |
void |
LoggingActiveMQServerPlugin.beforeCreateSession(String name,
String username,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String publicAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes)
Before a session is created.
|
Copyright © 2019 JBoss by Red Hat. All rights reserved.