Skip to content

Commit 032764e

Browse files
update default poller to use private constructor
Signed-off-by: Varun Bharadwaj <varunbharadwaj1995@gmail.com>
1 parent 21c0daf commit 032764e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/src/main/java/org/opensearch/indices/pollingingest/DefaultStreamPoller.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public class DefaultStreamPoller implements StreamPoller {
8686

8787
private PartitionedBlockingQueueContainer blockingQueueContainer;
8888

89-
public DefaultStreamPoller(
89+
private DefaultStreamPoller(
9090
IngestionShardPointer startPointer,
9191
Set<IngestionShardPointer> persistedPointers,
9292
IngestionConsumerFactory consumerFactory,

0 commit comments

Comments
 (0)