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/18 20:43:27 UTC
[04/12] incubator-iota git commit: Adding Global name for
WatchService thread
Adding Global name for WatchService thread
Project: http://git-wip-us.apache.org/repos/asf/incubator-iota/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-iota/commit/f850688b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-iota/tree/f850688b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-iota/diff/f850688b
Branch: refs/heads/master
Commit: f850688b91b3607929a20b6816e2d7c0777c7aeb
Parents: 7202f0f
Author: Barbara Gomes <ba...@gmail.com>
Authored: Fri Jul 15 16:22:56 2016 -0700
Committer: Barbara Gomes <ba...@gmail.com>
Committed: Fri Jul 15 16:22:56 2016 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/iota/fey/JsonReceiverActor.scala | 2 +-
fey-core/src/main/scala/org/apache/iota/fey/Utils.scala | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/f850688b/fey-core/src/main/scala/org/apache/iota/fey/JsonReceiverActor.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/JsonReceiverActor.scala b/fey-core/src/main/scala/org/apache/iota/fey/JsonReceiverActor.scala
index 6170524..1664478 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/JsonReceiverActor.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/JsonReceiverActor.scala
@@ -30,7 +30,7 @@ class JsonReceiverActor extends Actor with ActorLogging {
val monitoring_actor = FEY_MONITOR.actorRef
val watchFileTask = new WatchServiceReceiver(self)
- var watchThread = new Thread(watchFileTask, "WatchService")
+ var watchThread = new Thread(watchFileTask, GLOBAL_DEFINITIONS.WATCH_SERVICE_THREAD)
override def preStart() {
prepareDynamicJarRepo()
http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/f850688b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
index bd30d9c..8402485 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
@@ -293,6 +293,10 @@ object CONFIG{
}
}
+object GLOBAL_DEFINITIONS {
+ val WATCH_SERVICE_THREAD = "FeyWatchService"
+}
+
case class NetworkAlreadyDefined(message:String) extends Exception(message)