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/13 00:59:10 UTC
incubator-iota git commit: refactored fey core files to reflect
scalastyle requirements
Repository: incubator-iota
Updated Branches:
refs/heads/master 500cba4fb -> e944961f1
refactored fey core files to reflect scalastyle requirements
Project: http://git-wip-us.apache.org/repos/asf/incubator-iota/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-iota/commit/e944961f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-iota/tree/e944961f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-iota/diff/e944961f
Branch: refs/heads/master
Commit: e944961f1a340ed8dd10011a1e0d688dba9de532
Parents: 500cba4
Author: tonyfaustini <to...@yahoo.com>
Authored: Tue Jul 12 17:59:04 2016 -0700
Committer: tonyfaustini <to...@yahoo.com>
Committed: Tue Jul 12 17:59:04 2016 -0700
----------------------------------------------------------------------
fey-core/src/main/scala/org/apache/iota/fey/DirWatcher.scala | 2 +-
fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala | 6 +++---
fey-core/src/main/scala/org/apache/iota/fey/Utils.scala | 8 ++++----
3 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/e944961f/fey-core/src/main/scala/org/apache/iota/fey/DirWatcher.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/DirWatcher.scala b/fey-core/src/main/scala/org/apache/iota/fey/DirWatcher.scala
index be779b0..cf2b685 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/DirWatcher.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/DirWatcher.scala
@@ -31,7 +31,7 @@ class WatchDirectoryTask(watcherActor: ActorRef) extends Runnable {
private val watchService = FileSystems.getDefault.newWatchService()
- def watch(path: Path) = path.register(watchService, ENTRY_CREATE, ENTRY_MODIFY)
+ def watch(path: Path) : Unit = path.register(watchService, ENTRY_CREATE, ENTRY_MODIFY)
override def run() {
try {
http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/e944961f/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala b/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
index 796f01a..caf2ecc 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
@@ -78,7 +78,7 @@ protected class Ensemble(val orchestrationID: String,
/**
* Uses the json spec to create the performers
*/
- override def preStart() = {
+ override def preStart() : Unit = {
SYSTEM_ACTORS.monitoring ! Monitor.START(Utils.getTimestamp)
@@ -99,7 +99,7 @@ protected class Ensemble(val orchestrationID: String,
}
- override def postStop() = {
+ override def postStop() : Unit = {
SYSTEM_ACTORS.monitoring ! Monitor.STOP(Utils.getTimestamp)
}
@@ -242,7 +242,7 @@ protected class Ensemble(val orchestrationID: String,
s"Edges: \n$ed \nNodes: \n\t$nd \nPerformer \n\t$actors"
}
- def stopPerformers() = {
+ def stopPerformers(): Unit = {
performer.foreach(actor => actor._2 ! PoisonPill)
}
http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/e944961f/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 fd24955..2cdcff0 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
@@ -121,7 +121,7 @@ protected object Utils {
* @param delete
* @return
*/
- def updateOrchestrationState(orchestrationID: String, delete: Boolean = false) = {
+ def updateOrchestrationState(orchestrationID: String, delete: Boolean = false) : Unit = {
if (CHEKPOINT_ENABLED) {
FEY_CACHE.activeOrchestrations.get(orchestrationID) match {
case None =>
@@ -201,7 +201,7 @@ object CONFIG{
var LOG_APPENDER = ""
var MESSAGES_PER_RESIZE = 500
- def loadUserConfiguration(path: String) = {
+ def loadUserConfiguration(path: String) : Unit = {
val app = {
if(path != "" && Files.exists(Paths.get(path))) {
@@ -228,7 +228,7 @@ object CONFIG{
/**
* Resets logback context configuration and loads the new one
*/
- def setLogbackConfiguration() = {
+ def setLogbackConfiguration() : Unit = {
val context: LoggerContext = LoggerFactory.getILoggerFactory.asInstanceOf[LoggerContext]
try {
val root = LoggerFactory.getLogger(org.slf4j.Logger.ROOT_LOGGER_NAME).asInstanceOf[Logger]
@@ -240,7 +240,7 @@ object CONFIG{
StatusPrinter.printInCaseOfErrorsOrWarnings(context)
}
- def setLogAppenders(root: Logger) = {
+ def setLogAppenders(root: Logger) : Unit = {
LOG_APPENDER match {
case "FILE" =>
root.getAppender(CONSOLE_APPENDER).stop()