Uncaught write failures in StatefulProcessor

[DavidTegtmeyer]

When an StatefulProcessor encounters a timeout while writing events it does not seem to retry the write attempt, but fails immediately with the following stack trace:

com.rbmhtechnology.eventuate.EventsourcedWriter$WriteException: write failed
        at com.rbmhtechnology.eventuate.EventsourcedWriter$class.writeFailure(EventsourcedWriter.scala:153)
...
com.rbmhtechnology.eventuate.EventsourcedWriter$$anonfun$com$rbmhtechnology$eventuate$EventsourcedWriter$$initiatedWrite$1.applyOrElse(EventsourcedWriter.scala:240)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
        at akka.actor.Actor$class.aroundReceive(Actor.scala:484)
        at rgp.bookmaking.betbrain.actor.BetBrainAdapter.aroundReceive(BetBrainAdapter.scala:41)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
        at akka.actor.ActorCell.invoke(ActorCell.scala:495)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
        at akka.dispatch.Mailbox.run(Mailbox.scala:224)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
        at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: localhost/127.0.0.1:9042 (com.datastax.driver.core.exceptions.OperationTimedOutException: [localhost/127.0.0.1] Timed out waiting for server response))
        at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:476)
        at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:435)
        at com.rbmhtechnology.eventuate.log.cassandra.package$$anon$1$$anonfun$run$1.apply(package.scala:30)
        at scala.util.Try$.apply(Try.scala:192)
        at com.rbmhtechnology.eventuate.log.cassandra.package$$anon$1.run(package.scala:30)
        at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
        at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:409)
        ... 4 common frames omitted