the thread-pool-executor.
>
> > Or it intended that every Flow is doing his work in it's own thread?
>
> No.
>
> -Endre
>
>
>
> On Tue, Apr 19, 2016 at 3:48 PM, Thomas Zimmer > wrote:
>
>> Hey guys,
>>
>> I have an application where I ex
Hey guys,
I have an application where I expect many clients to connect to via TCP. So
my design is the following. I have these two actor-types:
* Server-Actor - Accepts incoming TCP connections (Uses Reactive TCP -
Stream). Per incoming request i spawn a new "ClientSession" - actor
instance.
*
s above, you
> can use them as a template for your own:
> https://github.com/akka/akka/blob/master/akka-stream/src/main/scala/akka/stream/impl/Timers.scala
>
> -Endre
>
> On Thu, Feb 11, 2016 at 5:04 PM, Thomas Zimmer > wrote:
>
>> Ah sorry for not making a clear stateme
ncer connection?
>
> -Endre
>
> On Thu, Feb 11, 2016 at 4:45 PM, Thomas Zimmer > wrote:
>
>> Excatly. I use the PROXY Protocol which only sends a string "PROXY IP IP
>> port port\r\n" right in the beginning. So can you think of any good
>> solutio
Excatly. I use the PROXY Protocol which only sends a string "PROXY IP IP
port port\r\n" right in the beginning. So can you think of any good
solution?
On Thursday, February 11, 2016 at 4:43:08 PM UTC+1, drewhk wrote:
>
>
>
> On Thu, Feb 11, 2016 at 4:24 PM, Thomas Zimmer
ed with 1.X versions btw, and I think it did not in
> more recent versions.
>
> -Endre
>
> On Thu, Feb 11, 2016 at 3:36 PM, Thomas Zimmer > wrote:
>
>> Hello,
>>
>> I was playing around with Stream API 2.0 where I got a strange
>> error-message:
>&
Hello,
I was playing around with Stream API 2.0 where I got a strange
error-message:
"Cannot materialize an incoming connection Flow twice.". I could track down
the issue to a code-line. So this what I am doing
Server code:
val connections = Tcp().bind(localHost.getHostName, port, backlog,
One question in general: Is it better to have different FlowGraphs and set
them up in one large or flow or join different Flows directly to each
other?
Regards,
Thomas
On Tuesday, July 21, 2015 at 9:45:22 AM UTC+2, Thomas Zimmer wrote:
>
> Thanks Chad and also thank you √ (Strange name
Monday, July 20, 2015 at 8:25:52 PM UTC+2, √ wrote:
>
> Hi Thomas,
>
> as I said, I don't have access to a REPL right now.
>
> What does "but i cannot use atop on top of the tlsHandler" mean? What did
> you try, what did the compiler say? How did you adapt the cod
z wrote:
>
> Here is an example from an old version of my project using "atop":
> https://github.com/cretz/scimap/blob/dcd380e9f003864d768f1069c34b703dc488d10e/src/main/scala/scimap/handler/FlowBuilder.scala#L75.
>
> My more recent versions needed conditional TLS so I
of the bidiflow you get from the
> previous steps, add a join with the identity flow (Flow[Out1, In2]) or use
> a Flow.apply with a builder to manually connect the ports.
>
> On Mon, Jul 20, 2015 at 4:36 PM, Thomas Zimmer > wrote:
>
>> Can you tell me how to setup the correct
with 1 input and 1 output, you are connecting the
> bidiflow (2 inputs and 2 outputs) to eachother, leaving no inputs nor
> outputs open, which means it cannot be a Flow.
>
> On Mon, Jul 20, 2015 at 2:58 PM, Thomas Zimmer > wrote:
>
>> Hey,
>>
>> I really have pr
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, ByteSt
Hi,
i got a more conceptual question. Is it more to common to emit a message to
a ActorRef directly or use the ActorSelection instead? I am thinking of the
following use-case: I got a "business logic" actor (A) and a "persistence
logic" actor (B). So if i A wants to tell B to save a DB-Entry wo
-Endre
>
>
>>
>> Maybe you could use that as a starting point to chunk up the bytestring
>> into the header bytestring and payload bytestring.
>>
>> B/
>>
>> On 26 January 2015 at 12:09:57, Thomas Zimmer (
>> t...@turtle-entertainment.de ) wrote
>
>
>>
>> Maybe you could use that as a starting point to chunk up the bytestring
>> into the header bytestring and payload bytestring.
>>
>> B/
>>
>> On 26 January 2015 at 12:09:57, Thomas Zimmer (
>> t...@turtle-entertainment.de ) wrote:
>
Hi,
i have a question regarding TCP Streams and request strategies. Lets say i
have a TCPStream build upon the ReactiveStream Framework. I have a
Subscriber to consume the incoming data as a Sink using the
ActorSubscriber. Now my problem is that i have a binary network protocol
that looks like
t; directly -- otherwise, you may want to look at RFC 6125 for a generic
> server identity check. More here:
> http://tersesystems.com/2014/03/23/fixing-hostname-verification/
>
> Hope that helps,
>
> Will.
>
> On Friday, December 19, 2014 8:56:39 AM UTC-8, Thomas
Maybe this
helps: https://groups.google.com/d/msg/akka-user/stx5uNdoPxg/chnccBkvPNsJ
On Wednesday, December 24, 2014 5:16:10 PM UTC+1, Timothy Klim wrote:
>
> Hi.
> I'm trying to use new ssl/tls stream in smtpd server based on akka io.
> Are you included a spec for SslTlsCipher.scala? Within bran
Hi,
i created a simple application
(https://gist.github.com/Alien2150/9468c871135fd94869a2) to play around
with the SSL-Stream. But as soon as my client has been closed I am seeing
this log-message (without receiving any OnComplete messages):
[INFO] [01/07/2015 14:12:53.549] [app-akka.actor.de
:
ServerBinding.Connections -> TlsCipher -> SessionInboundData.
Regards,
Thomas
On Friday, December 19, 2014 8:31:23 PM UTC+1, rkuhn wrote:
>
> Thanks for sharing!
>
> 19 dec 2014 kl. 17:56 skrev Thomas Zimmer >:
>
> Hi,
>
> I also had this issue but
Hi,
I also had this issue but thanks to some examples
[https://github.com/xbucchiotty/akka-stream-ssltlscipher/blob/master/src/test/scala/Test.scala]
and of course the TLS Specs
[https://github.com/akka/akka/blob/62a20195af79c7b405303b5f97970c9ca7a6891a/akka-stream/src/test/scala/akka/stream/i
22 matches
Mail list logo
