Re: Re: Re: [akka-user] How to pipe reactive mongo results into a WebSocket stream

2015-11-25 Thread Akka Team
down to the Graph DSL and add a Merge node there wiith an eagerClose=true parameter (the current merge on Flow does not have that parameter exposed). This will close the WS as soon as the client closes. -Endre > > Cheers > > Stefan > > *Gesendet:* Mittwoch, 25. November 2015 u

Re: [akka-user] [akka-http] How many stream/graph instances will be materialized when binding to Http?

2015-11-26 Thread Akka Team
uot;, then I think it's > not a big deal. (Assuming the connection object is reusable across requests) > > Leon > > > 在 2015年11月25日星期三 UTC-8上午2:41:39,Akka Team写道: >> >> Ok, then the answer is that one stream will be materialized for each >> incoming c

Re: [akka-user] [Akka-stream] question about building graph

2015-11-26 Thread Akka Team
+ flow2 + flow3 > if(A.property1 ==2) goes to flow4 + flow5 > if(A.property1 == 3) goes to flow6 + flow7 + flow8 + flow9 > ... > ... > > > > > It seems what I want is a black box composite flow that encapsulate all > above sub flows and output them in orders. > > How

Re: [akka-user] [Akka-stream] Will Broadcast + merge keep the message order?

2015-11-26 Thread Akka Team
gic for A.property1. > > What I want is actually a "high level" branching "Fan-out" ( like a > conditional Balance) + ordered "Fan-in" > > > > Leon > > > 在 2015年11月25日星期三 UTC-8上午2:50:02,Akka Team写道: >> >> Hi Leon, >> >&g

Re: [akka-user] Two tcp connections between two actorsystems

2015-11-26 Thread Akka Team
;>>>>>>>>> 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 &g

Re: [akka-user] Two tcp connections between two actorsystems

2015-11-26 Thread Akka Team
a bug. Can you reproduce this reliably? -Endre > > And it seemed that websocket server A could never receive > ConnectionRegistered messages after business server restarted. I waited for > 10 minutes. At last I have to restart websocket server A. > > On Thu, Nov 26, 2015 at 6:4

Re: [akka-user] [akka-stream] How to create Source and push elements to it manually?

2015-11-26 Thread Akka Team
c.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 unsu

Re: [akka-user] Two tcp connections between two actorsystems

2015-11-26 Thread Akka Team
restarts, the websocket server A may sends > hundreds of ConnectionOpened messages via ActorSelection at the same time. > There may be a race condition? > > > On Thu, Nov 26, 2015 at 8:16 PM, Akka Team > wrote: > >> Hi, >> >> On Thu, Nov 26, 2015 at 1:13 PM, j

Re: [akka-user] [akka-stream] unfold / unfoldM

2015-11-26 Thread Akka Team
ou 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-use

Re: [akka-user] [akka-stream] unfold / unfoldM

2015-11-26 Thread Akka Team
1: scala.concurrent.Future[Unit] = >>> scala.concurrent.impl.Promise$DefaultPromise@14bc1d08 >>> >>> scala> 0 >>> 1 >>> 1 >>> 2 >>> 3 >>> 5 >>> 8 >>> 13 >>> 21 >>> 34 >>> 55 >>

Re: [akka-user] [akka-http] How many stream/graph instances will be materialized when binding to Http?

2015-11-27 Thread Akka Team
7;t see the internal changes, but they are there. Btw, before worrying about the costs you should measure if the performance is up to your expectations. -Endre > > 在 2015年11月26日星期四 UTC-8上午1:17:46,Akka Team写道: >> >> Hi Leon, >> >> > Just worry about the cost of the

Re: [akka-user] [Akka-stream] Will Broadcast + merge keep the message order?

2015-11-27 Thread Akka Team
e please share. Also, please note that this is equivalent to the case of actors. If you have two actors, that handle two different message types coming from a third actor must coordinate to sequentially emit to a fourth actor because Akka does not guarantee message ordering for unrelated senders

Re: [akka-user] [akka-stream] unfold / unfoldM

