Fixing a bug where completion stage's next step is called on forkjoinpool instead of the internal threadpool. (#396)
This commit is contained in:
Родитель
078f1a0cd9
Коммит
4370a8f952
|
@ -108,7 +108,7 @@ class MessageReceiver extends InitializableEntity implements IMessageReceiver, I
|
||||||
if (TRACE_LOGGER.isInfoEnabled()) {
|
if (TRACE_LOGGER.isInfoEnabled()) {
|
||||||
TRACE_LOGGER.info("Created MessagingFactory to namespace '{}'", this.namespaceEndpointURI.toString());
|
TRACE_LOGGER.info("Created MessagingFactory to namespace '{}'", this.namespaceEndpointURI.toString());
|
||||||
}
|
}
|
||||||
});
|
}, MessagingFactory.INTERNAL_THREAD_POOL);
|
||||||
} else {
|
} else {
|
||||||
factoryFuture = CompletableFuture.completedFuture(null);
|
factoryFuture = CompletableFuture.completedFuture(null);
|
||||||
}
|
}
|
||||||
|
|
|
@ -73,7 +73,7 @@ final class MessageSender extends InitializableEntity implements IMessageSender
|
||||||
if (TRACE_LOGGER.isInfoEnabled()) {
|
if (TRACE_LOGGER.isInfoEnabled()) {
|
||||||
TRACE_LOGGER.info("Created MessagingFactory to namespace '{}'", this.namespaceEndpointURI.toString());
|
TRACE_LOGGER.info("Created MessagingFactory to namespace '{}'", this.namespaceEndpointURI.toString());
|
||||||
}
|
}
|
||||||
});
|
}, MessagingFactory.INTERNAL_THREAD_POOL);
|
||||||
} else {
|
} else {
|
||||||
factoryFuture = CompletableFuture.completedFuture(null);
|
factoryFuture = CompletableFuture.completedFuture(null);
|
||||||
}
|
}
|
||||||
|
|
|
@ -776,7 +776,7 @@ public class CoreMessageSender extends ClientEntity implements IAmqpSender, IErr
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return null;
|
return null;
|
||||||
});
|
}, MessagingFactory.INTERNAL_THREAD_POOL);
|
||||||
}
|
}
|
||||||
|
|
||||||
return this.sendLinkReopenFuture;
|
return this.sendLinkReopenFuture;
|
||||||
|
|
2
pom.xml
2
pom.xml
|
@ -13,7 +13,7 @@
|
||||||
<proton-j-version>0.31.0</proton-j-version>
|
<proton-j-version>0.31.0</proton-j-version>
|
||||||
<junit-version>4.12</junit-version>
|
<junit-version>4.12</junit-version>
|
||||||
<slf4j-version>1.7.0</slf4j-version>
|
<slf4j-version>1.7.0</slf4j-version>
|
||||||
<client-current-version>1.2.18</client-current-version>
|
<client-current-version>1.2.19-SNAPSHOT</client-current-version><!-- Only to port any fixes from 3.1.x branch -->
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
|
Загрузка…
Ссылка в новой задаче