Skip to content

Commit

Permalink
FFM-12087 Remove flush from LocalConnector as not supported there
Browse files Browse the repository at this point in the history
  • Loading branch information
erdirowlands committed Oct 4, 2024
1 parent f7640f2 commit eac0984
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
import java.util.Date;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import lombok.NonNull;
Expand All @@ -42,7 +41,6 @@ public class LocalConnector implements Connector, AutoCloseable {
private static final String SEGMENTS = "segments";
private final String source;
private final Gson gson = new Gson();
private final AtomicBoolean isShuttingDown = new AtomicBoolean(false);

static {
LogUtil.setSystemProps();
Expand Down Expand Up @@ -199,13 +197,12 @@ public void close() {

@Override
public boolean getShouldFlushAnalyticsOnClose() {
// TODO - do we want to support flush for local connector? need to pass it in somehow
return false;
}

@Override
public void setIsShuttingDown() {
isShuttingDown.set(true);
// No need for local connector as no retries used
}

private class FileWatcherService implements Service, AutoCloseable {
Expand Down

0 comments on commit eac0984

Please sign in to comment.