[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GitHub] activemq-artemis pull request #2075: ARTEMIS-1852 PageCursorProvider is leak...

Github user clebertsuconic commented on a diff in the pull request:
    --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/ ---
    @@ -239,8 +239,28 @@ public void stop() {
           for (PageSubscription cursor : activeCursors.values()) {
    -      executor.shutdownNow();
    +      int pendingCleanupTasks = scheduledCleanup.get();
    --- End diff --
    Nice catch.. very nice...
    However.. I'm not sure why we were calling shutdown here. PageCursor doesn't own the executor...
    this is using ArtemisExecutor. where shutdownNow will call an empty method.. and getPendingTasks will return also an empty array.
    I think the only thing you should do here is call the flush method.