trim slowdown codes before parsing to int

ing-bank · Oct 16, 2023 · 860f295 · 860f295
1 parent 9030d7c
commit 860f295
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/resources/reference.conf b/src/main/resources/reference.conf
@@ -32,7 +32,7 @@ rokku {
         region = "us-east-1"
         v2SignatureEnabled = false
         # To add more then one code, seperate them with comma
-        slowdownCodes = "503"
+        slowdownCodes = "502, 503"
         healthCheck {
            # can be one of:
            #   s3ListBucket  - uses AWS S3 client to list single bucket

diff --git a/src/main/scala/com/ing/wbaa/rokku/proxy/config/StorageS3Settings.scala b/src/main/scala/com/ing/wbaa/rokku/proxy/config/StorageS3Settings.scala
@@ -14,7 +14,7 @@ class StorageS3Settings(config: Config) extends Extension {
   val storageS3AdminSecretkey: String = config.getString("rokku.storage.s3.admin.secretkey")
   val awsRegion: String = config.getString("rokku.storage.s3.region")
   val v2SignatureEnabled: Boolean = config.getBoolean("rokku.storage.s3.v2SignatureEnabled")
-  val slowdownCodes: Array[Int] = config.getString("rokku.storage.s3.slowdownCodes").split(",").map(o => o.toInt)
+  val slowdownCodes: Array[Int] = config.getString("rokku.storage.s3.slowdownCodes").split(",").map(o => o.trim.toInt)
   val isRequestUserQueueEnabled: Boolean = config.getBoolean("rokku.storage.s3.request.queue.enable")
   private val hcMethodString = config.getString("rokku.storage.s3.healthCheck.method")
   val hcMethod: HCMethod = hcMethodString match {