Skip to content

Commit 0d8c268

Browse files
committed
test(batch): provide executor for running after-close events
1 parent e339dc4 commit 0d8c268

2 files changed

Lines changed: 105 additions & 80 deletions

File tree

src/main/java/io/weaviate/client6/v1/api/collections/batch/BatchContext.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@
5353
* @param <PropertiesT> the shape of properties for inserted objects.
5454
*/
5555
public final class BatchContext<PropertiesT> implements Closeable {
56-
private final int maxReconnectRetries = 5;
56+
private final int maxReconnectRetries;
5757

5858
private final CollectionDescriptor<PropertiesT> collectionDescriptor;
5959
private final CollectionHandleDefaults collectionHandleDefaults;
@@ -164,6 +164,7 @@ public final class BatchContext<PropertiesT> implements Closeable {
164164

165165
this.queue = new ArrayBlockingQueue<>(queueSize);
166166
this.batch = new Batch(batchSize, maxSizeBytes);
167+
this.maxReconnectRetries = maxReconnectRetries;
167168
}
168169

169170
private BatchContext(Builder<PropertiesT> builder) {

0 commit comments

Comments
 (0)