Github user franz1981 commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2393#discussion_r227822843
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
---
@@ -349,7 +349,9 @@ public boolean supportsDirectDelivery() {
@Override
public HandleStatus handle(final MessageReference ref) throws Exception
{
- if (callback != null && !callback.hasCredits(this) ||
availableCredits != null && availableCredits.get() <= 0) {
+ // available credits can be set back to null with a flow control
option.
+ AtomicInteger checkInteger = availableCredits;
--- End diff --
nice!
---
