Re: [akka-user] Re: Akka dispatchers are not reused instead new dispatchers are created overtime

Wow, you have 500 CPU cores on your machine? -- Cheers, √ On Feb 16, 2016 5:01 PM, "Hareesh Jagannathan" wrote: > Thanks for responding quickly. Attaching a screeshot form visual Vm. As > you can see there are more than 700 dispatcher for one my system. > > My design is as

Re: [akka-user] Re: Akka dispatchers are not reused instead new dispatchers are created overtime

If you don't do any blocking then your max should be the number of cores you have and the factor about 0.6-0.7 -- Cheers, √ On Feb 16, 2016 5:17 PM, "Hareesh Jagannathan" wrote: > See thats my problem. All i have is 8core CPU (3 nodes) so basically 24 > cores. > > I

Re: [akka-user] Re: Akka dispatchers are not reused instead new dispatchers are created overtime

No, I'd use a dedicated dispatcher for the routees which do IO, use ThreadPoolExecutor. -- Cheers, √ On Feb 16, 2016 5:24 PM, "Hareesh Jagannathan" wrote: > > I do have blocking file-io in one of the router of the pipeline. > > Should i used Pinned dispatcher for those and

Re: [akka-user] Message ordering for newly instantiated actors

Hi James, 1) Message sends are not guaranteed to be delivered (i.e. at-most-once) 2) B could die/exit before it gets the message from C 3) C could die/exit before it gets the message from A That aside, if those things do not happen, it should be fine. On Tue, Feb 16, 2016 at 9:27 PM, James P

Re: [akka-user] [akka-stream] Difference between Source[Future[T]] .mapAsync(n)(f => f) and .flatMapConcat(f => Source.fromFuture(f))?

If I were you, I'd use parallelism 1, and if that ever became a problem, I'd revisit that choice. Focus on the business value and tune when you have something which works :) On Wed, Feb 17, 2016 at 11:49 AM, Alexey Shuksto wrote: > Hello there, > > I have `Source[Future[T]]`

Re: [akka-user] [ANNOUNCE] Akka 2.4.2 including Streams and HTTP Released!

Or even better, anyone could do that :) On Thu, Feb 18, 2016 at 10:46 AM, Endre Varga wrote: > We can make it public again once it has been properly tested, documented > etc. Until then, I think the workaround is to just copy the source and > include it directly in

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

Depends on what kind of semantics you're looking for: immediate pause, controlled rate of inputs, or other? On Mon, Feb 22, 2016 at 8:56 AM, Tal Pressman wrote: > I don't know of any way to do it out of the box, but you can create your > own custom GraphStage that handles the

Re: [akka-user] zipWithIndex

There's also: someSource.zip(Source.fromIterator(() => Iterator.from(0))) On Thu, Mar 10, 2016 at 3:42 PM, Akka Team wrote: > Hi Richard, > > I would say in general being able to achieve what you want by composition > rather than a multitude of special stages is what we

Re: [akka-user] Re: Http Client with Source.tick

Cool, happy hAkking! -- Cheers, √ On Mar 11, 2016 12:11 AM, "Arun Sethia" wrote: > Super ... you guys are awesome ... more I am learning, it is becoming more > and more interesting. > > I used recover, It worked well. Thanks a lot. > > > On Thursday, March 10, 2016 at

Re: [akka-user] Re: Http Client with Source.tick

http://doc.akka.io/api/akka/2.4.2/?_ga=1.176202021.1085570125.1455222020#akka.stream.scaladsl.FlowOps -- Cheers, √ On Mar 10, 2016 11:43 PM, "Arun Sethia" wrote: > Thanks. > > please can you provide the link where I can see how to deal with such > errors. > > On

Re: [akka-user] Re: Http Client with Source.tick

For each only deals with elements, not errors. Please consult the documentation for combinators that let you observe and manipulate errors. -- Cheers, √ On Mar 10, 2016 11:04 PM, "Arun Sethia" wrote: > httpSourceGraph1 is httpSourceGraph , but still same issue > > > val

Re: [akka-user] Akka HTTP bind exception on Windows

if (isWindows) selector.select(1) // :( On Thu, Apr 7, 2016 at 2:57 PM, Endre Varga wrote: > Oh, you are our savior! I am 99% sure that that is the solution we are > looking after, thanks! > > -Endre > > On Thu, Apr 7, 2016 at 2:35 PM, Antti Nevala

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

