Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 08D13200B3B for ; Mon, 11 Jul 2016 22:33:46 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 07384160A78; Mon, 11 Jul 2016 20:33:46 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 027C1160A5E for ; Mon, 11 Jul 2016 22:33:44 +0200 (CEST) Received: (qmail 21780 invoked by uid 500); 11 Jul 2016 20:33:44 -0000 Mailing-List: contact commits-help@iota.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@iota.incubator.apache.org Delivered-To: mailing list commits@iota.incubator.apache.org Received: (qmail 21771 invoked by uid 99); 11 Jul 2016 20:33:44 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jul 2016 20:33:44 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id C2C24C0B7B for ; Mon, 11 Jul 2016 20:33:43 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.646 X-Spam-Level: X-Spam-Status: No, score=-4.646 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.426] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id nV-O4Z8X905m for ; Mon, 11 Jul 2016 20:33:41 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id BBACA5F253 for ; Mon, 11 Jul 2016 20:33:40 +0000 (UTC) Received: (qmail 21752 invoked by uid 99); 11 Jul 2016 20:33:39 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jul 2016 20:33:39 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C3023DFFF8; Mon, 11 Jul 2016 20:33:39 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: tonyfaustini@apache.org To: commits@iota.incubator.apache.org Message-Id: <3631eaa8ac654136881f61cb04aa8b9b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: incubator-iota git commit: refactored performers to change log.info mesaages to log.debug Date: Mon, 11 Jul 2016 20:33:39 +0000 (UTC) archived-at: Mon, 11 Jul 2016 20:33:46 -0000 Repository: incubator-iota Updated Branches: refs/heads/master 6af71ea02 -> 500cba4fb refactored performers to change log.info mesaages to log.debug Project: http://git-wip-us.apache.org/repos/asf/incubator-iota/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-iota/commit/500cba4f Tree: http://git-wip-us.apache.org/repos/asf/incubator-iota/tree/500cba4f Diff: http://git-wip-us.apache.org/repos/asf/incubator-iota/diff/500cba4f Branch: refs/heads/master Commit: 500cba4fba65c88b695a0fb220d7d85d6626c04d Parents: 6af71ea Author: tonyfaustini Authored: Mon Jul 11 13:33:26 2016 -0700 Committer: tonyfaustini Committed: Mon Jul 11 13:33:26 2016 -0700 ---------------------------------------------------------------------- .gitignore | 2 -- .../apache/iota/fey/performer/Application.scala | 22 ++++++++++---------- .../apache/iota/fey/performer/Heartbeat.scala | 2 +- .../apache/iota/fey/performer/Timestamp.scala | 4 ++-- .../org/apache/iota/fey/performer/Sensor.scala | 6 +++--- .../iota/fey/performer/ZMQPublisher.scala | 6 +++--- .../iota/fey/performer/ZMQSubscriber.scala | 8 +++---- 7 files changed, 24 insertions(+), 26 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/.gitignore ---------------------------------------------------------------------- diff --git a/.gitignore b/.gitignore index 3de1a08..75f1edb 100644 --- a/.gitignore +++ b/.gitignore @@ -86,5 +86,3 @@ metastore_db/ #nohup files nohup*.out -#generated jars -fey-examples/active-jar-repo/*.jar http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/performers/stream/src/main/scala/org/apache/iota/fey/performer/Application.scala ---------------------------------------------------------------------- diff --git a/performers/stream/src/main/scala/org/apache/iota/fey/performer/Application.scala b/performers/stream/src/main/scala/org/apache/iota/fey/performer/Application.scala index a574c26..ce5164d 100644 --- a/performers/stream/src/main/scala/org/apache/iota/fey/performer/Application.scala +++ b/performers/stream/src/main/scala/org/apache/iota/fey/performer/Application.scala @@ -24,16 +24,16 @@ import scala.concurrent.duration._ object Application extends App { - println("Starting") - - implicit val system = ActorSystem("STREAM-RUN") - - val timestamp = system.actorOf(Props(classOf[Timestamp], Map.empty, 1.minutes, Map.empty, 1.seconds, "", "", false), name = "TIMESTAMP") - - timestamp ! PROCESS("Stream it") - - val heartbeat = system.actorOf(Props(classOf[Heartbeat], Map.empty, 1.minutes, Map.empty, 1.seconds, "", "", false), name = "HEARTBEAT") - - heartbeat ! PROCESS("Stream it") +// println("Starting") +// +// implicit val system = ActorSystem("STREAM-RUN") +// +// val timestamp = system.actorOf(Props(classOf[Timestamp], Map.empty, 1.minutes, Map.empty, 1.seconds, "", "", false), name = "TIMESTAMP") +// +// timestamp ! PROCESS("Stream it") +// +// val heartbeat = system.actorOf(Props(classOf[Heartbeat], Map.empty, 1.minutes, Map.empty, 1.seconds, "", "", false), name = "HEARTBEAT") +// +// heartbeat ! PROCESS("Stream it") } http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/performers/stream/src/main/scala/org/apache/iota/fey/performer/Heartbeat.scala ---------------------------------------------------------------------- diff --git a/performers/stream/src/main/scala/org/apache/iota/fey/performer/Heartbeat.scala b/performers/stream/src/main/scala/org/apache/iota/fey/performer/Heartbeat.scala index ad16632..73dd4f8 100644 --- a/performers/stream/src/main/scala/org/apache/iota/fey/performer/Heartbeat.scala +++ b/performers/stream/src/main/scala/org/apache/iota/fey/performer/Heartbeat.scala @@ -49,7 +49,7 @@ class Heartbeat(override val params: Map[String, String] = Map.empty, } override def execute() = { - log.info("Alive") + log.debug("Alive") propagateMessage("Alive") } http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/performers/stream/src/main/scala/org/apache/iota/fey/performer/Timestamp.scala ---------------------------------------------------------------------- diff --git a/performers/stream/src/main/scala/org/apache/iota/fey/performer/Timestamp.scala b/performers/stream/src/main/scala/org/apache/iota/fey/performer/Timestamp.scala index 3f22688..3901e98 100644 --- a/performers/stream/src/main/scala/org/apache/iota/fey/performer/Timestamp.scala +++ b/performers/stream/src/main/scala/org/apache/iota/fey/performer/Timestamp.scala @@ -41,7 +41,7 @@ class Timestamp(override val params: Map[String, String] = Map.empty, } override def customReceive: Receive = { - case x => log.info(s"Untreated $x") + case x => log.debug(s"Untreated $x") } override def processMessage[T](message: T, sender: ActorRef): Unit = { @@ -49,7 +49,7 @@ class Timestamp(override val params: Map[String, String] = Map.empty, override def execute() = { val ts = java.lang.System.currentTimeMillis() - log.info(ts.toString) + log.debug(ts.toString) propagateMessage(ts.toString) } http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/performers/virtual_sensor/src/main/scala/org/apache/iota/fey/performer/Sensor.scala ---------------------------------------------------------------------- diff --git a/performers/virtual_sensor/src/main/scala/org/apache/iota/fey/performer/Sensor.scala b/performers/virtual_sensor/src/main/scala/org/apache/iota/fey/performer/Sensor.scala index 0cda6d4..01ffb71 100644 --- a/performers/virtual_sensor/src/main/scala/org/apache/iota/fey/performer/Sensor.scala +++ b/performers/virtual_sensor/src/main/scala/org/apache/iota/fey/performer/Sensor.scala @@ -77,7 +77,7 @@ class Sensor(override val params: Map[String, String] = Map.empty, } override def customReceive: Receive = { - case x => log.info(s"Untreated $x") + case x => log.debug(s"Untreated $x") } override def processMessage[T](message: T, sender: ActorRef): Unit = { @@ -97,7 +97,7 @@ class Sensor(override val params: Map[String, String] = Map.empty, case "vibration" => out = "DATA|cloud|" + lrn + "|" + ts + "|{\"blob\":\"" + vib + "\"}" case "wav" => out = "DATA|cloud|" + lrn + "|" + ts + "|{\"wav\":\"" + sound + "\"}" } - log.info(out) + log.debug(out) propagateMessage(out) } @@ -145,7 +145,7 @@ class Sensor(override val params: Map[String, String] = Map.empty, try { expected_value = ev.toFloat } catch { - case e: Exception => log.info(s"Expected a Float you used $ev ") + case e: Exception => log.error(s"Expected a Float you used $ev ") } } http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQPublisher.scala ---------------------------------------------------------------------- diff --git a/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQPublisher.scala b/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQPublisher.scala index 4c43d45..d7dbf90 100644 --- a/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQPublisher.scala +++ b/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQPublisher.scala @@ -84,11 +84,11 @@ class ZMQPublisher(override val params: Map[String, String] = Map.empty, } override def customReceive: Receive = { - case x => log.info(s"Untreated $x") + case x => log.debug(s"Untreated $x") } override def execute() = { - log.info(s"Msg count: $count") + log.debug(s"Msg count: $count") } override def processMessage[T](message: T, sender: ActorRef): Unit = { @@ -114,7 +114,7 @@ class ZMQPublisher(override val params: Map[String, String] = Map.empty, } def _zmq_send(Message: String) = { - log.info(s"messsage =$Message") + log.debug(s"messsage =$Message") pub.send(Message) count += 1 } http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/500cba4f/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQSubscriber.scala ---------------------------------------------------------------------- diff --git a/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQSubscriber.scala b/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQSubscriber.scala index 3decb70..c7d0381 100644 --- a/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQSubscriber.scala +++ b/performers/zmq/src/main/scala/org/apache/iota/fey/performer/ZMQSubscriber.scala @@ -57,7 +57,7 @@ class ZMQSubscriber(override val params: Map[String, String] = Map.empty, val address = new String(subscriber.recv(0)) // Read message contents val contents = new String(subscriber.recv(0)) - log.info(s"HERE IT IS $address : $contents") + log.debug(s"HERE IT IS $address : $contents") count += 1 } } @@ -92,16 +92,16 @@ class ZMQSubscriber(override val params: Map[String, String] = Map.empty, } override def customReceive: Receive = { - case x => log.info(s"Untreated $x") + case x => log.debug(s"Untreated $x") } override def execute() = { - log.info(s"Msg count: $count") + log.debug(s"Msg count: $count") } override def processMessage[T](message: T, sender: ActorRef): Unit = { message match { - case _ => log.info("Ignoring this message as format not expected") + case _ => log.debug("Ignoring this message as format not expected") } }