From 17546252028e774a777450c118f0c30d60a97617 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Martynas=20Mickevi=C4=8Dius?= Date: Tue, 21 Feb 2017 13:05:36 +0200 Subject: [PATCH] #22353 fix mbean expected json format --- .../scala/akka/cluster/MBeanSpec.scala | 18 +++++++++--------- .../scala/akka/stream/stage/GraphStage.scala | 6 +++--- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/MBeanSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/MBeanSpec.scala index 4885968c07..8ac5e092b7 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/MBeanSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/MBeanSpec.scala @@ -116,37 +116,37 @@ abstract class MBeanSpec val unreachableObservedBy = Vector(first, second, third).sorted.map(address(_)) val expectedJson = s"""{ - | "self-address": "${address(first)}", | "members": [ | { | "address": "${sortedNodes(0)}", - | "status": "Up", | "roles": [ | "testNode" - | ] + | ], + | "status": "Up" | }, | { | "address": "${sortedNodes(1)}", - | "status": "Up", | "roles": [ | "testNode" - | ] + | ], + | "status": "Up" | }, | { | "address": "${sortedNodes(2)}", - | "status": "Up", | "roles": [ | "testNode" - | ] + | ], + | "status": "Up" | }, | { | "address": "${sortedNodes(3)}", - | "status": "Up", | "roles": [ | "testNode" - | ] + | ], + | "status": "Up" | } | ], + | "self-address": "${address(first)}", | "unreachable": [ | { | "node": "${address(fourth)}", diff --git a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala index 7d68f1d54d..4ae5352a51 100644 --- a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala +++ b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala @@ -10,14 +10,14 @@ import java.util.concurrent.locks.ReentrantLock import akka.actor._ import akka.annotation.ApiMayChange -import akka.japi.function.{Effect, Procedure} +import akka.japi.function.{ Effect, Procedure } import akka.stream._ import akka.stream.impl.StreamLayout.Module -import akka.stream.impl.fusing.{GraphInterpreter, GraphStageModule, SubSink, SubSource} +import akka.stream.impl.fusing.{ GraphInterpreter, GraphStageModule, SubSink, SubSource } import akka.stream.impl.ReactiveStreamsCompliance import scala.collection.mutable.ArrayBuffer -import scala.collection.{immutable, mutable} +import scala.collection.{ immutable, mutable } import scala.concurrent.duration.FiniteDuration import akka.stream.actor.ActorSubscriberMessage