in management-cluster-http/src/main/scala/org/apache/pekko/management/cluster/scaladsl/ClusterHttpManagementRoutes.scala [119:136]
private def routeFindMember(cluster: Cluster, readOnly: Boolean): Route = {
extractMethod { (method: HttpMethod) =>
if (readOnly && method != HttpMethods.GET) {
complete(StatusCodes.MethodNotAllowed)
} else {
path(RemainingDecoded) { memberAddress =>
findMember(cluster, memberAddress) match {
case Some(member) =>
routeGetMember(member) ~ routeDeleteMember(cluster, member) ~ routePutMember(cluster, member)
case None =>
complete(
StatusCodes.NotFound -> ClusterHttpManagementMessage(
s"Member [$memberAddress] not found"))
}
}
}
}
}