Implementation akka-quartz-scheduler and Internet of things

This is a multimodule project it include two modules that can live separated but I want to give you the idea of allways work in a multimodules environments.

• akka-quartz-scheduler: We needed something similar to the linux cron service, execute several tasks spread in time, change the schedule of those tasks, change the tasks and all of this without stop the services.
• Full implementation of the akka example of InternetOf Things

Implementation of akka-quartz-scheduler in a cron service problem

What is my problem?: I have several tasks that need to execute following an specific schedule and with different parameters every time that be executed. There are not periodical tasks but I know that for example every sunday or every week someone will publish when I have to execute our tasks. In our example we are going to inspect an url about films and tv series http://mejorenvo.com/. So we can review a fixed amount of page or schedule inspect page those days that we know that company is planning to add new film pages.

What will you find in the Implementation of akka-quartz-scheduler ?

• How implement tasks that can be execute like in a linux cron services but without the security problems and at the same time with a variable schedule without stoped any process. I have implement 2 scheduler:
  • Internal configuration: In application.conf akka configuration file.
  • External configuration: In an external file, this file won't be in our compiled distribution. So while our daemons are working I can change this external configuration and the jobs will be rescheduled without any problem and without stop my akka application.

What you will not find here, but you should

• A proper ErrorHandler implementation.
• Implementation of Supervisor strategy.
• Test module: This point we'll be interesting in the future. All code have been prepared for be tested in akka environment without mocking any value.

Requirements, Installation, Launching

Requirements

• jdk 1.7+ -> how check java version: java -version
• scala 2.11.x -> how check scala version: scala -version
• sbt 0.13.11+ -> how check sbt version: sbt about

Installation and Launching

• clone repository
• go to root project
• type in your terminal:
  • sbt "AkkaSchedulerPoc/runMain com.ldg.BootNotScheduled 1 5" . Description: It will let you review from page 1 to page 5 and then ends all process:

    .....
    2019-04-08 11:41:49.435[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-2] DEBUG akka.event.EventStream - Default Loggers started
    2019-04-08 11:41:49.468[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - Start process in Akka Scheduler Example
    2019-04-08 11:41:51.404[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-2] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p1.html
    2019-04-08 11:41:51.430[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p3.html
    2019-04-08 11:41:51.459[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-6] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p4.html
    2019-04-08 11:41:51.974[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-7] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p5.html
    2019-04-08 11:41:51.976[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p2.html
    2019-04-08 11:41:51.980[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-7] INFO  com.ldg.actors.IOTask - Start IOTask process
    2019-04-08 11:41:51.980[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-7] INFO  com.ldg.actors.IOTask - Stop IOTask process
    2019-04-08 11:41:51.992[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - Stop process in Akka Schedule Example
    [DEBUG] [04/08/2019 11:41:51.997] [IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-3] [EventStream] shutting down: StandardOutLogger started
    2019-04-08 11:41:51.997[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] DEBUG akka.event.EventStream - shutting down: StandardOutLogger started
    [DEBUG] [04/08/2019 11:41:51.999] [IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-3] [EventStream] all default loggers stopped
    [success] Total time: 4 s, completed 08-abr-2019 11:41:52
    
    

  • sbt "AkkaSchedulerPoc/runMain com.ldg.BootScheduled" . Description: You have to configurate the pages to review and when it must be done. Every thing in an external configuration file (root/akka-quickstart-scala/scriptsdb/cronmoviepages.conf)

Implementation of akka example of Internet of Things

This project implement the akka example of InternetOf Things The idea is that each house can has several sensors devices and should be possible get/set values in each device. Each house must have a Network Connection Component (NCC) It must allow connect the sensor device to Internet.

Copyright of My Children (Mariela and Samuel)