Skip to content

Commit 71a4087

Browse files
committed
first attempt at moving Batch deserialization out of the lock
1 parent 768dc71 commit 71a4087

File tree

1 file changed

+19
-0
lines changed

1 file changed

+19
-0
lines changed
Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
package org.logstash.ackedqueue;
2+
3+
import java.util.List;
4+
5+
public class DeserializedBatch {
6+
private final List<byte[]> elements;
7+
private final long firstSeqNum;
8+
private final Queue queue;
9+
10+
public DeserializedBatch(List<byte[]> elements, long firstSeqNum, Queue queue) {
11+
this.elements = elements;
12+
this.firstSeqNum = firstSeqNum;
13+
this.queue = queue;
14+
}
15+
16+
public Batch deserialize() {
17+
return new Batch(elements, firstSeqNum, queue);
18+
}
19+
}

0 commit comments

Comments
 (0)