2015-11-27 Thread Akka Team
t;>>>>> E)])akka.stream.scaladsl.Source[E,Unit] >>>>>> >>>>>> scala> unfold(0->1){ >>>>>> | case (a,b) if a < 1000 => Some((b->(a+b),a)) >>>>>> | case _ => None &

Re: [akka-user] Re: Wikipedia presence

2015-12-24 Thread Akka Team
> 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-use

Re: [akka-user] Nginx error when proxying to Akka Http and large response sizes

2016-01-20 Thread Akka Team
ause 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 th

Re: [akka-user] Re: artificially completing an infinite akka stream

2016-01-20 Thread Akka Team
/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 sto

Re: [akka-user] Akka sharding security - is shardRegion custom behavior possible to implement this?

2016-01-20 Thread Akka Team
kka-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

Re: [akka-user] Does akka streams support a getDataBytes() with context flow?

2016-01-20 Thread Akka Team
ubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: le

Re: [akka-user] How-to start a not uniform flow in java?

2016-01-20 Thread Akka Team
.com/d/optout. >>> >> >> -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> S

Re: [akka-user] [akka-http] drain connection or it will be Stalled

2016-01-20 Thread Akka Team
t;>>>>>>> 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 subscr

Re: [akka-user] unsubscribeAll(C classifier) for LookupEventBus?

2016-01-20 Thread Akka Team
ups > "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 https://groups.google.com/group

Re: [akka-user] Akka's actor based custom Event Bus implementation casues bottleneck

2016-01-20 Thread Akka Team
nd an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe -

Re: [akka-user] akka-http Graceful Shutdown with Akka-Agents?

2016-01-21 Thread Akka Team
t; "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 https://groups.google.com/group

Re: [akka-user] [Akka-Stream] How to balance between a dynamic number of flow

2016-01-21 Thread Akka Team
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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. &g

Re: [akka-user] Adaptive Load Balancing with DistributedPubSub Extension

2016-01-21 Thread Akka Team
roup/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,

Re: [akka-user] akka-http Graceful Shutdown with Akka-Agents?

2016-01-21 Thread Akka Team
Hi Jan, On Thu, Jan 21, 2016 at 3:26 PM, Jan Algermissen wrote: > Hi Endre, > > On Thursday, January 21, 2016 at 11:57:27 AM UTC+1, Akka Team wrote: >> >> Hi Jan, >> >> For these case I would use a simple >> java.util.concurrent.atomic.AtomicReference()

Re: [akka-user] Re: ETL with Akka Streams

2016-01-22 Thread Akka Team
Hi Richard, Oops, my bad. The groupWithin on the SubFlow does seem to work as expected. > Glad to hear that! > > Comments on the overall approach still welcomed! > Unfortunately, given the current load on the Akka team, I would rather recommend to pose smaller questions as we can

Re: [akka-user] [Akka-Stream] Help to build a looping graph/flow

2016-01-22 Thread Akka Team
t; To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: letitcrash.com Twitter: @akkate

Re: [akka-user] Akka remote communication roadmap?

2016-01-22 Thread Akka Team
teeing per-pair ordering with at-most-once semantics (*) >>>>- … across connection failures >>>> >>>> I’d very much like to dump as much of the baggage as possible to make >>>> headway, but this will mean that we become (even) more opinionated in t

Re: [akka-user] [Akka-Http] Client API sample

2016-01-22 Thread Akka Team
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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.

Re: [akka-user] Akka and Akka Stream performance.

2016-01-22 Thread Akka Team
iving 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > --

Re: [akka-user] How to use UnzipWith

2016-01-22 Thread Akka Team
scribed 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 https://groups

Re: [akka-user] akka-http graceful shutdown - what is the effect of ServerBinding#unbind

2016-01-22 Thread Akka Team
+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the

Re: [akka-user] Akka remote communication roadmap?

2016-01-22 Thread Akka Team
re 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 https://

Re: [akka-user] Re: Can I Pause some Flow In the the akka-stream?

2016-02-22 Thread Akka Team
//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

Re: [akka-user] Akka remote communication roadmap?

2016-02-22 Thread Akka Team
es: 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.

Re: [akka-user] groupBy limits

2016-02-22 Thread Akka Team
d 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] testing database connection error when using akka persistence

