Refactor worker connection unsubscribe method