diff --git a/backendFs2Rabbit/src/main/scala/com/itv/bucky/backend/fs2rabbit/Fs2RabbitAmqpClient.scala b/backendFs2Rabbit/src/main/scala/com/itv/bucky/backend/fs2rabbit/Fs2RabbitAmqpClient.scala index 424852d..1a96025 100644 --- a/backendFs2Rabbit/src/main/scala/com/itv/bucky/backend/fs2rabbit/Fs2RabbitAmqpClient.scala +++ b/backendFs2Rabbit/src/main/scala/com/itv/bucky/backend/fs2rabbit/Fs2RabbitAmqpClient.scala @@ -50,7 +50,7 @@ class Fs2RabbitAmqpClient[F[_]](client: RabbitClient[F], connection: model.AMQPC case _ => NullVal } - val fs2MessageHeaders: Map[String, model.AmqpFieldValue] = publishCommand.basicProperties.headers.mapValues(toAmqpValue) + val fs2MessageHeaders: Map[String, model.AmqpFieldValue] = publishCommand.basicProperties.headers.view.mapValues(toAmqpValue).toMap val message = model.AmqpMessage( publishCommand.body.value, @@ -80,7 +80,7 @@ class Fs2RabbitAmqpClient[F[_]](client: RabbitClient[F], connection: model.AMQPC val messageProperties = publish.MessageProperties( contentType = amqpEnvelope.properties.contentType.map(ContentType.apply), contentEncoding = amqpEnvelope.properties.contentEncoding.map(ContentEncoding.apply), - headers = amqpEnvelope.properties.headers.mapValues(_.toValueWriterCompatibleJava), + headers = amqpEnvelope.properties.headers.view.mapValues(_.toValueWriterCompatibleJava).toMap, deliveryMode = amqpEnvelope.properties.deliveryMode.map(dm => DeliveryMode(dm.value)), priority = amqpEnvelope.properties.priority, correlationId = amqpEnvelope.properties.correlationId, @@ -109,11 +109,11 @@ class Fs2RabbitAmqpClient[F[_]](client: RabbitClient[F], connection: model.AMQPC ) } - override def declare(declarations: decl.Declaration*): F[Unit] = declare(declarations.toIterable) + override def declare(declarations: decl.Declaration*): F[Unit] = declare(declarations.toList) override def declare(declarations: Iterable[decl.Declaration]): F[Unit] = { def argumentsFromAnyRef(arguments: Map[String, AnyRef]): Map[String, SafeArg] = - arguments.mapValues { + arguments.view.mapValues[SafeArg] { case arg: String => arg case arg: BigDecimal => arg case arg: Integer => arg.intValue() @@ -125,7 +125,7 @@ class Fs2RabbitAmqpClient[F[_]](client: RabbitClient[F], connection: model.AMQPC case arg: java.lang.Byte => arg.byteValue() case arg: java.util.Date => arg case t => throw new IllegalArgumentException(s"Unsupported type for rabbit arguments $t") - } + }.toMap def exchangeTypeToFs2ExchangeType(exchangeType: ExchangeType): model.ExchangeType = exchangeType match { diff --git a/build.sbt b/build.sbt index 9941a9a..d2b3ccc 100644 --- a/build.sbt +++ b/build.sbt @@ -167,10 +167,7 @@ lazy val backendJavaAmqp = project lazy val backendFs2Rabbit = project .settings(name := "com.itv") .settings(moduleName := "bucky-backend-fs2-rabbit") - .settings(kernelSettings: _*) - .configs(IntegrationTest) - .settings(Defaults.itSettings) - .settings(inConfig(ITTest)(Defaults.testSettings): _*) + .settings(kernelSettings) .dependsOn(core) .aggregate(core) .settings(