Eventsourced and reliable channel in Scala

event_sourced_channel.scala

class Sender(receiverPath: String) extends Actor {
  val id = 1
  val ext = EventsourcingExtension(context.system)
  val proxy = context.actorOf(
    Props(new DestinationProxy(receiverPath)))
  val channel = ext.channelOf(ReliableChannelProps(1, proxy)
    .withRedeliveryMax(1000)
    .withRedeliveryDelay(1 second)
    .withConfirmationTimeout(2 seconds))

  def receive = {
    case msg: Message => {
      sender ! s"accepted ${msg.event}"
      channel forward msg
    }
  }
}