// create
                response = client.prepareIndex()
                        .setIndex(index)
                        .setSource(new DocMap(source))
                        .setRefreshPolicy(RefreshPolicy.IMMEDIATE)
                        .setOpType(OpType.CREATE)
                        .execute()
                        .actionGet(fessConfig.getIndexIndexTimeout());
            } else {

                user.setSurname(user.getName());
            }

            ComponentUtil.getAuthenticationManager().insert(user);

            userBhv.insertOrUpdate(user, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });

            if (logger.isInfoEnabled()) {
                logger.info("User {} completed successfully: username={}, id={}", isUpdate ? "update" : "create", username, user.getId());

        final SearchLogBhv searchLogBhv = ComponentUtil.getComponent(SearchLogBhv.class);
        searchLogBhv.batchUpdate(searchLogList, op -> {
            op.setRefreshPolicy(Constants.TRUE);
        });
    }

    /**
     * Processes the click log queue.
     *
     * @param queue The click log queue.
     */

                            upsertMap.put(fessConfig.getIndexFieldFavoriteCount(), 1);
                            builder.setUpsert(upsertMap);
                            builder.setRefreshPolicy(Constants.TRUE);
                        });

                        writeJsonResponse(HttpServletResponse.SC_CREATED, escapeJsonKeyValue(RESULT_FIELD, "created"));

                    })