clebertsuconic commented on code in PR #6300:
URL: https://github.com/apache/artemis/pull/6300#discussion_r2955538077
##########
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java:
##########
@@ -1161,24 +1162,42 @@ public String getSecurityDomain() {
return securityDomain;
}
- public static class TempResourceCleanerUpper implements CloseListener,
FailureListener {
+ public static class TempResourceCleanerUpper implements CloseListener,
FailureListener , IOCallback {
+
+ final Executor sessionExecutor;
+
+ final OperationContext operationContext;
private final SimpleString resourceName;
private final ActiveMQServer server;
private TempResourceObserver observer;
- public TempResourceCleanerUpper(final ActiveMQServer server, final
SimpleString resourceName) {
+ public TempResourceCleanerUpper(final ActiveMQServer server, final
SimpleString resourceName, final Executor sessionExecutor, OperationContext
context) {
this.server = server;
this.resourceName = resourceName;
+ this.sessionExecutor = sessionExecutor;
+ this.operationContext = context;
}
public void setObserver(TempResourceObserver observer) {
this.observer = observer;
}
private void run() {
+ sessionExecutor.execute(() -> {
Review Comment:
this is just to avoid possible races
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
