Mailing-List: contact dev-help@edgent.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@edgent.apache.org
From: Dale LaBossiere <dml.apache@gmail.com>
Content-Type: multipart/alternative; boundary="Apple-Mail=_82453A5D-D587-4C9D-A524-EE9BF14FE175"
Message-Id: <FA9BD3B8-9942-4875-9AF0-C9AED5DA4D99@gmail.com>
Mime-Version: 1.0 (Mac OS X Mail 8.2 \(2104\))
Subject: Re: Trying register an application via the registerJar command
Date: Mon, 19 Sep 2016 11:30:05 -0400
References: <66814353-1C7B-4E6F-B398-BED3BF7BD542@pacbell.net> <4cb1f4a7-e300-98dc-5ae4-5d20f0f107cb@debrunners.com> <88E263E5-F417-415F-BB59-88859A18D14B@pacbell.net> <3be9ec9e-2621-9435-0c1d-670a5aa171dc@debrunners.com> <E044CB3F-2A24-4DFA-8F15-BF16F598BC16@pacbell.net> <38A15CF7-ADCC-4F29-AC76-0BC424F4AD4B@gmail.com> <26FB740D-685C-48E6-A4F8-3BE8D235D79E@pacbell.net> <A0085AAF-23CB-4789-9554-4DD08D2C2B59@gmail.com>
To: dev@edgent.apache.org
In-Reply-To: <A0085AAF-23CB-4789-9554-4DD08D2C2B59@gmail.com>
archived-at: Mon, 19 Sep 2016 15:30:16 -0000

--Apple-Mail=_82453A5D-D587-4C9D-A524-EE9BF14FE175
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=utf-8

FYI I just created https://issues.apache.org/jira/browse/EDGENT-250 =
<https://issues.apache.org/jira/browse/EDGENT-250> to update IotProvider =
doc related to registerJar().  You should consider adding commentary =
there as part of your experiences =E2=80=94 and/or consider tacking that =
jira and maybe even enhancing the doc further in this space :-)

=E2=80=94 Dale


> On Sep 19, 2016, at 11:07 AM, Dale LaBossiere <dml.apache@gmail.com> =
wrote:
>=20
> The TopologyBuilder.getBuilder() impl is bogus.  Looks like it=E2=80=99s=
 copied from TestApplication().  All it does is return a builder =
(BiConsumer) that creates a topology consisting of a TStream<String> =
containing one tuple with the app=E2=80=99s name and prints that stream.
>=20
> Your getBuilder() impl needs to return a BiConsumer that builds your =
app=E2=80=99s topology.  Looks like that=E2=80=99s what your accept() is =
trying to do.  Seems like you want something like (though I=E2=80=99d =
rename that accept() to something like =E2=80=9CbuildTopology()=E2=80=9D =
for clarity).
>=20
>       public BiConsumer<Topology, JsonObject> getBuilder() {
>       		return (t,c) -> accept(t,c);
>       }  =20
>=20
> Fix that and then see what happens regarding handling of the submit =
request.  You might also consider adding a println to your getBuilder() =
and accept() to verify they=E2=80=99re getting called.
>=20
> =E2=80=94 Dale
>=20
>> On Sep 16, 2016, at 5:44 PM, Susan Cline <home4slc@pacbell.net> =
wrote:
>>=20
>> Thanks Dale.  It did not work however, the results are the same after =
removing the 3 lines before provider.start().
>> When I submit the SpeedJarApp I can see this in the pi terminal (this =
is the full output from when I started the registerJarExample =
application to when I submitted the command):
>>=20
>> pi@raspberrypi:~/devConf $ java -jar registerJarExample.jar =
speed_sensor_config1.txt
>> Sep 16, 2016 9:39:08 PM =
org.apache.edgent.runtime.appservice.AppService registerTopology
>> INFO: Register application name: edgentIotDevicePubSub
>> Sep 16, 2016 9:39:08 PM =
org.apache.edgent.runtime.appservice.AppService registerTopology
>> INFO: Register application name: edgentIotCommandsToControl
>> Sep 16, 2016 9:39:08 PM =
org.apache.edgent.runtime.appservice.AppService registerTopology
>> INFO: Register application name: edgentJobMonitorApp
>> false
>> Sep 16, 2016 9:39:09 PM pi.RegisterJarExample main
>> INFO: Here is some info
>> Sep 16, 2016 9:39:09 PM com.ibm.iotf.client.AbstractClient =
createClient
>> INFO: pool-1-thread-22-edgentIotDevicePubSub: Org ID    =3D ni6dcf
>>        Client ID    =3D d:ni6dcf:SpeedSensor:Pi3_SpeedSensor_1
>> Sep 16, 2016 9:39:09 PM com.ibm.iotf.client.AbstractClient connect
>> INFO: pool-1-thread-22-edgentIotDevicePubSub: Connecting client =
d:ni6dcf:SpeedSensor:Pi3_SpeedSensor_1 to =
ssl://ni6dcf.messaging.internetofthings.ibmcloud.com:8883 (attempt =
#1)...
>> Sep 16, 2016 9:39:10 PM com.ibm.iotf.client.AbstractClient connect
>> INFO: pool-1-thread-22-edgentIotDevicePubSub: Successfully connected =
to the IBM Watson IoT Platform
>> Sep 16, 2016 9:39:49 PM =
org.apache.edgent.runtime.appservice.AppService registerJar
>> INFO: Register jar: file:///home/pi/devConf/pi.sensors.jar
>> Sep 16, 2016 9:39:49 PM =
org.apache.edgent.runtime.appservice.AppService registerJar
>> INFO: about to call registerTopology
>> Sep 16, 2016 9:39:49 PM =
org.apache.edgent.runtime.appservice.AppService registerTopology
>> INFO: Register application name: SpeedJarApp
>> SpeedJarApp
>> Sep 16, 2016 9:40:11 PM org.apache.edgent.runtime.etiao.Executable$1 =
accept
>> INFO: No more active user tasks
>>=20
>> Thanks,
>>=20
>> Susan
>>=20
>>=20
>>=20
>>> On Sep 16, 2016, at 10:32 AM, Dale LaBossiere <dml.apache@gmail.com> =
wrote:
>>>=20
>>> I haven=E2=80=99t digested the complete email message yet, but try =
removing those three lines before provider.start() and try again.
>>> IotProvider already create/registers those services (described in =
its javadoc).  I guess I wouldn=E2=80=99t be surprised if these extra =
additions might much things up.
>>>=20
>>> =E2=80=94 Dale
>>>=20
>>>> On Sep 16, 2016, at 1:17 PM, Susan Cline <home4slc@pacbell.net> =
wrote:
>>>>=20
>>>> I=E2=80=99ve gotten a step further, but I am still having problems.
>>>> ...
>>>>=20
>>>> public class RegisterJarExample {
>>>> 		IotProvider provider =3D new IotProvider(topology -> new =
IotpDevice(topology, configFile));
>>>> 		/*
>>>> 		 * Not sure if I need the next few lines or not ...
>>>> 		 */
>>>> 		JsonControlService control =3D new JsonControlService();
>>>> 		provider.getServices().addService(ControlService.class, =
control);=20
>>>> 		ApplicationService appService =3D =
AppService.createAndRegister(provider, provider);
>>>> 		provider.start();
>>>> 	=09
>>>> 		logger.info("Here is some info");
>>>> 	}
>>>> =09
>>>> }
>>>=20
>>=20
>=20


--Apple-Mail=_82453A5D-D587-4C9D-A524-EE9BF14FE175--