2016-02-22 Thread Akka Team
mail to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the

Re: [akka-user] Split bytestring source into several sources

2016-02-22 Thread Akka Team
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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. >

Re: [akka-user] Coordination between several Akka clusters

2016-02-22 Thread Akka Team
eceiving 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. >

Re: [akka-user] Re: Using local file system to store Actor's state ?

2016-02-22 Thread Akka Team
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+...@googlegroups.com. >> To post to this group, send email to akka...@googlegroups.com. &g

Re: [akka-user] [akka-stream] Is there a way to access Configuration from Flow?

2016-02-22 Thread Akka Team
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 gr

Re: [akka-user] Disable hostname verification

2016-02-22 Thread Akka Team
his 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

Re: [akka-user] Re: Can I Pause some Flow In the the akka-stream?

2016-02-23 Thread Akka Team
up 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. >

Re: [akka-user] Re: what gets serialized and when

2016-02-24 Thread Akka Team
s.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 t

Re: [akka-user] Can quarantine happen without remote actor creation or watching?

2016-02-24 Thread Akka Team
ot; 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 https://groups.google.com/group/akka-user. > For more opti

Re: [akka-user] Can quarantine happen without remote actor creation or watching?

2016-02-24 Thread Akka Team
e 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 beca

Re: [akka-user] [Stream] Connecting arbitrary number of graphs with materialized values

2016-02-26 Thread Akka Team
s.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

Re: [akka-user] Quite stdout when using the TestEventListener?

2016-02-26 Thread Akka Team
kka-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 ema

Re: [akka-user] SSL Encrypting between Remote Client and Akka cluster

2016-02-26 Thread Akka Team
he 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"

Re: [akka-user] DistributedPubSub -- list of topics

2016-02-26 Thread Akka Team
uot; 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 https://groups.google.com/group/akka-user. > For more op

Re: [akka-user] Re: akka persistence - silent failure for non serializing messages - is that the best we can do?

2016-02-26 Thread Akka Team
ually had to go down to the cellar to find them.” >> “That’s the display department.” >> “With a flashlight.” >> “Ah, well, the lights had probably gone.” >> “So had the stairs.” >> “But look, you found the notice, didn’t you?” >> “Yes,” said Arthur, “yes I did. I

Re: [akka-user] Managing blocking (outside of an Actor or Stream stage)

2016-02-26 Thread Akka Team
kka-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

Re: [akka-user] Akka: distributed pubsub. How to stop an unneeded publisher?

2016-02-26 Thread Akka Team
ubscribed 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. > V

Re: [akka-user] What makes an Actor crash ?

2016-02-26 Thread Akka Team
u 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@goo

Re: [akka-user] Does the Receive Pipeline Pattern play well with non-blocking asynchronous compositions?

2016-02-26 Thread Akka Team
>>>>>>> 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 a

Re: [akka-user] How to stop akka stream that is being processed

2016-02-26 Thread Akka Team
il to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on

Re: [akka-user] Re: akka persistence - silent failure for non serializing messages - is that the best we can do?

2016-02-26 Thread Akka Team
at the error case > ought to be added to the TCK so that you can help them make their solutions > more robust. > > > On 26 February 2016 at 11:38, Akka Team wrote: > >> Hi Tim, >> >> >> >> On Sun, Feb 21, 2016 at 1:23 PM, Tim Pigden >> wr

Re: [akka-user] How to stop akka stream that is being processed

2016-02-26 Thread Akka Team
Also, watch this ticket: https://github.com/akka/akka/issues/19892 On Fri, Feb 26, 2016 at 1:26 PM, Akka Team wrote: > Hi Jerry, > > Let's say I have an akka stream that is being run to materialize to some >> value. I'd like to have ability to cancel it at a cert

Re: [akka-user] akka default dispatcher : parallelism-min & parallelism-max