https://github.com/akka/akka/issues/20256 On Thu, Apr 7, 2016 at 5:18 PM, Patrik Nordwall <patrik.nordw...@gmail.com> wrote: > I agree, we have had that conclusion several times, but never fixed it. An > issue is a good start, please. > > tors 7 apr. 2016 kl. 16:20 skrev Vikto

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

Hmmm, since that mechanism is completely internal, perhaps we could solve that discretely and remove that run-all-on-shutdown. On Thu, Apr 7, 2016 at 4:17 PM, Patrik Nordwall <patrik.nordw...@gmail.com> wrote: > > > On Thu, Apr 7, 2016 at 12:46 PM, Viktor Klang <viktor.kl...@

Re: [akka-user] How do you determine/set the version of Akka used by the Scala REPL?

fig.path")", but that returned > "null" (?). > > Mark > > On Wed, Apr 6, 2016 at 3:00 AM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> ActorSystem.Version >> >> On Wed, Apr 6, 2016 at 6:04 AM, Mark Bower <markrbo...@gmail.com> wrote: &g

Re: [akka-user] Diffing streams

posing the two futures. > > On Tue, Apr 12, 2016 at 12:03 AM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> What does keep going mean? >> >> On Mon, Apr 11, 2016 at 11:42 PM, Richard Rodseth <rrods...@gmail.com> >> wrote: >> >>

Re: [akka-user] Akka HTTP bind exception on Windows

And to clarify, by "we", anyone reading this or the Issue is eligible for fixing it :) On Fri, Apr 8, 2016 at 10:11 AM, Endre Varga wrote: > Hi Michael, > > No, Akka HTTP uses Akka's own TCP stack, we don't use Netty there. I guess > we should just fix this in the

Re: [akka-user] Best practice for consuming a Http response entity's data stream

On Fri, Apr 8, 2016 at 1:06 PM, Chris Baxter wrote: > If I want to consume a Http service and then do something with the > response body, there are a couple of ways to go about doing that. The two > ones that I am trying to decide between are: > > val f:Future[ByteString]

Re: [akka-user] Diffing streams

What does keep going mean? On Mon, Apr 11, 2016 at 11:42 PM, Richard Rodseth wrote: > I need to compare two streams of timeseries data. I thought of doing > something with zip() but in the case where the data is missing in one > stream at the beginning or end, I'd like to

Re: [akka-user] local and remote actors configuration with groups advice/help needed

Deployment paths are absolute and your instances do not live directly below your root. (As witnessed by $a in your path) -- Cheers, √ On Apr 10, 2016 21:16, "Federico Jakimowicz" wrote: > Hi! > > I'm having a very hard time with akka configuration, I have read quite a >

Re: [akka-user] local and remote actors configuration with groups advice/help needed

I'm sorry for not being more clear in my response. I mean that when you say: /recommendations in the config, you're saying that the actor named "recommendations" is a child of the user root actor, i.e. once created using actorsystem.actorOf But in your code, it is created within another

Re: [akka-user] How do you determine/set the version of Akka used by the Scala REPL?

ActorSystem.Version On Wed, Apr 6, 2016 at 6:04 AM, Mark Bower wrote: > I am running MacOSX10.8, Java1.8, Scala 2.11 and would like to run Akka > 2.4 in the Scala REPL, but I cannot find out how to specific where the > Scala REPL gets its Akka implementation. I can run

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

Or rather, if scheduled events are not cancelled hen they are no longer needed, it will be a memory leak. Memory leaks are bad no matter if you shut the actor system down or not :) But to answer the question: shutting down the ActorSystem shuts down the Scheduler. On Thu, Apr 7, 2016 at 12:11

Re: [akka-user] Cancel a Scheduler by terminating its ActorSystem

> > /Patrik > > tors 7 apr. 2016 kl. 12:14 skrev Viktor Klang <viktor.kl...@gmail.com>: > >> Or rather, if scheduled events are not cancelled hen they are no longer >> needed, it will be a memory leak. Memory leaks are bad no matter if you >> shut the actor sys

Re: [akka-user] Detecting empty source

…and, an empty source is one which signals onComplete before any data has passed through. :) On Tue, Mar 22, 2016 at 10:58 AM, Akka Team wrote: > Hi Richard, > > There is no other way to detect whether a Source is empty than to run it. > For example if a Source wraps a

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

