ARTEMIS-1069 Artemis unsafe usage on Eventls polling

artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java

@@ -143,10 +143,6 @@ public class AMQPConnectionContext extends ProtonInitializable {
       handler.flush();
    }
 
-   public void flush(boolean wait) {
-      handler.flush(wait);
-   }
-
    public void close(ErrorCondition errorCondition) {
       handler.close(errorCondition);
    }

artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/handler/ProtonHandler.java

@@ -56,12 +56,7 @@ public class ProtonHandler extends ProtonInitializable {
 
    private final Executor dispatchExecutor;
 
-   private final Runnable dispatchRunnable = new Runnable() {
+   private final Runnable dispatchRunnable = () -> dispatch();
-      @Override
-      public void run() {
-         dispatch();
-      }
-   };
 
    private ArrayList<EventHandler> handlers = new ArrayList<>();
 
@@ -251,23 +246,13 @@ public class ProtonHandler extends ProtonInitializable {
    }
 
    public void flush() {
-      flush(false);
-   }
-
-   public void flush(boolean wait) {
       synchronized (lock) {
          transport.process();
-
          checkServerSASL();
-
       }
 
-      if (wait) {
-         dispatch();
-      } else {
       dispatchExecutor.execute(dispatchRunnable);
    }
-   }
 
    public void close(ErrorCondition errorCondition) {
       synchronized (lock) {
@@ -276,7 +261,8 @@ public class ProtonHandler extends ProtonInitializable {
          }
          connection.close();
       }
-      flush(true);
+
+      flush();
    }
 
    protected void checkServerSASL() {