You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iota.apache.org by to...@apache.org on 2016/07/11 20:33:39 UTC
incubator-iota git commit: refactored performers to change log.info
mesaages to log.debug
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 <to...@yahoo.com>
Authored: Mon Jul 11 13:33:26 2016 -0700
Committer: tonyfaustini <to...@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")
}
}