Reformat with scalafmt 3.9.10

Executed command: scalafmt --non-interactive

Author: scala-steward

core/src/main/scala/org/elasticmq/actor/queue/QueueActorMessageOps.scala

@@ -33,7 +33,7 @@ trait QueueActorMessageOps
         receiveMessages(visibilityTimeout, count, receiveRequestAttemptId).send()
       case DeleteMessage(deliveryReceipt) =>
         deleteMessage(deliveryReceipt).send()
-      case LookupMessage(messageId) => messageQueue.getById(messageId.id).map(_.toMessageData)
+      case LookupMessage(messageId)                           => messageQueue.getById(messageId.id).map(_.toMessageData)
       case MoveMessage(message, destination, sourceQueueName) =>
         moveMessage(message, destination, sourceQueueName).send()
       case DeduplicationIdsCleanup =>

core/src/main/scala/org/elasticmq/actor/queue/QueueActorQueueOps.scala

@@ -10,7 +10,7 @@ trait QueueActorQueueOps extends Logging {
 
   def receiveAndReplyQueueMsg[T](msg: QueueQueueMsg[T]): ReplyAction[T] =
     msg match {
-      case GetQueueData() => queueData
+      case GetQueueData()                                                   => queueData
       case UpdateQueueDefaultVisibilityTimeout(newDefaultVisibilityTimeout) =>
         logger.info(s"${queueData.name}: Updating default visibility timeout to $newDefaultVisibilityTimeout")
         queueData = queueData.copy(defaultVisibilityTimeout = newDefaultVisibilityTimeout)
@@ -40,7 +40,7 @@ trait QueueActorQueueOps extends Logging {
         messageQueue.clear()
         fifoMessagesHistory = FifoDeduplicationIdsHistory.newHistory()
       case GetQueueStatistics(deliveryTime) => getQueueStatistics(deliveryTime)
-      case UpdateQueueTags(newQueueTags) =>
+      case UpdateQueueTags(newQueueTags)    =>
         logger.info(s"${queueData.name} Adding and Updating tags ${newQueueTags}")
         queueData = queueData.copy(tags = queueData.tags ++ newQueueTags)
       case RemoveQueueTags(tagsToRemove) =>

core/src/main/scala/org/elasticmq/actor/queue/operations/MoveMessageOps.scala

@@ -22,7 +22,7 @@ trait MoveMessageOps extends Logging {
         if (queueData.isFifo) {
           CommonOperations.wasRegistered(messageWithSourceQueueName.toNewMessageData, fifoMessagesHistory) match {
             case Some(_) => ResultWithEvents.empty
-            case None =>
+            case None    =>
               logger.debug(s"Moved message (${messageWithSourceQueueName.id}) from FIFO queue to ${queueData.name}")
               moveMessageToQueue(regenerateDeduplicationId(messageWithSourceQueueName))
           }

persistence/persistence-file/src/main/scala/org/elasticmq/persistence/file/QueueConfigUtil.scala

@@ -25,7 +25,7 @@ object QueueConfigUtil extends Logging {
         .toMap
     ) match {
       case Success(value) => getQueuesFromConfig(value)
-      case Failure(ex) => {
+      case Failure(ex)    => {
         logger.error("Failed to extract queue configuration", ex)
         throw new IllegalStateException(ex)
       }
@@ -35,7 +35,7 @@ object QueueConfigUtil extends Logging {
   private def getQueuesFromConfig(queuesConfig: Map[String, ConfigValue]): List[CreateQueueMetadata] = {
     Try(getQueuesFromConfigUnsafe(queuesConfig)) match {
       case Success(value) => value
-      case Failure(ex) => {
+      case Failure(ex)    => {
         logger.error("Failed to create queues from config", ex)
         throw new IllegalStateException(ex)
       }

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/AttributesModule.scala

@@ -109,7 +109,7 @@ trait AttributesModule {
     def read(parameters: Map[String, String]): Map[String, String] = {
       def collect(suffix: Int, acc: Map[String, String]): Map[String, String] = {
         parameters.get("Attribute." + suffix + ".Name") match {
-          case None => acc
+          case None     => acc
           case Some(an) =>
             collect(suffix + 1, acc + (an -> parameters("Attribute." + suffix + ".Value")))
         }

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/CancelMessageMoveTaskDirectives.scala

@@ -23,7 +23,7 @@ trait CancelMessageMoveTaskDirectives { this: ElasticMQDirectives with QueueURLM
         await(
           queueManagerActor ? CancelMessageMoveTask(params.TaskHandle)
         ) match {
-          case Left(e: ElasticMQError) => throw e.toSQSException
+          case Left(e: ElasticMQError)                 => throw e.toSQSException
           case Right(approximateNumberOfMessagesMoved) =>
             complete(CancelMessageMoveTaskResponse(approximateNumberOfMessagesMoved))
         }

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/ChangeMessageVisibilityDirectives.scala

@@ -23,7 +23,7 @@ trait ChangeMessageVisibilityDirectives { this: ElasticMQDirectives with Respons
         )
         result.map {
           case Left(error) => throw error.toSQSException
-          case Right(_) =>
+          case Right(_)    =>
             emptyResponse("ChangeMessageVisibilityResponse")
         }
       }

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/DeleteMessageBatchDirectives.scala

@@ -27,7 +27,7 @@ trait DeleteMessageBatchDirectives {
           val result = queueActor ? DeleteMessage(DeliveryReceipt(receiptHandle))
 
           result.flatMap {
-            case Right(_) => Future.successful(BatchDeleteMessageResponseEntry(id))
+            case Right(_)            => Future.successful(BatchDeleteMessageResponseEntry(id))
             case Left(invalidHandle) =>
               Future.failed(invalidHandle.toSQSException)
           }

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/ResponseMarshaller.scala

@@ -25,7 +25,7 @@ trait ResponseMarshaller { this: RespondDirectives =>
   ): Marshaller[T, RequestEntity] =
     marshallerDependencies.protocol match {
       case AWSProtocol.`AWSJsonProtocol1.0` => sprayJsonMarshaller[T]
-      case _ =>
+      case _                                =>
         namespace { ns =>
           Marshaller.withFixedContentType[T, RequestEntity](`text/xml(UTF-8)`) { t =>
             val xml = xmlSerializer.toXml(t) % ns

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/SendMessageDirectives.scala

@@ -145,7 +145,7 @@ trait SendMessageDirectives {
       .get(AwsTraceHeaderSystemAttribute)
       .map {
         case StringMessageAttribute(value, _) => TracingId(value)
-        case NumberMessageAttribute(_, _) =>
+        case NumberMessageAttribute(_, _)     =>
           throw SQSException.invalidParameter(
             s"$AwsTraceHeaderSystemAttribute should be declared as a String, instead it was recognized as a Number"
           )