durre

import { createOrderDao } from './orderDao'
import { createProductDao } from './productDao'
import { createPaymentService } from './paymentService'
import { createOrderService } from './orderService'

const orderDao = createOrderDao()
const productDao = createProductDao()
const paymentService = createPaymentService()

const orderService = createOrderService({ orderDao, productDao, paymentService })

durre

object FutureUtils {

  def sequenceOr[T](result: Or[Future[T], ErrorMessage]): Future[Or[T, ErrorMessage]] = {
    result match {
      case Good(futureValue) => futureValue.map(Good(_))
      case Bad(msg) => Future.successful(Bad(msg))
    }
  }
}

durre

import akka.actor.ActorLogging
import akka.stream.actor.ActorPublisher
import akka.util.ByteString
import com.rabbitmq.client._

class RabbitConsumerActor(connection: Connection, queue: Queue) extends ActorPublisher[RabbitMessage] with ActorLogging {

  val channel = connection.createChannel()
  val consumer = new DefaultConsumer(channel) {
    override def handleDelivery(consumerTag: String, envelope: Envelope, properties: AMQP.BasicProperties, body: Array[Byte]) =