diff --git a/Examples/src/main/java/io/github/jwdeveloper/tiktok/CollectorExample.java b/Examples/src/main/java/io/github/jwdeveloper/tiktok/CollectorExample.java index 1e26212..53a295f 100644 --- a/Examples/src/main/java/io/github/jwdeveloper/tiktok/CollectorExample.java +++ b/Examples/src/main/java/io/github/jwdeveloper/tiktok/CollectorExample.java @@ -24,11 +24,9 @@ package io.github.jwdeveloper.tiktok; import io.github.jwdeveloper.tiktok.extension.collector.TikTokLiveCollector; -import org.bson.Document; import java.io.IOException; -import java.util.List; -import java.util.Map; +import java.util.*; public class CollectorExample { @@ -59,10 +57,10 @@ public class CollectorExample { { event.getException().printStackTrace(); }) - .addListener(collector.newListener(additionalDataFields, o -> + .addListener(collector.newListener(additionalDataFields, document -> { //filtering document data before it is inserted to database - if (o instanceof Document document && document.get("dataType") == "message") { + if (document.get("dataType") == "message") { return false; } return true; diff --git a/extension-collector/src/main/java/io/github/jwdeveloper/tiktok/extension/collector/api/settings/mongo/MongoDataCollectorSettings.java b/extension-collector/src/main/java/io/github/jwdeveloper/tiktok/extension/collector/api/settings/mongo/MongoDataCollectorSettings.java index 3d319ab..bca2564 100644 --- a/extension-collector/src/main/java/io/github/jwdeveloper/tiktok/extension/collector/api/settings/mongo/MongoDataCollectorSettings.java +++ b/extension-collector/src/main/java/io/github/jwdeveloper/tiktok/extension/collector/api/settings/mongo/MongoDataCollectorSettings.java @@ -29,7 +29,6 @@ import java.util.function.Consumer; @Data public class MongoDataCollectorSettings { - @Setter private String connectionUrl; private String databaseName = "tiktok";