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 fey core files to reflect scalastyle requirements
Date Wed, 13 Jul 2016 00:59:10 GMT
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 <tonyfaustini@yahoo.com>
Authored: Tue Jul 12 17:59:04 2016 -0700
Committer: tonyfaustini <tonyfaustini@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()


Mime
View raw message