You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by cd...@apache.org on 2019/08/27 13:58:30 UTC
[plc4x] 42/44: reset TriggeredScraperImpl classname
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit 7f328e580f0a958aa8ae2dd30ddb35df19f25ddd
Author: Till Voss <ti...@codecentric.de>
AuthorDate: Tue Aug 27 15:44:37 2019 +0200
reset TriggeredScraperImpl classname
---
.../src/main/java/org/apache/plc4x/logstash/Plc4x.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/plc4j/integrations/logstash-plugin/src/main/java/org/apache/plc4x/logstash/Plc4x.java b/plc4j/integrations/logstash-plugin/src/main/java/org/apache/plc4x/logstash/Plc4x.java
index ca01f45..7de9230 100644
--- a/plc4j/integrations/logstash-plugin/src/main/java/org/apache/plc4x/logstash/Plc4x.java
+++ b/plc4j/integrations/logstash-plugin/src/main/java/org/apache/plc4x/logstash/Plc4x.java
@@ -24,7 +24,7 @@ import org.apache.plc4x.java.scraper.config.triggeredscraper.JobConfigurationTri
import org.apache.plc4x.java.scraper.config.triggeredscraper.ScraperConfigurationTriggeredImpl;
import org.apache.plc4x.java.scraper.config.triggeredscraper.ScraperConfigurationTriggeredImplBuilder;
import org.apache.plc4x.java.scraper.exception.ScraperException;
-import org.apache.plc4x.java.scraper.triggeredscraper.TriggeredScraperImplMBean;
+import org.apache.plc4x.java.scraper.triggeredscraper.TriggeredScraperImpl;
import org.apache.plc4x.java.scraper.triggeredscraper.triggerhandler.collector.TriggerCollector;
import org.apache.plc4x.java.scraper.triggeredscraper.triggerhandler.collector.TriggerCollectorImpl;
import org.apache.plc4x.java.utils.connectionpool.PooledPlcDriverManager;
@@ -50,7 +50,7 @@ public class Plc4x implements Input {
private String id;
private PlcDriverManager plcDriverManager;
private TriggerCollector triggerCollector;
- private TriggeredScraperImplMBean scraper;
+ private TriggeredScraperImpl scraper;
private final CountDownLatch done = new CountDownLatch(1);
@@ -113,7 +113,7 @@ public class Plc4x implements Input {
try {
plcDriverManager = new PooledPlcDriverManager();
triggerCollector = new TriggerCollectorImpl(plcDriverManager);
- scraper = new TriggeredScraperImplMBean(scraperConfig, (jobName, sourceName, results) -> {
+ scraper = new TriggeredScraperImpl(scraperConfig, (jobName, sourceName, results) -> {
//TODO: use jobname etc for multiple connections
for (Map.Entry<String, Object> result : results.entrySet()) {