Hi Tom,
glad that we were able to help you and I hope that in this comparison Edgent
performed well :-)
Is there any chance to get a copy of your results in that comparison. I'm
asking cause in the Apache PLC4X project we're working hard on providing
integrations to interesting platforms.
Chris
Am 25.09.18, 17:00 schrieb "Tom G." <tom.gelbl...@googlemail.com.INVALID>:
Hi Julian, Christofer,
thank you for your replies! Context of my question is that I’m comparing
Apache Nifi/MiNiFi, StreamSets Data Collector/SDC Edge and Apache Edgent.
From my first impression it seemed like that all of them support transport
via HTTP out of the box. Finally, I followed your advice and solved the
situation by moving on to MQTT with a mosquitto instance. (MiNiFi requires
some additional manual configuration to enable MQTT support.)
Very helpful was the SimplePublisherApp which is part of the examples:
https://github.com/apache/incubator-edgent-samples/tree/2fadbbf574ee9fbf0d839fe18ce23de20d6d5d21/connectors/src/main/java/org/apache/edgent/samples/connectors/mqtt
Many thanks,
Tom
2018-09-20 21:00 GMT+02:00 Tom G. <tom.gelbl...@googlemail.com>:
> Dear Apache Edgent community,
>
> I’m trying to figure out how to establish a HTTP connection between two
> Apache Edgent instances.
> I want to tail an active file and send the appended records via HTTP to
> another Apache Edgent instance.
> The second instance should receive these records via HTTP and write them
> to disk.
>
> My code for the first instance looks like this:
>
> package com.mycompany.app;
>
> import org.apache.edgent.connectors.http.*;
> import org.apache.edgent.connectors.file.*;
> import org.apache.edgent.providers.direct.DirectProvider;
> import org.apache.edgent.topology.TStream;
> import org.apache.edgent.topology.Topology;
>
> /**
> * Edgent Application template.
> */
>
> public class TemplateApp {
>
> public static void main(String[] args) throws Exception {
>
> //Create a provider
> DirectProvider dp = new DirectProvider();
>
> //Create a topology
> Topology top = dp.newTopology();
>
> //Build the topology
> String watchedDir = "/tmp/test/";
>
> //Read file
> TStream<String> pathnames = FileStreams.directoryWatcher(top, ()
> -> watchedDir, null);
> TStream<String> lines = FileStreams.textFileReader(pathnames);
>
> //Insert filter here
> lines.print();
>
> //Insert ‘send data to HTTP server’ here
>
> //Submit the topology
> dp.submit(top);
> }
> }
>
> How do I fill the gap after “//Insert ‘send data to HTTP server’ here” to
> be able to send the records to the second instance?
>
> How does the HTTP part of the second instance have to look like to be able
> to receive these records?
>
> Best regards,
>
> Tom
>
>
