Hey,
I really have problems understanding the TLS Bidi-Flows. The specs are not
very helpful as they only do "echo" the input as fas as I understood and
there is not official documentation. What I have so far:
* A TCP flow (Flow[ByteString, ByteString])
* A logical flow (Flow[ByteString, ByteString])
How can i connect this to the TLS Bidi-Flow. Here is the code I tried:
val session =
NegotiateNewSession.withDefaults.withCipherSuites("TLS_RSA_WITH_AES_128_CBC_SHA")
.withCipherSuites("TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256","TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA",
"TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384","TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA",
"TLS_DHE_RSA_WITH_AES_256_CBC_SHA",
"TLS_DHE_RSA_WITH_AES_128_CBC_SHA","TLS_RSA_WITH_AES_128_CBC_SHA256","TLS_RSA_WITH_AES_128_CBC_SHA",
"TLS_RSA_WITH_AES_256_CBC_SHA256", "TLS_RSA_WITH_AES_256_CBC_SHA")
.withProtocols("TLSv1.2")
.withClientAuth(ClientAuth.None)
val closing = IgnoreComplete
val tlsHandler = SslTls(sslContext, session, akka.stream.io.Role.server,
closing)
val logicalFlow = getLogicalFlow
// SslTlsInbound to bytes
val inboundFlow: Flow[SslTlsInbound, ByteString, Unit] =
Flow[SslTlsInbound].map {
case SessionBytes(_, bytes: ByteString) =>
log.info("Received bytes")
bytes
case SessionTruncated => sys.error("Truncated")
}
// bytes to SslTlsOutbound
val outboundFlow: Flow[ByteString, SslTlsOutbound, Unit] = Flow[ByteString].map
{
case bytes: ByteString =>
log.info("Sending bytes")
SendBytes(bytes)
}
val tlsFlow = Flow() { implicit builder =>
import FlowGraph.Implicits._
val tls = builder.add(tlsHandler)
// Define outbound/inbound flows
tls.out2 ~> inboundFlow ~> tls.in2
// tls.out1 ~> outboundFlow ~> tls.in1
tls.in1 <~ outboundFlow <~ tls.out1
// Define in/outlet
(tls.in2, tls.out1)
}
// conn = Tcp.IncomingConnection
conn.handleWith(tlsFlow)
As soon as I start the application I get this error-message:
Cannot build Flow with open inputs () and outputs ()
info] akka.actor.ActorInitializationException: exception during creation
info] at akka.actor.ActorInitializationException$.apply(Actor.scala:166)
info] at akka.actor.ActorCell.create(ActorCell.scala:596)
info] at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
info] at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
info] at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
info] at akka.dispatch.Mailbox.run(Mailbox.scala:219)
info] at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
info] at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
info] at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
info] at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
info] at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
info] Caused by: java.lang.IllegalArgumentException: Cannot build Flow with
open inputs () and outputs ()
info] at akka.stream.scaladsl.FlowGraph$Builder.buildFlow(Graph.scala:427)
info] at akka.stream.scaladsl.FlowApply$class.apply(FlowApply.scala:18)
info] at akka.stream.scaladsl.Flow$.apply(Flow.scala:313)
I do not understand where I should have open inputs or outputs? All the
BIDI-Flow inputs should be in use?
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
