Hello,
I'm working on a client-side application atop tcp streams, and I'm
curious what is the recommended approach for handling reconnects. I'm
thinking to wrap the underlying transport flow in an AsyncStage, and then
rematerialize the transport on completion. It would look something like
this:
class ReconnectionStage[In, Out](transport: Flow[In, Out, Any],
maxInFlight: Int) extends AsyncStage[In, Out, Any] {
private var inFlight = 0
private val buffer = FixedSizeBuffer[Out](maxInFlight)
private var fm: FlowMaterializer = _
private var callback: AsyncCallback[Any] = _
private var runnableFlow: RunnableFlow[(ActorRef, Future[Unit])] = _
private var input: ActorRef = _
private def connect() {
val (ref, future) = runnableFlow.run()(fm)
input = ref
future.onComplete( _ => callback.invoke(Reconnect))(fm.executionContext)
}
override def preStart(ctx: AsyncContext[Out, Any]) {
fm = ctx.materializer
callback = ctx.getAsyncCallback()
runnableFlow = Source.actorRef(maxInFlight, OverflowStrategy.fail)
.via(transport).toMat(Sink.foreach(callback.invoke))(Keep.both)
}
...
}
It's a bit involved, and I haven't yet finished -- so I guess I'm just here
to check if I'm even on the right track :)
Cheers,
Peter
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
