diff --git a/src/main/java/com/coveo/pushapiclient/DocumentUploadQueue.java b/src/main/java/com/coveo/pushapiclient/DocumentUploadQueue.java index 83168820..d3cc8480 100644 --- a/src/main/java/com/coveo/pushapiclient/DocumentUploadQueue.java +++ b/src/main/java/com/coveo/pushapiclient/DocumentUploadQueue.java @@ -64,7 +64,9 @@ public void add(DocumentBuilder document) throws IOException, InterruptedExcepti this.flush(); } documentToAddList.add(document); - logger.info("Adding document to batch: " + document.getDocument().uri); + if (logger.isDebugEnabled()) { + logger.debug("Adding document to batch: " + document.getDocument().uri); + } this.size += sizeOfDoc; } @@ -86,7 +88,9 @@ public void add(DeleteDocument document) throws IOException, InterruptedExceptio this.flush(); } documentToDeleteList.add(document); - logger.info("Adding document to batch: " + document.documentId); + if (logger.isDebugEnabled()) { + logger.debug("Adding document to batch: " + document.documentId); + } this.size += sizeOfDoc; } diff --git a/src/main/java/com/coveo/pushapiclient/StreamDocumentUploadQueue.java b/src/main/java/com/coveo/pushapiclient/StreamDocumentUploadQueue.java index 7a039f7a..c4e6ecd9 100644 --- a/src/main/java/com/coveo/pushapiclient/StreamDocumentUploadQueue.java +++ b/src/main/java/com/coveo/pushapiclient/StreamDocumentUploadQueue.java @@ -56,7 +56,9 @@ public void add(PartialUpdateDocument document) throws IOException, InterruptedE this.flush(); } documentToPartiallyUpdateList.add(document); - logger.info("Adding document to batch: " + document.documentId); + if (logger.isDebugEnabled()) { + logger.debug("Adding document to batch: " + document.documentId); + } this.size += sizeOfDoc; } diff --git a/src/main/java/com/coveo/pushapiclient/UpdateStreamService.java b/src/main/java/com/coveo/pushapiclient/UpdateStreamService.java index 4500d11f..948c3461 100644 --- a/src/main/java/com/coveo/pushapiclient/UpdateStreamService.java +++ b/src/main/java/com/coveo/pushapiclient/UpdateStreamService.java @@ -218,7 +218,6 @@ public HttpResponse close() private UploadStrategy getUploadStrategy() { return (streamUpdate) -> { String batchUpdateJson = new Gson().toJson(streamUpdate.marshal()); - System.out.println(batchUpdateJson); return this.platformClient.uploadContentToFileContainer(fileContainer, batchUpdateJson); }; }