2016-03-07 Thread Akka Team
ld be 4.0 * 8 cores = 32, which is not lower than 4 and not higher than 64 so the end number would be 32 threads. -- Johan Andrén Akka Team, Lightbend Inc. On Wed, Mar 2, 2016 at 4:34 PM, karthik annamalai wrote: > I am a newbie to akka, so please excuse me if this sounds like a dumb > qu

Re: [akka-user] An equivalent of ReactiveX `PublishSubject` in akka-streams

2016-03-08 Thread Akka Team
Hi Oleg, You are right that "Subscriber" is very low level (and "Processor" is as well) and hard to get right, it is meant for libraries to implement for interop rather than end user implementations. There isn't any component that supports dynamic subscription in akka-streams, so that is why you

Re: [akka-user] Restarting FSMs , and avoiding undesired side-effects

2016-03-08 Thread Akka Team
Hi Spencer, This sounds like it could work with a supervision strategy that does not restart the actor but rather lets it resume on a failure. If that is not possible you would have to move the information that the FSM actor has been previously started somewhere outside of it. Could be to another

Re: [akka-user] circuit breaker sync vs async

2016-03-10 Thread Akka Team
having problems, you would not want to wrap request validation in a circuitbreaker, since an invalid request then might open the breaker stopping other perfectly valid requests from being accepted during the reset timeout. I hope this helps. -- Johan Andrén Akka Team, Lightbend Inc

Re: [akka-user] zipWithIndex

2016-03-10 Thread Akka Team
var index = 0L def next = { index += 1 index } (string) => Iterable((string, next)) } -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: &

Re: [akka-user] Re: Question about kaka-http websocket client

2016-03-10 Thread Akka Team
: val outgoing = Source.single(TextMessage("out")).concatMat(Source.maybe)(Keep.right) This will materialize into a promise that you can complete or fail whenever you want to kill the connection from the client side. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>&

Re: [akka-user] awaitTermination not working?

2016-03-11 Thread Akka Team
Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>

Re: [akka-user] Shutdown HttpServer

2016-03-11 Thread Akka Team
Hi Richard Yes, that sounds right. You could also just keep the future as a direct reference in your actor and then .foreach(binding => binding.unbind()) in preRestart/postStop to make the server lifecycle follow the actor lifecycle. -- Johan Andrén Akka Team, Lightbend

Re: [akka-user] Android chat

2016-03-11 Thread Akka Team
Hi, To notice that you lost contact with the other end of a TCP socket you have to read or write the socket, this is probably best achieved by providing some type of heartbeat in your own protocol. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read

Re: [akka-user] akka.actor.PreRestartException Happening whenever there is restart

2016-03-11 Thread Akka Team
that. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >&g

Re: [akka-user] Re: [2.5-Scala] How to cleanup Sink/Source?

2016-03-11 Thread Akka Team
ing a Sink its InHandler will get onUpstreamFinish and onUpstreamFailure where closing resources can be done. Think of their resources as internal mutable state just like in an actor. It is not another components responsibility to manage such resources. -- Johan Andrén Akka Team, Lightben

Re: [akka-user] akka.http.scaladsl.model.EntityStreamSizeException: null when processing Chunked POST request [2.4.2]

2016-03-11 Thread Akka Team
://github.com/akka/akka/issues/20013 (and a PR to fix this). Thanks for reporting! -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>&g

Re: [akka-user] akka.actor.PreRestartException Happening whenever there is restart

2016-03-11 Thread Akka Team
Option.get does not return null for an empty option, it throws an exception. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>

Re: [akka-user] akka streams over tcp

2016-03-11 Thread Akka Team
e behavior. I hope this helps. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/curren

Re: [akka-user] How-to restart a RunnableGraph on failure?

2016-03-21 Thread Akka Team
kka-user+...@googlegroups.com. >>> To post to this group, send email to akka...@googlegroups.com. >>> Visit this group at https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> -- > >&

Re: [akka-user] Re: Clarification on unreachable nodes in cluster

2016-03-21 Thread Akka Team
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

Re: [akka-user] Re: Clarification on unreachable nodes in cluster

