Merge pull request #29 from Tecsisa/28-add-new-helper-method

Add new method to improve resilience (closes #28)
Tecsisa · Sep 16, 2016 · b3f3258 · b3f3258
2 parents 66326bc + 583b52f
commit b3f3258
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...consul/src/main/scala/com.tecsisa.constructr.coordination.consul/ConsulCoordination.scala b/...consul/src/main/scala/com.tecsisa.constructr.coordination.consul/ConsulCoordination.scala
@@ -137,7 +137,9 @@ final class ConsulCoordination(
     }
   }
 
-  override def addSelf[A: NodeSerialization](self: A, ttl: FiniteDuration) = {
+  override def addSelf[A: NodeSerialization](self: A, ttl: FiniteDuration) = createIfNotExist(self, ttl)
+
+  def createIfNotExist[A: NodeSerialization](self: A, ttl: FiniteDuration) = {
     val keyUri = nodesUri.withPath(nodesUri.path / Base64.getUrlEncoder.encodeToString(implicitly[NodeSerialization[A]].toBytes(self)))
     val addSelfWithPreviousSession = for {
       Some(sessionId) <- retrieveSessionForKey(keyUri)

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -3,7 +3,7 @@ import sbt._
 object Version {
   final val Scala            = "2.11.8"
   final val ConstructrAkka   = "0.13.2"
-  final val raptureJsonCirce = "2.0.0-M5"
+  final val raptureJsonCirce = "2.0.0-M7"
   final val Akka             = "2.4.4"
   final val AkkaLog4j        = "1.1.3"
   final val ScalaTest        = "2.2.6"