You're in luck today—I happen to be a Klang! What you found is no longer valid and applied to the original Akka Futures. Thanks for finding this ancient documentation remnant, if you ever see me at a conference, please let me know and I'll thank you in person. :) On Thu, Mar 24, 2016 at 3:28

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

"The only thing worse than not saying anything, is telling a lie." (i.e. I don't think that's a solution) On Mon, Mar 21, 2016 at 7:22 PM, Endre Varga wrote: > The issue is that there might be 3rd party RS stages, or stages from a > different materializer, so even

Re: [akka-user] postStop doesn't get invoked after actor initialization failure

Philosophically, how can something be stopped which failed to start? -- Cheers, √ On Mar 27, 2016 6:12 PM, "Stanislav Savulchik" wrote: > Hi, everyone! > > I've discovered that Actor's postStop method doesn't get invoked if > exception occurs during actor initialization

Re: [akka-user] Apparent thread leak with non-default akka dispatcher

Great story, Jesse. Thanks for sharing! On Wed, Mar 23, 2016 at 3:12 PM, Jesse C wrote: > Here is what we've figured out. We've got a native library that contains a > thread local member that includes a ZMQ socket. That socket is apparently > not being correctly

Re: [akka-user] Re: How to? - Sink.foldM[U, T](zero: U)(f: (U, T) ⇒ Future[U]): Sink[T, Future[U]]

thub.com/akka/akka/issues/18603 > > Thanks in advance if someone steps up to contribute! > > On Tue, Mar 8, 2016 at 12:12 PM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> I'd like to repeat that a scanAsync and a foldAsync would be very welcome >> addi

Re: [akka-user] Re: How to? - Sink.foldM[U, T](zero: U)(f: (U, T) ⇒ Future[U]): Sink[T, Future[U]]

I'd like to repeat that a scanAsync and a foldAsync would be very welcome additions :) On Tue, Mar 8, 2016 at 12:01 AM, Andrew Gaydenko wrote: > Giovanni, hi! > > Thanks! - have played with this test. In fact, I started tests with > -Xmx=128M, and range up to 20M. The

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

Could be related to: https://github.com/akka/akka/issues/19216 On Fri, Mar 4, 2016 at 1:26 PM, Chris Baxter wrote: > I have noticed a strange issue after we upgraded to akka 2.4.2 that > appears sporadically but once it rears its ugly head it basically causes > the server to

Re: [akka-user] Issue with Smallest Mailbox router pool introduced in akka 2.4.2

I think: regression? On Fri, Mar 4, 2016 at 1:44 PM, Chris Baxter wrote: > Should I create a separate ticket for this? It appeared to me like the > issue with AbstractNodeQueue was fixed though. Am I reading this wrong? > > On Friday, March 4, 2016 at 7:38:47 AM UTC-5, √

Re: [akka-user] Error while creating router from config

Your configuration says that the router lives directly beneath /User/ bout in reality you're trying to put it under akka://ModellerSystem/user/localProcessor/$a/$b/$b/$a/$a/ On Fri, Mar 4, 2016 at 6:51 PM, Sergey Sopin wrote: > Hi, > > I am trying to create router from

Re: [akka-user] Re: Does each ActorMaterializer need its own ActorSystem?

