fix(queue): Upgrade keiko, keep deprecated attribute around (#2136)

spinnaker · Apr 10, 2018 · 51f452d · 51f452d
1 parent 1257c50
commit 51f452d
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/gradle.properties b/gradle.properties
@@ -20,4 +20,4 @@ junitVersion=1.0.2
 jupiterVersion=5.0.2
 junitLegacyVersion=4.12.0
 spekVersion=1.1.5
-keikoVersion=2.6.0
+keikoVersion=2.6.1
diff --git a/orca-queue/src/main/kotlin/com/netflix/spinnaker/orca/q/messages.kt b/orca-queue/src/main/kotlin/com/netflix/spinnaker/orca/q/messages.kt
@@ -23,6 +23,7 @@ import com.netflix.spinnaker.orca.pipeline.model.Execution
 import com.netflix.spinnaker.orca.pipeline.model.Execution.ExecutionType
 import com.netflix.spinnaker.orca.pipeline.model.Stage
 import com.netflix.spinnaker.orca.pipeline.persistence.ExecutionRepository
+import com.netflix.spinnaker.q.Attribute
 import com.netflix.spinnaker.q.Message
 import java.time.Duration
 
@@ -401,3 +402,11 @@ data class NoDownstreamTasks(
   constructor(source: TaskLevel) :
     this(source.executionType, source.executionId, source.application, source.stageId, source.taskId)
 }
+
+@Deprecated("Kept only to support old messages on the queue without having to do a migration")
+@JsonTypeName("totalThrottleTime")
+data class TotalThrottleTimeAttribute(var totalThrottleTimeMs: Long = 0) : Attribute {
+  fun add(throttleTimeMs: Long) {
+    this.totalThrottleTimeMs += throttleTimeMs
+  }
+}