From e4dd72d3804b697f110a79ba5510c654f0765ec5 Mon Sep 17 00:00:00 2001 From: Filip Krzywka Date: Mon, 24 Sep 2018 10:42:47 +0200 Subject: Remove Consul configuration decoding Change-Id: I36a6aea55507abfb61613806c93257b049d6eea4 Issue-ID: DCAEGEN2-827 Signed-off-by: Filip Krzywka --- .../impl/adapters/ConsulConfigurationProviderTest.kt | 20 ++------------------ 1 file changed, 2 insertions(+), 18 deletions(-) (limited to 'hv-collector-core/src/test') diff --git a/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt b/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt index 7a1a4cdc..c6364f74 100644 --- a/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt +++ b/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt @@ -141,9 +141,8 @@ private fun constructConsulConfigProvider(url: String, const val kafkaAddress = "message-router-kafka" -fun constructConsulResponse(): String { - - val config = """{ +fun constructConsulResponse(): String = + """{ "dmaap.kafkaBootstrapServers": "$kafkaAddress:9093", "collector.routing": [ { @@ -156,18 +155,3 @@ fun constructConsulResponse(): String { } ] }""" - - val encodedValue = String(Base64.getEncoder().encode(config.toByteArray())) - - return """[ - { - "CreateIndex": 100, - "ModifyIndex": 200, - "LockIndex": 200, - "Key": "zip", - "Flags": 0, - "Value": "$encodedValue", - "Session": "adf4238a-882b-9ddc-4a9d-5b6758e4159e" - } - ]""" -} -- cgit 1.2.3-korg