Conflict is what creates drama. The more conflict actors find, the more interesting the performance.
- Michael Shurtleff 

Akka Messages

_{Built with ❤︎ by developers @UTN}

---

Purpose

Explore concurrency models. Akka is one of the main choices whenever you want to enter the concurrency world. Or at least that's what people say...let's find out how hard it is to deal with this :)

---

Setup

Scala + SBT

First download Scala + SBT from here: https://www.scala-lang.org/download/

Akka

Then Download this repo and let the IDE import all things. This might take a while...you can force the update from the console also with: sbt reload clean compile If you're interested in what does each command go to here: https://www.scala-sbt.org/1.x/docs/Command-Line-Reference.html

Start this thing!

Stand in the root directory of this project and execute

sbt "runMain com.omnipresent.AkkaMessages 2551"

You should span several processes to see the sharding working. Run the same command with new ports such as 2552, 9000, etc.

Endpoints

Up to this date we have the following endpoints:

• Queues

🌠 Queues

[GET] /queues

Here you'll see all available queues' names.

[POST] /queues

To create queues.

{
  "name": "cola_1",
  "producers": 1,
  "workers": 3,
  "jobInterval": 1,
  "spreadType": "pubsub"
}

[GET] /queues/:id

Extra info about queues? [WIP]