private void logRequest()

in crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/SolrMessageProcessor.java [198:220]


    private void logRequest(SolrRequest request) {
        if(request instanceof UpdateRequest) {
            final StringBuilder rmsg = new StringBuilder(64);
            String collection = request.getCollection();
            rmsg.append("Submitting update request for collection=").append(collection != null ? collection : request.getParams().get("collection"));
            if(((UpdateRequest) request).getDeleteById() != null) {
                final int numDeleteByIds = ((UpdateRequest) request).getDeleteById().size();
                metrics.counter("numDeleteByIds").inc(numDeleteByIds);
                rmsg.append(" numDeleteByIds=").append(numDeleteByIds);
            }
            if(((UpdateRequest) request).getDocuments() != null) {
                final int numUpdates = ((UpdateRequest) request).getDocuments().size();
                metrics.counter("numUpdates").inc(numUpdates);
                rmsg.append(" numUpdates=").append(numUpdates);
            }
            if(((UpdateRequest) request).getDeleteQuery() != null) {
                final int numDeleteByQuery = ((UpdateRequest) request).getDeleteQuery().size();
                metrics.counter("numDeleteByQuery").inc(numDeleteByQuery);
                rmsg.append(" numDeleteByQuery=").append(numDeleteByQuery);
            }
            log.info(rmsg.toString());
        }
    }