Skip to content

Commit b4a6109

Browse files
committed
minor naming tweak
1 parent 103a05e commit b4a6109

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

  • logstash-core/src/main/java/org/logstash/ackedqueue

logstash-core/src/main/java/org/logstash/ackedqueue/Queue.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff 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.

0 commit comments

Comments
 (0)