2016-03-21 Thread Akka Team
if system.terminate() could do that for you as part of the > cluster extension then I could simply Await for Future to be > ready. > > On Monday, March 21, 2016 at 9:36:43 AM UTC, Akka Team wrote: >> >> But then you cannot expect a graceful removal from the cluster. >> >&g

Re: [akka-user] How-to restart a RunnableGraph on failure?

2016-03-21 Thread Akka Team
ly no way to restart a whole graph and it is not a trivial problem to tackle in general. -Endre > The work of the stream is "transactional" so I have no problems with the > current broken state caused by the exception. > > For me restart simplifies my code so I think It is

Re: [akka-user] Detecting empty source

2016-03-22 Thread Akka Team
t; --- > 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

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

2016-03-22 Thread Akka Team
s.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: letitcrash.com Twitter: @akkateam

Re: [akka-user] Re: Can't get akka clustering to work in docker

2016-03-22 Thread Akka Team
gt;>>>>>>>> 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 th

Re: [akka-user] Re: Can this be done with the build in stages?

2016-03-22 Thread Akka Team
;>> 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 a

Re: [akka-user] What is the impact of Kafka Streams on reactive-kafka?

2016-03-22 Thread Akka Team
ls 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team

Re: [akka-user] Re: Akka Supervisor Strategy

2016-03-23 Thread Akka Team
: 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

Re: [akka-user] stash with big queues

2016-03-23 Thread Akka Team
o 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 https://g

Re: [akka-user] [akka java 2.4.2] Future callbacks for already completed futures

2016-03-24 Thread Akka Team
ls 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Te

Re: [akka-user] Supervision Strategy with GraphStage doesn't work

2016-04-04 Thread Akka Team
/src/main/scala/akka/stream/impl/fusing/Ops.scala#L57 -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://do

Re: [akka-user] Behavior of akka 2.4.3 with modeled custom headers

2016-04-06 Thread Akka Team
ved 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@google

Re: [akka-user] Routing Kafka messages to websocket

2016-04-06 Thread Akka Team
-- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>

Re: [akka-user] [akka-streams] Resource pool for use within a flow

2016-04-06 Thread Akka Team
in parallell anyway. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/addition

Re: [akka-user] [akka-streams] Resource pool for use within a flow

2016-04-08 Thread Akka Team
ile keeping track of resources etc. but nothing super complicated IMO. -- Johan Andrén Akka Team, Lightbend Inc. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>>

Re: [akka-user] [akka-http-experimental] Testkit not published

2016-04-11 Thread Akka Team
;> 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+

Re: [akka-user] Re: ActorSystem.terminate() couldn't fully terminate the system

2016-04-20 Thread Akka Team
ead >>>> waiting for work, the if there is a thread that is occupied with something, >>>> it would show some of your application classes and methods in it's stack >>>> trace. >>>> >>>> Are you using the latest Cassandra driver? Any

Re: [akka-user] Akka recovery mechanism

2016-04-20 Thread Akka Team
> "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 https://groups.google.com/group/

Re: [akka-user] Akka graph stream failed to produce output

2016-04-20 Thread Akka Team
; >>>>>>>>>> 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 &

Re: [akka-user] Handling HTTPS with Akka-http

2016-04-20 Thread Akka Team
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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe -

Re: [akka-user] Akka Singleton Cluster: resolveOnce of a worker by master fails after restart

2016-04-20 Thread Akka Team
>>>> 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 > emai

Re: [akka-user] Code example of Akka Stream where Source is bulk data (records read in chunks)

2016-04-20 Thread Akka Team
bscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: letitc

Re: [akka-user] Question: Regarding reactive streams and threads / dispatcher

2016-04-20 Thread Akka Team
://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 unsu

Re: [akka-user] Handling timeouts when consuming http services via pooled connections

2016-05-10 Thread Akka Team
om. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: letitcrash.com Twitter: @akkateam

Re: [akka-user] `No elements passed in the last 1 minute` error in Http().superPool

2016-05-10 Thread Akka Team
roup. > 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 https://groups.google.com/group/akka-user. > For more optio

<    2   3   4   5   6   7   8   9   10   >