Mailing-List: contact dev-help@edgent.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@edgent.apache.org
MIME-Version: 1.0
From: Gayashan Amarasinghe <gayashan.amarasinghe@gmail.com>
Date: Wed, 31 May 2017 13:11:46 +1000
Message-ID: <CAJt7cMU244RSh2U+kvfTA5vanegxBkzh53VWRXpAQ2QGpWe6NA@mail.gmail.com>
Subject: Looking for samples and some help on Loosely coupled Edgent applications
To: dev@edgent.apache.org
Content-Type: multipart/alternative; boundary="001a114a8d5a2d98d70550c94a71"
archived-at: Wed, 31 May 2017 03:12:31 -0000

--001a114a8d5a2d98d70550c94a71
Content-Type: text/plain; charset="UTF-8"

Hi Edgent community,

I am a PhD student from University of Melbourne and I am interested in the
Apache Edgent project. I need some help to implement a scenario to submit a
topology externally to a provider. Unfortunately apart from some test cases
in the source code and [1], I couldn't find any documentation on this. So
here's what I have done so far,

   - I have implemented the TopologyBuilder interface and created a
   separate jar. This is the code in the class.

public class MyTopology implements TopologyBuilder {

    @Override

    public String getName() {

        return "MyCPUTempApp";

    }


    @Override

    public BiConsumer<Topology, JsonObject> getBuilder() {

        CPUTempSensor cpuTempSensor = new CPUTempSensor();

        return (t, c) -> t.poll(cpuTempSensor, 2, TimeUnit.SECONDS)

                .filter(readings -> readings >
35).sink(System.out::println);

    }

}


   - In a separate project, I have created another class to instantiate a
   DirectProvider and to load the previous jar using an AppService similar to
   the IotAppServiceTest. Here's the code,

public class DynamicAppLoader {
    public static void main(String[] args) {
        DirectProvider directProvider = new DirectProvider();
        JsonControlService jsonControlService = new JsonControlService();
        directProvider.getServices().addService(ControlService.class,
jsonControlService);
        ApplicationService service =
AppService.createAndRegister(directProvider, directProvider);
        File cpuTempAppJar =
                new
File("/home/gayashan/projects/research/cputemptopology/target/cputemptopology-1.0.0.jar");
        try {
            URL cpuTempAppJarUrl = cpuTempAppJar.toURI().toURL();
            JsonObject registerJar =
newRegisterJarRequest(cpuTempAppJarUrl.toExternalForm());
            jsonControlService.controlRequest(registerJar);
            JsonObject submitCpuTempApp = newSubmitRequest("MyCPUTempApp");
            jsonControlService.controlRequest(submitCpuTempApp);
            System.out.println(service.getApplicationNames());
        } catch (Exception e) {
            System.err.println("Error: " + e.getLocalizedMessage());
        }
    }

...
// newRegisterJarRequest and newSubmitRequest methods are as same as in
the IotAppServiceTest class.
}

But unfortunately I don't understand how to get this to work. Can someone
help me with this and point where I am making a mistake? Apologies in
advance if this seems like a trivial question.

Thank you.

[1]
https://edgent.apache.org/recipes/recipe_dynamic_analytic_control.html#loosely-coupled-edgent-applications

Best regards,
Gayashan

--001a114a8d5a2d98d70550c94a71--