File tree Expand file tree Collapse file tree
logstash-core/src/main/java/org/logstash/ackedqueue Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -613,10 +613,10 @@ public synchronized Batch nonBlockReadBatch(int limit) throws IOException {
613613 * @throws IOException if an IO error occurs
614614 */
615615 public Batch readBatch (int limit , long timeout ) throws IOException {
616- return readDeserializedBatch (limit , timeout ).deserialize ();
616+ return readSerializedBatch (limit , timeout ).deserialize ();
617617 }
618618
619- private synchronized SerializedBatchHolder readDeserializedBatch (int limit , long timeout ) throws IOException {
619+ private synchronized SerializedBatchHolder readSerializedBatch (int limit , long timeout ) throws IOException {
620620 lock .lock ();
621621
622622 try {
@@ -627,7 +627,7 @@ private synchronized SerializedBatchHolder readDeserializedBatch(int limit, long
627627 }
628628
629629 /**
630- * read a {@link Batch } from the given {@link Page}. If the page is a head page, try to maximize the
630+ * read a {@link SerializedBatchHolder } from the given {@link Page}. If the page is a head page, try to maximize the
631631 * batch size by waiting for writes.
632632 * @param p the {@link Page} to read from.
633633 * @param limit size limit of the batch to read.
You can’t perform that action at this time.
0 commit comments