I don't understand the question. And looking at the code I don't think it would compile. On Wed, Mar 2, 2016 at 10:15 AM, wrote: > system = ActorSystem.create(); > > new Array[]{"a","b"}.stream() > .forEach { > final Materializer m = >

Re: [akka-user] Source Repeat given interval

mapConcat(identity) -- Cheers, √ On Mar 7, 2016 10:26 PM, "Arun Sethia" wrote: > Hi, > > I have requirement where source should repeat infinite times after given > interval, for example: > > val input:List[Int]=List(1,2,3) > > > val flow=Flow[Int].map(x=> x * 2) > > >

Re: [akka-user] Re: Does each ActorMaterializer need its own ActorSystem?

ActorMaterializer needs ActorContext and a Materializer can be used for many materializations. -- Cheers, √ On Mar 2, 2016 10:22, wrote: > sorry I hitted the send button too early. its just meant as pesudo code. > I was wondering if each > > ActorMaterializer needs its

Re: [akka-user] any plans to integrate ignite as a data grid with Akka ?

Hi Mahmoud, what would the benefits be? On Thu, Mar 31, 2016 at 4:32 PM, mahmoud romeh wrote: > Hi All , > > is there any plan to have to integration between apache and akka or maybe > using the cluster manager of Ignite to be the cluster manager of AKKA ? or > cache

Re: [akka-user] akka 2.4.2 [java] stopping http-server and flow handling IncomingConnection

When you say "cancel" do you mean "abrupt termination" or something with a code path attached to it? On Thu, Mar 31, 2016 at 11:53 PM, paweł kamiński wrote: > dont take it personally, there is a lot to process and sometimes it is > easy to overlook the most important part, I

Re: [akka-user] Akka on Android: akka.actor.ActorInitializationException

Hi Luca, check the stack trace of the ActorInitializationException On Fri, Apr 1, 2016 at 10:02 AM, Luca Lovagnini wrote: > Hello Akka community! > > I'm trying to porting Apache Flink (which > relays on Akka) to Android, but don't worry: you

Re: [akka-user] akka 2.4.2 [java] stopping http-server and flow handling IncomingConnection

Call 'shutdown' on the ActorSystem? Or only the Materializer? On Fri, Apr 1, 2016 at 11:29 AM, paweł kamiński wrote: > I want to clean state of the app, so I could > > 1) terminate akka-system which would also terminate http-server and start > it all over again. > OR > 2) I

Re: [akka-user] Supervising Remote Actors

http://doc.akka.io/docs/akka/2.4.2/scala/remoting.html#Creating_Actors_Remotely On Fri, Apr 1, 2016 at 12:05 PM, Jayesh Jadhav wrote: > Hi, > > Is it possible to supervise remote actors? Since faults should be > contained, asynchronously signaled and managed, will an

Re: [akka-user] [reactive-kafka 0.9.0.1] Why is my use of reactive-kafka so slow on commit?

Hi Greg, I don't know why the performance is low in your example, but there are several problematic aspects of how you're measuring. For any benchmark on the JVM, plaese use JMH (for sbt projects, see sbt-jmh )

Re: [akka-user] akka://ClusterSystem/deadLetters

? -- Cheers, √ On Mar 28, 2016 6:49 PM, "Sudha Vuppalapati" wrote: > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/deadLetters] Message > [akka.cluster.InternalClusterAction$InitJoin$] from >

Re: [akka-user] postStop doesn't get invoked after actor initialization failure

PostStop would never be called if the constructor fails. Which could be said to be similar to preStart? -- Cheers, √ On Mar 31, 2016 2:39 PM, "Endre Varga" wrote: > > > On Thu, Mar 31, 2016 at 2:36 PM, Guido Medina wrote: > >> it gets worse if I

Re: [akka-user] Diffing streams

ed, Apr 13, 2016 at 12:39 AM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> If your publisher is data-aware then it can insert dummies/fillers for >> missing data just fine? >> >> On Tue, Apr 12, 2016 at 7:53 PM, Richard Rodseth <rrods...@gmail.com> >

Re: [akka-user] Source~>Broadcast~>WebSocket endpoint

Val src = someSource.map(processJSON).alsoTo(somewhereWhichWorksFine) -- Cheers, √ On Apr 22, 2016 9:14 AM, "clca" wrote: > I'm struggling to figure out how to build a stream that does the following: > > Source ~> process (ex. XML2Json) ~> Broadcast[String](2) then out(0)

Re: [akka-user] Re: migrating from an earlier version of akka-streams ..

What are you expecting to be returned? -- Cheers, √ On Apr 26, 2016 3:49 PM, "Debasish Ghosh" wrote: > Thanks Konrad for the pointer .. when I run the graph I get a NotUsed .. > That's not hwat I get with the earlier implementation. Please have a look > at the gist ..

Re: [akka-user] Re: Akka remote thread pools tuning.

On Wed, Apr 27, 2016 at 2:59 PM, Guido Medina wrote: > I understand that's the only way to fine tune a system, but you usually do > that after you have found an starting point. > The default configuration is that starting point :) > I gave you an assumption but my

Re: [akka-user] Re: Akka remote thread pools tuning.

What does your measurements show? On Wed, Apr 27, 2016 at 2:32 PM, Guido Medina wrote: > Should remote dispatcher ideally have the sum of client + server threads > or min (CPUs, client + server threads) ? > > -- > >> Read the docs: http://akka.io/docs/ > >>

