mirror of
https://github.com/jwdeveloper/TikTokLiveJava.git
synced 2026-02-27 16:59:39 -05:00
Fixed CollectorExample and removed useless @Setter in MongoDataCollectorSettings!
This commit is contained in:
@@ -24,11 +24,9 @@ package io.github.jwdeveloper.tiktok;
|
|||||||
|
|
||||||
|
|
||||||
import io.github.jwdeveloper.tiktok.extension.collector.TikTokLiveCollector;
|
import io.github.jwdeveloper.tiktok.extension.collector.TikTokLiveCollector;
|
||||||
import org.bson.Document;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.*;
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
public class CollectorExample {
|
public class CollectorExample {
|
||||||
|
|
||||||
@@ -59,10 +57,10 @@ public class CollectorExample {
|
|||||||
{
|
{
|
||||||
event.getException().printStackTrace();
|
event.getException().printStackTrace();
|
||||||
})
|
})
|
||||||
.addListener(collector.newListener(additionalDataFields, o ->
|
.addListener(collector.newListener(additionalDataFields, document ->
|
||||||
{
|
{
|
||||||
//filtering document data before it is inserted to database
|
//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 false;
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
|
|||||||
@@ -29,7 +29,6 @@ import java.util.function.Consumer;
|
|||||||
@Data
|
@Data
|
||||||
public class MongoDataCollectorSettings {
|
public class MongoDataCollectorSettings {
|
||||||
|
|
||||||
@Setter
|
|
||||||
private String connectionUrl;
|
private String connectionUrl;
|
||||||
|
|
||||||
private String databaseName = "tiktok";
|
private String databaseName = "tiktok";
|
||||||
|
|||||||
Reference in New Issue
Block a user