initial commit

Author: baovitt

build.sbt

@@ -439,6 +439,11 @@ lazy val scala_libraries = (project in file("scala-libraries"))
       "nl.gn0s1s" %% "elastic4s-core" % elastic4sVersion,
       logback
     ),
+    libraryDependencies ++= Seq(
+      "org.elasticmq" %% "elasticmq-core" % "1.6.5",
+      "org.elasticmq" %% "elasticmq-server" % "1.6.5",
+      "org.elasticmq" %% "elasticmq-rest-sqs" % "1.6.5"
+    ),
     Defaults.itSettings
   )
 

scala-libraries/README.md

@@ -7,4 +7,5 @@
 - [A Guide to the Scala Retry Library](https://www.baeldung.com/scala/retry-library)
 - [Introduction to Apache Log4j in Scala](https://www.baeldung.com/scala/apache-log4j)
 - [Logging in Scala Applications Using Scala-Logging](https://www.baeldung.com/scala/scala-logging)
-- [AWScala – AWS SDK for Scala](https://www.baeldung.com/scala/awscala-aws-sdk-for-scala)
+- [AWScala – AWS SDK for Scala](https://www.baeldung.com/scala/awscala-aws-sdk-for-scala)
+- [Introduction to ElasticMQ] https://baeldung.com/scala/introduction-to-elasticmq

scala-libraries/src/main/scala/com/baeldung/elasticmq/DirectClient.scala

@@ -0,0 +1,5 @@
+package com.baeldung.elasticmq
+
+// val config = ConfigFactory.load("elasticmq.conf")
+// val server = new ElasticMQServer(new ElasticMQServerConfig(config))
+// server.start()

scala-libraries/src/main/scala/com/baeldung/elasticmq/RestClient.scala

@@ -0,0 +1,31 @@
+package com.baeldung.elasticmq
+
+import org.elasticmq.rest.sqs.SQSRestServerBuilder
+import org.elasticmq.server.ElasticMQServer
+import org.elasticmq.server.config.ElasticMQServerConfig
+
+import com.typesafe.config.ConfigFactory
+
+import org.apache.pekko.actor.{Actor, ActorRef, ActorSystem}
+import org.apache.pekko.event.LoggingAdapter
+
+implicit val actorSystem: ActorSystem = ActorSystem.create()
+implicit val executionContext: concurrent.ExecutionContextExecutor = actorSystem.dispatcher
+implicit val m_logger: LoggingAdapter = actorSystem.log
+
+// class QueueActor extends Actor:
+//   val messageQueue: mutable.PriorityQueue[InternalMessage]()
+//   val awaiting: mutable.PriorityQueue[ActorRef]()
+
+//   def receive = case ReceiveMessages =>
+
+
+// val result: Future[ActorRef] = flow:
+//   (queueManager ? Lookup(name)).apply() match
+//     case Some(queueActor) => queueActor
+//     case None => (queueManager ? Create(name)).apply()
+
+lazy val server = SQSRestServerBuilder
+  .withPort(9325)
+  .withInterface("localhost")
+  .start()