final CoordinatorHelper helper =
                createCapturingHelper("node1@host1", capturedPath, capturedBody, createMockResponse(200, "{\"deleted\":0}"));

        helper.cleanupExpiredDocuments();

        assertNotNull(capturedBody.get());
        assertTrue(capturedBody.get().contains("\"lt\""));
        assertTrue(capturedBody.get().contains("\"expiredTime\""));

                dispatchEvent(event);
            }
        } catch (final Exception e) {
            logger.debug("Failed to process events in poll.", e);
        }

        try {
            cleanupExpiredDocuments();
        } catch (final Exception e) {
            logger.debug("Failed to cleanup expired documents in poll.", e);
        }
    }

    /**