final OperationInfo info = new OperationInfo();
                        info.name = getStringValue(source, "name");
                        info.instanceId = getStringValue(source, "instanceId");
                        info.hostname = getStringValue(source, "hostname");
                        info.status = getStringValue(source, "status");
                        info.createdTime = getLongValue(source, "createdTime");

        for (final Map<String, Object> doc : documents) {
            final String title = getStringValue(doc, "title");
            final String url = getStringValue(doc, "url");
            final String content = getStringValue(doc, "content");
            final String description = getStringValue(doc, "content_description");

            final StringBuilder docContext = new StringBuilder();

        assertEquals("operation", coordinatorHelper.getStringValue(source, "type"));
        assertEquals("reindex", coordinatorHelper.getStringValue(source, "name"));
        assertEquals("node1@host1", coordinatorHelper.getStringValue(source, "instanceId"));
        assertEquals("host1", coordinatorHelper.getStringValue(source, "hostname"));
        assertEquals("running", coordinatorHelper.getStringValue(source, "status"));
    }