Add MiMa filters for internal API changes

akka · Mar 21, 2019 · 2e24b6e · 2e24b6e
1 parent a9470d4
commit 2e24b6e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/mqtt-streaming/src/main/mima-filters/1.0-RC1.backwards.excludes b/mqtt-streaming/src/main/mima-filters/1.0-RC1.backwards.excludes
@@ -0,0 +1,9 @@
+# PR #1595
+# https://github.com/akka/alpakka/pull/1595
+ProblemFilters.exclude[Problem]("akka.stream.alpakka.mqtt.streaming.impl.*")
+# private[streaming]
+ProblemFilters.exclude[MissingMethodProblem]("akka.stream.alpakka.mqtt.streaming.scaladsl.MqttClientSession.commandFlow")
+ProblemFilters.exclude[MissingMethodProblem]("akka.stream.alpakka.mqtt.streaming.scaladsl.ActorMqttClientSession.commandFlow")
+# private[streaming]
+ProblemFilters.exclude[MissingMethodProblem]("akka.stream.alpakka.mqtt.streaming.scaladsl.MqttClientSession.eventFlow")
+ProblemFilters.exclude[MissingMethodProblem]("akka.stream.alpakka.mqtt.streaming.scaladsl.ActorMqttClientSession.eventFlow")
diff --git a/mqtt-streaming/src/main/scala/akka/stream/alpakka/mqtt/streaming/scaladsl/MqttSession.scala b/mqtt-streaming/src/main/scala/akka/stream/alpakka/mqtt/streaming/scaladsl/MqttSession.scala
@@ -152,7 +152,7 @@ final class ActorMqttClientSession(settings: MqttSessionSettings)(implicit mat:
 
  private val pingReqBytes = PingReq.encode(ByteString.newBuilder).result()
 
- override def commandFlow[A](connectionId: ByteString): CommandFlow[A] =
+ private[streaming] override def commandFlow[A](connectionId: ByteString): CommandFlow[A] =
  Flow
  .lazyInitAsync { () =>
  val killSwitch = KillSwitches.shared("command-kill-switch-" + clientSessionId)
@@ -249,7 +249,7 @@ final class ActorMqttClientSession(settings: MqttSessionSettings)(implicit mat:
  }
  .mapMaterializedValue(_ => NotUsed)
 
- override def eventFlow[A](connectionId: ByteString): EventFlow[A] =
+ private[streaming] override def eventFlow[A](connectionId: ByteString): EventFlow[A] =
  Flow[ByteString]
  .watch(clientConnector.toUntyped)
  .watchTermination() {