iota-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tonyfaust...@apache.org
Subject incubator-iota git commit: refactored performers to change log.info mesaages to log.debug
Date Mon, 11 Jul 2016 20:33:39 GMT
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 <tonyfaustini@yahoo.com>
Authored: Mon Jul 11 13:33:26 2016 -0700
Committer: tonyfaustini <tonyfaustini@yahoo.com>
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")
     }
   }
 


Mime
View raw message