Re: [akka-user] Re: Akka remote thread pools tuning.

Hi Guido, In my experience the only way to tune a system is to measure, change, measure again. Until you have measured you're just making random changes which may or may not be beneficial. More importantly: What are your goals, and how do you know that they are met? On Wed, Apr 27, 2016 at 2:44

Re: [akka-user] migrating from an earlier version of akka-streams ..

of > groupBy as we learnt from SQL. We cannot access the substreams as separate > abstractions that groupBy creates. > > On Tue, Apr 26, 2016 at 11:28 PM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> Debasish, >> >> The problem with groupBy was that it

Re: [akka-user] migrating from an earlier version of akka-streams ..

Debasish, The problem with groupBy was that it was too easy to create leaks and silently broken solutions with it, but I sympathize with your situation, I also felt the original as being more ergonomic. I think there is room for improvement in the current solution. -- Cheers, √ On Apr 26, 2016

Re: [akka-user] Re: migrating from an earlier version of akka-streams ..

Sorry if I'm being daft, but shouldn't it be doing: transactions.groupBy(maxSubstreams = 100, _.accountNo).toMat(txnSink, Keep.right) On Tue, Apr 26, 2016 at 6:05 PM, Debasish Ghosh wrote: > Roland - > > I need to merge into a fold sink w/ a Monoid. Consider the

Re: [akka-user] migrating from an earlier version of akka-streams ..

>> >>> Thanks Viktor .. my main issue is that we lose the natural semantics of >>> groupBy as we learnt from SQL. We cannot access the substreams as separate >>> abstractions that groupBy creates. >>> >>> On Tue, Apr 26, 2016 at 11:28 PM, Viktor Kl

Re: [akka-user] How to add headers in Akka-HTTP client Http() call

Hi Rahul, http://doc.akka.io/api/akka/2.4.6/?_ga=1.210392661.1579561034.1353497989#akka.http.scaladsl.model.HttpRequest request.addHeader(…) On Sat, May 21, 2016 at 7:48 PM, Rahul Kumar wrote: > Hi, > > I have a small doubt, how i can pass headers in Akka-HTTP client

Re: [akka-user] Source.queue vs Source.actorRef vs custom GraphStage

