diff --git a/azure/service-bus/src/main/scala/com/commercetools/queue/azure/servicebus/ServiceBusMessageContext.scala b/azure/service-bus/src/main/scala/com/commercetools/queue/azure/servicebus/ServiceBusMessageContext.scala index 0d912ea..b128b09 100644 --- a/azure/service-bus/src/main/scala/com/commercetools/queue/azure/servicebus/ServiceBusMessageContext.scala +++ b/azure/service-bus/src/main/scala/com/commercetools/queue/azure/servicebus/ServiceBusMessageContext.scala @@ -37,7 +37,7 @@ class ServiceBusMessageContext[F[_], T]( override def metadata: Map[String, String] = underlying.getRawAmqpMessage.getApplicationProperties.asScala.view.collect { - case (k, v) if v.isInstanceOf[String] => (k, v.asInstanceOf[String]) + case (k, v: String) => (k, v) }.toMap override def ack(): F[Unit] =