Skip to content

Commit bbd97ad

Browse files
author
Johannes Duesing
committed
Adapted instance registry client to reflect the interface change in endpoints related to matching.
1 parent fecc237 commit bbd97ad

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/main/scala/de/upb/cs/swt/delphi/crawler/instancemanagement/InstanceRegistry.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,8 @@ object InstanceRegistry extends JsonSupport with AppLogging
149149
if(!configuration.usingInstanceRegistry) {
150150
Failure(new RuntimeException("Cannot get ElasticSearch instance from Instance Registry, no Instance Registry available."))
151151
} else {
152-
val request = HttpRequest(method = HttpMethods.GET, configuration.instanceRegistryUri + "/matchingInstance?ComponentType=ElasticSearch")
152+
val request = HttpRequest(method = HttpMethods.GET, configuration.instanceRegistryUri +
153+
s"/matchingInstance?Id=${configuration.instanceId.getOrElse(-1)}&ComponentType=ElasticSearch")
153154

154155
Await.result(Http(system).singleRequest(request) map {response =>
155156
response.status match {
@@ -188,7 +189,8 @@ object InstanceRegistry extends JsonSupport with AppLogging
188189
val idToPost = configuration.elasticSearchInstance.id.getOrElse(-1L)
189190
val request = HttpRequest(
190191
method = HttpMethods.POST,
191-
configuration.instanceRegistryUri + s"/matchingResult?Id=$idToPost&MatchingSuccessful=$isElasticSearchReachable")
192+
configuration.instanceRegistryUri +
193+
s"/matchingResult?CallerId=${configuration.instanceId.getOrElse(-1)}&MatchedInstanceId=$idToPost&MatchingSuccessful=$isElasticSearchReachable")
192194

193195
Await.result(Http(system).singleRequest(request) map {response =>
194196
if(response.status == StatusCodes.OK){

0 commit comments

Comments
 (0)