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 <[email protected]> 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()) {
