Github user clebertsuconic commented on a diff in the pull request:

    https://github.com/apache/activemq-artemis/pull/1638#discussion_r148796005
  
    --- Diff: 
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/actors/ProcessorBase.java
 ---
    @@ -109,12 +125,49 @@ public final boolean isFlushed() {
           return stateUpdater.get(this) == STATE_NOT_RUNNING;
        }
     
    -   protected void task(T command) {
    --- End diff --
    
    What about just fix the offending flush than add this complex piece?


---

Reply via email to