Isn't CLQ.size O(N)? -- Cheers, √ On May 9, 2016 7:38 AM, "Tim Harper" wrote: > I did some benchmarking to see how well `Source.actorRef` and > `Source.queue` performed. Also, I wanted to see how much better I could do > if I didn't need my Source to buffer (this stream

Re: [akka-user] Source.queue vs Source.actorRef vs custom GraphStage

we could use a counter. > > On May 9, 2016, at 01:29, Viktor Klang <viktor.kl...@gmail.com> wrote: > > Isn't CLQ.size O(N)? > > -- > Cheers, > √ > On May 9, 2016 7:38 AM, "Tim Harper" <timchar...@gmail.com> wrote: > >> I did some benchmarking to s

Re: [akka-user] Re: Akka Remoting Ports

Waiting to hear what? On Wed, May 11, 2016 at 4:34 AM, wrote: > Hi, > Still waiting to hear, could anybody please give me some hint > > Regards > > > > On Tuesday, May 10, 2016 at 6:29:03 PM UTC+5, enovo...@gmail.com wrote: >> >> Hi, >> I have two remote actor systems

Re: [akka-user] Implementing ACID style processing using Akka?

What will you do if the bank reverses the payment? On Thu, May 12, 2016 at 11:41 PM, kraythe wrote: > I have a system that is a traditional DB centric app for the most part. > However the data is loaded in a memcache for speed and ease of use. What I > would be interested in

Re: [akka-user] Implementing ACID style processing using Akka?

No, I mean if the bank reverses a payment which was previously accepted. -- Cheers, √ On May 13, 2016 3:25 PM, "kraythe" wrote: > Well currently the system is designed such that the remote transaction > failing rolls back the transaction. So in this one scenario, that is how

Re: [akka-user] Call a function on overflow

+1! -- Cheers, √ On May 4, 2016 7:28 PM, "Tim Harper" wrote: > I should mention... it came to my attention that Source.queue has been > added since I first learned Akka Streams, and that as of 2.4.3, the object > returned by Source.queue can be closed. > > Super happy

Re: [akka-user] [2.4.4] connection level http client Api misses requests

A DNS lookup + processing time could take 5 seconds. What happens when you test the code on known addresses with predictable response times? -- Cheers, √ On May 5, 2016 2:35 PM, "Edmondo Porcu" wrote: Hello, I have a trivial use case where I use the Http()

Re: [akka-user] Akka client behind nat issue

Hi Abud, On Fri, May 6, 2016 at 12:34 PM, wrote: > > Hi, > Thank you for quick reply. > My requirement is: > - Client from behind NAT initiates a connection, sends a message (using > ask pattern) and receives the reply, can we not achieve it using akka > remoting? > >

Re: [akka-user] Akka client behind nat issue

Hi Abud, Akka Remote is not a client-server protocol, it is a p2p protocol. If you want to use asymmetric communication (where nodes are not symmetrically reachable), use Akka IO. On Fri, May 6, 2016 at 9:57 AM, wrote: > > Hi, > I am working on a simple client server

Re: [akka-user] Akka dispatchers 80% cpu time spent in ForkJoinPool.scan() -> Unsafe.park()

Using Awaits a lot or just oversized the pool? -- Cheers, √ On Apr 15, 2016 7:33 PM, "dylan wilder" wrote: > As above. I'm using akka http and the service isn't scaling with the > number of simultaneous connections. I've also posted hear so I won't bother > writing up

Re: [akka-user] Access to LoggingAdapter

but I'd recommend against that solution since it wouldn't necessarily be portable across materializer impls. -- Cheers, √ On Jul 14, 2016 08:39, "Akka Team" wrote: > If you are writing a custom graph stage, you can access it inside the > GraphStageLogic from the

Re: [akka-user] akka-cluster split brain when enable auto-down and set a node random package loss rate 50%

What behavior are you looking to achieve? -- Cheers, √ On Jul 22, 2016 5:11 AM, "Yutao Shuai" wrote: > In a 5-node cluster, hypothesis the nodes is A,B,C,D,E. All nodes > monitor each other, enable auto-down, and we set the node-A random > package loss rate 50%, after

Re: [akka-user] How to create listener which is placed outside actor system?

why? -- Cheers, √ On Aug 10, 2016 9:35 AM, "Иван Осипов" wrote: > Hi! Question in the topic > I need something like that > > > ActorSystem system; > MessageA msg;//some impl > > system.registerOutsideCallback(msg, new Callback() { >public void invoke(MessageA

Re: [akka-user] How to create listener which is placed outside actor system?

I'm not sure I understand. Perhaps if you outline your requirements (i.e. how modules are required to interact etc) it will be easier for others to suggest possible solutions? On Wed, Aug 10, 2016 at 8:53 PM, Иван Осипов wrote: > Only one module of my application

Re: [akka-user] Configurable parallelism/elastic groupBy

A routing stage with consistent hashing and then a N-Way merge to insert into db? -- Cheers, √ On Jul 20, 2016 9:09 PM, "Richard Rodseth" wrote: > I'm sure I've asked this before in numerous ways, but it's still an issue > for me. > > I have an ETL stream that reads

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Ah, sorry, I should've looked more carefully. AFAICT you'll need to figure out what throttling means for a fan-in operation. (Because now you're adding an unbounded queue (the CLQ)) On Sun, Jul 10, 2016 at 4:31 PM, Jack Daniels wrote: > Hi! I use it in the example

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Considered Flow.throttle? On Fri, Jul 8, 2016 at 11:23 AM, Jack Daniels wrote: > up vote > down votefavorite > > > Hey guys! I continue learning

Re: [akka-user] Exception during Actor construction

Caused by: akka.ConfigurationException: ActorSystem [akka://MQReceiver] needs to have a 'ClusterActorRefProvider' enabled in the configuration, currently uses [akka.actor.LocalActorRefProvider] -- Cheers, √ On Jul 11, 2016 09:23, "Drisha Roy" wrote: > hi, > I am getting

Re: [akka-user] Akka-Stream: deploying graphs from a plain config file

Seems tractable to define a conventional format using the condig lib and interpret the config to generate the graph. Report back if you decide to do that! -- Cheers, √ On Jul 11, 2016 17:35, "Héctor Veiga" wrote: > Hi, > > I am trying to figure out if there is any way of

Re: [akka-user] Re: Akka Stream Getting Stuck (2.4.9-RC2)

Create a reproducer? -- Cheers, √ On Aug 6, 2016 1:18 AM, "tigerfoot" wrote: > I should add that when it fails it just locks the stream--nothing further > processed. No errors or other output is produced. > > On Friday, August 5, 2016 at 6:11:34 PM UTC-5, tigerfoot wrote:

Re: [akka-user] Re: Akka v2.3.14 with Java 7 - TLS configuration

https://github.com/typesafehub/ssl-config On Tue, Aug 9, 2016 at 10:33 AM, Guido Medina wrote: > To be honest and fair, TLS configuration is a messy "Java" subject, it has > nothing to do with Akka so I believe you should search for Java TLS > configuration instead, > I know

Re: [akka-user] LEAK: You are creating too many HashedWheelTimer instances

I would suspect that you may be creating new ActorSystem instances instead of reusing a single one. -- Cheers, √ On Jul 1, 2016 7:05 PM, "Yan Pei" wrote: > Hello All, > > I am using AKKA 2.4.4 and Cassandra 2.x. > Today I found there is an error from the thread of >

Re: [akka-user] Is it possible to increase the number of serialization threads?

I'm not sure I understand why write/readObject special methods would necessarily be faster? Most of the waste of Java Serialization is its envelopes and using class names etc. On Sat, Jul 2, 2016 at 1:14 AM, Eduardo Fernandes wrote: > Hi. > > I'm using Akka 2.3.13, Java

Re: [akka-user] Is it possible to increase the number of serialization threads?

optimized serialization code. > > Bests regards and thanks for your comment. > > > On Sat, Jul 2, 2016 at 9:27 PM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> I'm not sure I understand why write/readObject special methods would >> necessarily be faster

Re: [akka-user] Is it possible to increase the number of serialization threads?

nows about your functional logic. > > Regards > > On Sat, Jul 2, 2016 at 10:05 PM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> Hi Eduardo, >> >> Perhaps I misunderstood, what serialization format are you emitting in >> your readObject/writeObject

Re: [akka-user] Is Akka Persistence production ready.

Are you running multiple instances of Akka Persistence on the same machine? On Tue, Jun 28, 2016 at 2:27 PM, Vishal Singh wrote: > No not shared. > > On Tuesday, June 28, 2016 at 4:44:06 PM UTC+5:30, √ wrote: >> >> LevelDB is not for production usage FWIW. Are you using

Re: [akka-user] How do we handel OversizedPayloadException in Akka

Hi Prakash, Do you use Java Serialization? On Tue, Aug 16, 2016 at 12:21 PM, prakash chinnaswamy < prakash.chinnaswamy...@gmail.com> wrote: > We have a distributed application on akka cluster. Actor “A” sends message > of large size to a remote actor. And we get the following Warning. > > >

Re: [akka-user] Class cast exceptions in actors that return Future[Unit]

On Wed, Feb 1, 2017 at 2:55 AM, Alan Burlison wrote: > Ahah! I think you may of nailed it... Thanks! >> > > Indeed you did nail it - "thanks" doesn't come close as I'd looked at this > for so long that I'd gone completely snow-blind ;-) > You're welcome. A reminder that

Re: [akka-user] Class cast exceptions in actors that return Future[Unit]

On Wed, Feb 1, 2017 at 10:51 AM, Alan Burlison <alan.burli...@gmail.com> wrote: > On 01/02/17 09:06, Viktor Klang wrote: > > You're welcome. A reminder that the actual error messages are very >> important to include. :) >> > > Yes, I consider my wrist to b

Re: [akka-user] Persistent Graph Stage

Would it be more flexible with a `persistentBuffer` stage? On Mon, Feb 6, 2017 at 4:54 PM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > Would you be up to implementing it? Otherwise I don't think there will be > much happening around this. > It could start out in

Re: [akka-user] [Akka stream] Sink/source materialization

You mean like: Source.single(()).flatMapConcat(_ => yourFunction())? -- Cheers, √ On Feb 8, 2017 03:33, "hbf" wrote: > Heya everybody! > > I know that Akka Stream elegantly distinguishes *describing* a graph from > *materializing* a graph. > > When working on custom Akka Stream

Re: [akka-user] Class cast exceptions in actors that return Future[Unit]

or > for example sends a Future[Unit] back, then you will have a > Future[Future[Unit]] returned from ask. > > -- > Johan > Akka Team > > On Tue, Jan 31, 2017 at 2:41 PM, Alan Burlison <alan.burli...@gmail.com> > wrote: > >> On 31/01/2017 21:36, Viktor

Re: [akka-user] Class cast exceptions in actors that return Future[Unit]

I think the problem is that your responding with a scala.util.Success rather than a akka.actor.Status.Success. On Wed, Feb 1, 2017 at 12:20 AM, Alan Burlison <alan.burli...@gmail.com> wrote: > On 31/01/17 22:18, Viktor Klang wrote: > > The answer will be in the stack traces. &g

Re: [akka-user] newbie question about await inside actors code

017 12:12, Viktor Klang wrote: > > http://doc.akka.io/docs/akka/2.4/scala/actors.html#Stash >> > > Ahah! I'd seen stash in the docs and not really come up with an case > (other than become/become) where it would be useful, and then forgotten > about it. I'm still not clear h

Re: [akka-user] newbie question about await inside actors code

http://doc.akka.io/docs/akka/2.4/scala/actors.html#Stash On Tue, Feb 21, 2017 at 1:09 PM, Alan Burlison <alan.burli...@gmail.com> wrote: > On 20/02/2017 12:01, Viktor Klang wrote: > > No. I'd recommend to use stashing, makes the cost explicit. >> > > Could

Re: [akka-user] newbie question about await inside actors code

No. I'd recommend to use stashing, makes the cost explicit. -- Cheers, √ On Feb 20, 2017 12:56 PM, "Alan Burlison" wrote: > > This is not a solution because it creates one new thread for every > blocker. > > In general I agree, but if the code has already aggregated

Re: [akka-user] Akka Streams - Retry failed RPC call.

Hi Sean! There is a mistake and a misunderstanding in your code: object Test extends App { implicit val system = ActorSystem() implicit val mat = ActorMaterializer() val x: Future[Done] = Source(List("one", "two", "three")).map { value => val data = makeRPCcall(value)

Re: [akka-user] Akka Streams - Retry failed RPC call.

def downloadS3ObjectFlow(s3Client: S3Client, bucket: String): Flow[String, ByteString, NotUsed] = { Flow[String].flatMapConcat { key => log.debug(s"Downloading $key") val data: Source[ByteString, NotUsed] = s3Client.download(bucket, key) data.recoverWithRetries(3, {

Re: [akka-user] What is the difference between using broadcasts and manually connecting shapes

What does the test output show? On Fri, Feb 10, 2017 at 5:30 AM, faiz halde wrote: > I wanted to know if there is any difference between the following two > scenarios > > val g = RunnableGraph.fromGraph(GraphDSL.create() { implicit builder: > GraphDSL.Builder[NotUsed] =>

Re: [akka-user] How do we handel OversizedPayloadException in Akka

get this error. We would like to handle this error and send a warning > message to the client. > > On Tue, Aug 16, 2016 at 5:00 PM, Viktor Klang <viktor.kl...@gmail.com> > wrote: > >> Hi Prakash, >> >> Do you use Java Serialization? >> >> On

Re: [akka-user] Strange actor behavior with Akka Spring Integration

On Aug 20, 2016 9:22 AM, "Roland Kuhn" wrote: > > Hi Mark, > > before we can move on, there is one important thing to do: as far as I can see you are describing a broken solution, not the real problem. Please let us take a step back to find a real solution. > > Interjection

Re: [akka-user] Re: Detail: akka.stream.StreamTcpException: Connection failed.

Are you consuming your response bodies? -- Cheers, √ On Feb 27, 2017 12:27 PM, "Chaitanya Mahipath" wrote: > Hi Johannes, > > I tried with Http.SingleRequest as suggested but could see the following > exception > > akka.stream.BufferOverflowException: Exceeded

Re: [akka-user] akka serialization - message boundary

Akka encloses the binary data in an envelope to track message size. It is recommended to send small messages for the same reason it is recommended to to send huge packets through normal post boxes. :-) -- Cheers, √ On Sep 6, 2016 08:00, "Wei" wrote: > Hello, > > I am trying

Re: [akka-user] akka serialization - message boundary

e context of persistence, but > many of the patterns are the same for remoting: > http://doc.akka.io/docs/akka/snapshot/scala/persistence- > schema-evolution.html > > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > &g

<    1   2   3   4   5   6   >