Re: [akka-user][deprecated] How to test ReceiveTimeout in Akka typed

Hi Urs, you can use isAlive to check whether the behavior in the BehaviorTestKit has terminated or not. You’ll have to manually feed the actor the "terminated" message (making the test

Re: [akka-user] Akka stream out of band data

Sent from my iPhone > On 18. Feb 2018, at 11:53, Christopher Hunt wrote: > > > >> On 18 Feb 2018, at 21:10, Viktor Klang wrote: >> >> How do you deal with M:N ports or X:Y element permutations? > > No idea. :-) My main question is, has there been any thinking around > associating metadat

Re: [akka-user] Akka, Akka Typed and dead code elimination

Sent from my iPhone > On 3. Feb 2018, at 07:25, Christopher Hunt wrote: > > Hi Roland, > >> On 3 Feb 2018, at 5:16 pm, Roland Kuhn wrote: >> >> could you elaborate on how exactly Akka Typed is expected to help with your >> use-case? The only diffe

Re: [akka-user] Akka, Akka Typed and dead code elimination

Hi Christopher, could you elaborate on how exactly Akka Typed is expected to help with your use-case? The only difference I can see is that the new (and currently removed) implementation contained fewer extension points, but that is unrelated to whether ActorRef has a type parameter or not. Re

Re: [akka-user] Akka typed ask and Scheduler

That would make it impossible to create an ActorRef without a system, which currently should work. Sent from my iPhone > On 31. Dec 2017, at 17:03, Patrik Nordwall wrote: > > Hi Tal, > > I think it would be possible to grab the scheduler from internal impl, also > for Typed. Please create an

Re: [akka-user] Distributing lots of large messages to a cluster on startup issue.

Yes, I meant an Akka HTTP server for this purpose: spin it up on the node where the map is created, can even be on a random port, and send the URL to this server around. That server can offer the last ten versions (or whatever), could use the hash of the preserialized map as identifier. That way

Re: [akka-user] Distributing lots of large messages to a cluster on startup issue.

May I suggest serving the large blobs via a different mechanisms like HTTP? Sending around URL (and putting them inside events) seems much better than putting the data bytes all over the place. Regards, Roland > 30 nov. 2017 kl. 16:11 skrev Patrik Nordwall : > > Sending 10 MB messages is inde

Re: [akka-user] Android client connecting to Akka cluster via sockets

Hi Tom, the core feature of Akka Cluster is location transparency: all Actors within the cluster can seamlessly communicate via their ActorRefs. Including something that is not really part of the cluster, or that can at least not fully participate in the location transparent setting, will likel

Re: [akka-user] Spray->Akka-Http Migration - seeing high 99th percentile latencies post-migration

You could try to decrease your thread pool size to 1 to exclude wakeup latencies when things (like CPU cores) have gone to sleep. Regards, Roland Sent from my iPhone > On 23. Oct 2017, at 22:49, Gary Malouf wrote: > > Yes, it gets parsed using entity(as[]) with spray-json support. Under a l

Re: [akka-user] Re: Understanding tuning akka dispatchers (by Jami allan)

ets the message. >>>> >>>> BUT I'm not sure this isn't a premature optimization. Since there's a >>>> possibility of a router in the mix, that means the child is sending a >>>> response to a message it received. In that

Re: [akka-user] Auto downing and Akka Cluster

Another way of putting this is that given enough time any cluster of size N with auto-down will eventually end up as N single-node clusters. It is thus not a sustainable strategy unless you invest the manpower to constantly manually rebuild the cluster. Regards, Roland Sent from my iPhone >

Re: [akka-user] My initial impressions of akka.typed design.

Hi Sean, removing the self-type would not help: its function is only to ensure that every ActorRef also has an appropriate implementation, basically proving that the down-cast that is used in many places in the implementation will work out fine. In the end every ActorRef needs to support the se

Re: [akka-user] [Akka-typed] How to test message protocol between two typed actors?

Since it is Actor-2 that is violating its contract, why don’t you write a test that inspects the response of Actor-2 to a Restart message? Sending to `self` is tracked by EffectfulActorContext and Actor-1’s role would be stubbed by an Inbox that you can inspect as well. The post condition should

Re: [akka-user] My initial impressions of akka.typed design.

Hi Sean, thanks for discussing Akka Typed! The design decision behind splitting the interface into a public and a private part is documented in the ScalaDoc for ActorRefImpl: end users shall not ever see the top two methods because there cannot possibly be a reason to use them—but the implemen

Re: [akka-user] Re: Akka HTTP usage of HttpEntity.toStrict

Hi Yannik, if your logging facility were capable of streaming then you could also avoid the double materialization issue using the .alsoTo combinator: you send the bytes to the logger while processing them in your business logic. This is also beneficial if the logger compacts the data, reducing

Re: [akka-user] Akka Typed API discussion

There already is ExtensibleBehavior, does that not provide you with all the access and tools you need? > 18 juli 2017 kl. 13:53 skrev Bryan Murphy : > > I mostly agree with you and the NamedStateBehavior may only be useful when > you have well defined state transitions (low change frequency) or

Re: [akka-user] Akka Typed API discussion

Hi Bryan, thanks for articulating your points! Regarding the first one I’d like to widen the scope of the discussion: is it useful to access the private state of a state machine for testing purposes? I know that I am guilty of creating the akka-testkit nearly seven years ago, allowing precisely

Re: [akka-user] Strange java.lang.VerifyError with ActorSystem initialization

Just a thought: are you using the Scala distribution’s runner to run the application? There were versions that added an old version of Akka to the bootclasspath. Regards, Roland > 20 juni 2017 kl. 14:28 skrev Matlik : > > I find it strange that it would be Akka, but this does appear to only i

Re: [akka-user] Resuming on error from flatMapMerge

Hi Stephen, wasn’t your requirement to drop the whole sub-list when a failure occurs during its processing? That is not achieved with this design: you’ll have to buffer all events and only release the buffer when the substream completes successfully. Something like .fold(Vector.empty[Int])(_

Re: [akka-user] Issues with reference.conf in libraries not getting referenced after pulling library out of main project and into Nexus

Another way to put this: yeah, you can do this, but you’ll have to use a suitable ClassLoader implementation that you control :-) > 31 maj 2017 kl. 09:17 skrev Richard Ney : > > Kinda suspected that would be your answer 😎 > > Sent from my iPhone > > On May 30, 2017, at 11:22 PM, Patrik Nordwal

Re: [akka-user] Resuming on error from flatMapMerge

The details here are probably too subtle to be useful as a system design tool: there are two kinds of failure handling at play in this example—a caught exception and propagation of teardown—and only one of them is reasonably controlled by the supervisionStrategy. I would recommend using `.recove

Re: [akka-user] akka-http client: How to ensure response entity is read

Hi Daniel & Arno, consuming response entities needs to be done so that the connection becomes reusable afterwards, i.e. to free up the resource. In this sense, does it really matter how long that takes? If the connection goes idle for too long, it will be closed anyway, so attaching a `Sink.ig

Re: [akka-user] New Documentation

Hi Mike, it took a bit until your proposal registered properly (I blame the sun): I agree that it would be nice to have a link to the API on every page of the reference docs, I’ve seen that elsewhere and it makes sense. It would be even nicer to have everything in the code samples linked to its

Re: [akka-user] Role of Akka in SMACK

Whoever this is: would you please abstain from such anonymous unsubstantiated claims? I cannot comment on the truthfulness of your critique, common courtesy would entail that I know at least your name to ask for supporting evidence. Regards, Roland Sent from my iPhone > On 3. May 2017, at 06:

Re: [akka-user] Uncaught error from thread shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem

Well, the screenshot shows the error quite clearly: the native library for leveldb is not found. Regards, Roland > 25 apr. 2017 kl. 08:27 skrev Sachin S V : > > I am running an assembly jar file in command prompt and getting the > exception below. And resulting in termination. > > Uncaught

Re: [akka-user] Re: Has akka-http has abandoned per request actors in favor an anti-pattern DSL?

Hi Robert, since a Route is just a function from request to future of response you can easily achieve all that you describe, delegating as much or as little as you wish to actors via the ask pattern (delegating via a parent actor whose ref is known to the route). Commonly extracted metadata are

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

> 20 feb. 2017 kl. 12:51 skrev Alan Burlison : > > On 20 February 2017 at 07:24, Roland Kuhn wrote: > >> There are two solutions: the pipeTo pattern, or not using Futures at all and >> collecting the responses within a dedicated ephemeral actor. > > What about th

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

There might be some miscommunication here: as I understand it the OP is using Await.result on an aggregation future. To that the answer is: don’t do that! The JVM does not support suspending an active computation to free up the thread, so you’re right that doing this can lead to deadlock. There

Re: [akka-user] Order of processing vs Futures in actor

> 15 feb. 2017 kl. 22:18 skrev Igor Berman : > > Hello All > Wanted to get a bit of advice regarding following usecase: > I have local ActorSystem that handles messages with some key inside. Every > such message causes mutation of db state by the key: read old value by key, > compute new state

Re: [akka-user] Re: I'm a freshman to Akka, please recommend me some useful learning material... Thanks a lot.

While “terrible” is pretty strong wording I think it is fair to say that Akka has very good reference documentation but its initial learning experience can be improved. Would it help if some of the video courses were available (for free, of course) that were part of Principles of Reactive Progra

Re: [akka-user] Strange behavior with unzip when fusing is on

sm > (e.g., just before merge)? > > Thanks, > Anil > > On Wed, Dec 21, 2016 at 2:40 AM, Endre Varga <mailto:endre.va...@lightbend.com>> wrote: > Yes, that might be the case. > > On Wed, Dec 21, 2016 at 9:39 AM, Roland Kuhn <mailto:goo...@rkuhn.info>&

Re: [akka-user] Strange behavior with unzip when fusing is on

I think what is happening here is that zip does not pull until the delayed element has come out, meaning that the second (less delayed) element will not overtake it. mapAsync is effectively a buffer, so you'll need a buffer in front of zip.in0 as well to enable parallelism. Regards, Roland Se

Re: [akka-user] Actor creation memory consistency

The answer lies in UnstartedCell, but beware that this code may be morally challenging: it uses a Lock ;-) Regards, Roland Sent from my iPhone > On 21 Dec 2016, at 08:02, stella wrote: > > I'm trying to understand how actor creating is being performed internally. > So, once we created our A

Re: [akka-user] Re: Akka application.conf does not override values in reference.conf

Hi Kilic, the config you are passing to the ActorSystem is not the right one: the ActorSystem expects a config with an `akka` element at the root, so you should just pass the `config` to the system, not the `akkaConfig`. Regards, Roland > 15 dec. 2016 kl. 10:02 skrev Kilic Ali-Firat : > > An

Re: [akka-user] Aeron errors when network temporarily disconnected.

Are you on Windows? Windows is known to do very weird things to processes when the ethernet link goes down (such as terminating listeners). > 14 dec. 2016 kl. 01:44 skrev Allan Brighton : > > Using akka-2.4.11 on Ubuntu-16.04: If I pull the network plug for a few > seconds while an actor is run

Re: [akka-user] Akka http create pathPrefix from a list

> 12 dec. 2016 kl. 08:16 skrev A. Nigredo : > > Hi all, I've got a list of String e.g. List("public", "assets") and I wanna > create pathPrefix from the list. > > I try like: > List("public", "assets") match { > case x::xs if xs.isEmpty => pathPrefix(x) > case x::xs => pathPrefix(xs.foldRi

Re: [akka-user] Unit test for Persistent Actor Replay

Well, it is solved in Akka Typed: removing system.actorOf() and system.stop() is the only way to "solve" this. The reason is that the semantics of these methods are incompatible with the distributed nature of the ActorSystem. Regards, Roland Sent from my iPhone > On 2 Dec 2016, at 08:12, Vikt

Re: [akka-user] ANNOUNCE: Akka HTTP 10.0.0 – fully stable release!

Woohoo, congrats everyone! Sent from my iPhone > On 22 Nov 2016, at 17:23, Konrad 'ktoso' Malawski wrote: > > Dear hakkers, > > Today, we are proud and happy to announce the immediate availability of the > fully stable version of Akka HTTP – 10.0.0, charmingly code named “X” by > @jonas on g

Re: [akka-user] Non-monotonic incremental computation

Indeed, these are very interesting points, including persistence. What I would like to try out (we have started some experiments at Actyx) is to decouple the actual datatype and the management of its δ-state from Akka Cluster: the cluster should become a provider of node identity and data dissem

Re: [akka-user] Problems with Persistence when rolling nodes.

Hi Robert, I cannot comment on whether mysql-async has issues, but assuming that it does not this would point towards having two actors with the quoted persistenceId active at the same time. Regards, Roland > 18 nov. 2016 kl. 17:49 skrev kraythe : > > Greetings, I am currently using the comm

Re: [akka-user] Re: Exposing Akka actors through a REST API

ee" (and also could lead to people > exploiting this by passing weird things in `part`. > > -- > Konrad `ktoso` Malawski > Akka @ Lightbend > >> On 12 November 2016 at 12:47:28, Roland Kuhn (goo...@rkuhn.info) wrote: >> >> I'm not sure I agree with Ko

Re: [akka-user] Re: Exposing Akka actors through a REST API

I'm not sure I agree with Konrad here: what is wrong with using an HTTP route to expose an actor as service endpoint? This does not imply that the actual implementation needs to be structured accordingly, the backend is completely independent a priori. The role of the composable route snippet is

Re: [akka-user] Abstracting away CommitableMessage

Yes, indeed: if it is strictly 1:1 and it retains the order of the messages, then this works. Thanks for the sample! Regards, Roland > 26 okt. 2016 kl. 22:12 skrev Itamar Ravid : > > Broadcast/Zip if your existing flow is 1:1. Here's a sample: > https://github.com/iravid/stream-processing-tal

Re: [akka-user] Abstracting away CommitableMessage

Hi Richard, unfortunately this is not possible in general: you would need to define exactly how the extra data (i.e. the commit token) is transported together with the data it belongs to through all possible stages. The answer from category theory would be a functor, but how do you define one f

Re: [akka-user] Re: Akka http vs Spray performance

Hi Olga, establishing a connection is a very expensive operation, which is why all modern clients/browsers reuse them for multiple requests. The ab tool needs the -k switch to enable this behavior. Regards, Roland Sent from my iPhone > On 5 Oct 2016, at 01:32, Olga Gorun wrote: > > > I tr

Re: [akka-user] Ask or Tell ?

Yes, almost: it should be context.actorOf, not system.actorOf. Regards, Roland Sent from my iPhone > On 3 Oct 2016, at 15:15, gervais.b wrote: > > Yes, sorry, state is good but per actor, so that I should create one actor > instance each time I would like to combine the two CSV. > > So, gi

Re: [akka-user] Ask or Tell ?

> 3 okt. 2016 kl. 14:30 skrev gervais.b : > > Hello, > > I'm fairly new with Akka (and maybe the whole question below is polluted by > my synchronous background). In my app, I have to parse 2 CSV available as > HTTP, I plan to access them from one actor that accept two messages (one per > csv

Re: [akka-user] Control how much cpu are used by the actor system?

Hi Jean-François, the JVM does not offer the functionality you seek, you'll have to use your operating system’s capabilities to restrict the resources available to the JVM itself. Regards, Roland Sent from my iPhone > On 30 Sep 2016, at 18:29, Jean-François Côté > wrote: > > Hi guys! >

Re: [akka-user] how to enable secure tcp socket connection on server side in Akka

The library you’re looking for is Akka Streams, not bare Akka IO. Coming from Mina you might want to read http://doc.akka.io/docs/akka/2.4/java/stream/stream-composition.html about how protocol pipelines are expressed. Unfo

Re: [akka-user] [Akka Stream] Happens-before relation and runForEach

Technically I'm not sure this is correct: since f is only called from within a single operator (and assuming only a single materialization) the shown code should work just fine. Of course it is necessary to know what you're doing when coding like this, and as Konrad says there are better alterna

Re: [akka-user] [akka-streams] It is not possible to create Graph with the custom shapes

Hi Sergey, Just add your custom stage using builder.add() and then write the ports of the resulting Shape using the normal GraphDSL methods. There is no need to make the wiring aware of your special shape. Regards, Roland Sent from my iPhone > On 19 Sep 2016, at 22:35, Sergey Sopin wrote: >

Re: [akka-user] probe does not get Terminated message

Hi Aditya, Terminated is only sent upon termination, not for a restart: an ActorRef stays valid across a restart so it would be wrong to signal that it becomes invalid (which is what Terminated means). Regards, Roland > 16 sep. 2016 kl. 08:02 skrev Aditya Prasad : > > Howdy y'all, > > I'm u

Re: [akka-user] [Remote] run akka remotely with a specific ClassLoader

This seems more like a configuration problem: you could try to logConfiguration to check whether the right settings are applied on both ActorSystems (local & remote) and if that does not show anything suspicious then switch on the remote debugging options

Re: [akka-user] Sharing my attempt at contributing to Akka

Ah, nice, I was not keeping up it seems! If we control the whole thing then it should actually be possible to add the second kind of link as well (directly to the snippet’s source). Regards, Roland > 3 sep. 2016 kl. 08:30 skrev Patrik Nordwall : > > Hi Omer, > > Thanks for very valuable feed

Re: [akka-user] Sharing my attempt at contributing to Akka

Hi Omer, thanks for writing this up instead of just walking away! Most of what you describe is already there, apart from some links. One of those link would probably be simple to add, the other I’m not so sure about: You can edit files on github, which will create a fork behind the scenes from

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

rocesses much fewermessages, but each message processing >> takes time. Actor3 could be something in-between. So I may want to have >> large number of instances of Actor1 and may be less for Actor2, but for >> Actor2 I want to use pinned dispatcher. Can I achieve all this withou

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

> On Saturday, August 20, 2016 at 4:58:14 AM UTC-4, √ wrote: > > 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

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

10:39:50 PM UTC-4, Justin du coeur wrote: > On Fri, Aug 19, 2016 at 4:23 PM, Mark Kaberman > wrote: > The fact that actor names are generated by Akka is also a concern. According > to Roland Kuhn that should be avoided. > > Hmm? Where does Roland say that? There are lots

Re: [akka-user] Router path in Akka config

Why do you conflate the route structure (i.e. the routing hops) with the supervisor hierarchy? This is usually a bad idea. Instead, create your three actors as children of a supervisor that introduces them to one another—and only introduce Routers once you have benchmarked that a single actor is

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

Hi Prakash, “handling exceptions” is not the most useful way to think about distributed systems—most of the exceptions are thrown outside of your call stack and therefore not visible at all. Failures must be communicated explicitly as messages instead. One core aspect here is that Akka is distr

Re: [akka-user] Akka Spring integration seems to slowly leak memory

I'll try to rephrase: 1) I think your problem is that you create one system per call and never shut it down. Don't do that. 2) don't use routers, please. Sent from my iPhone > On 22 Jul 2016, at 19:04, Mark Kaberman wrote: > > 1. Creating an AkkaSystem per POST does not help since each syste

Re: [akka-user] Akka Spring integration seems to slowly leak memory

> 21 juli 2016 kl. 18:39 skrev Mark Kaberman : > > I was able to write a test app which reproduces the problem (attached). Based > on the application.conf I would expect 65 instances of the actors to be > created. When I start my actors (by executing POST request to > http://localhost:8080/star

Re: [akka-user] ANNOUNCE: New Remoting Milestone 3

Very impressive, congratulations! > 8 juli 2016 kl. 17:24 skrev Patrik Nordwall : > > Dear hakkers, > > We are pleased to announce the availability of the third development > milestone of the new Akka Remoting, codenamed Artery. It’s an early > development preview and we encourage you to try i

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

Doesn't the classical remoting perform serialization within the single actor responsible for each connection? Sent from my iPhone > On 03 Jul 2016, at 12:57, Viktor Klang wrote: > > Eduardo, are you sure that there aren't any synchronized-blocks or locks > used? (i.e. is this a contention pro

Re: [akka-user] Akka Spring integration seems to slowly leak memory

> 14 juni 2016 kl. 16:28 skrev Mark Kaberman : > > Hi Roland, > > As I wrote in my original post my application traverses the tree. The depth > of the three is small and the paths are known in advance, but the breath is > very large. So I have relatively small number of actors (and actorRouter

Re: [akka-user] Akka Spring integration seems to slowly leak memory

Hi Mark, it is not easy to help you due to insufficient information: How many different actorRouterName arguments can there be? Will the resulting number of actors fit into memory? Do you or do you not stop all created actors eventually? Stopping an actor requires a call to context().stop(self(

Re: [akka-user] Re: ANNOUNCE: New Remoting Milestone 2

Andrew, there seem to be a few misunderstandings here: HTTP by design requires TCP as its transport akka-http implements HTTP using akka-streams which in turn uses Akka IO for the TCP part—no Netty anywhere akka-remote has nothing to do with Akka IO, akka-stream, or akka-http Regards, Roland

Re: [akka-user] Dependent Processing with Millions of Records without Backlogging?

Yes, that sounds reasonable. Perhaps a kind of natural batching that accumulates changes as long as the previous sort is being executed? Sent from my iPhone > On 01 Jun 2016, at 22:43, kraythe wrote: > > Perhaps, though honestly the entire problem scope is in the post, just > generically expr

Re: [akka-user] Dependent Processing with Millions of Records without Backlogging?

It seems that your initial description is too vague for direct help—that sorting aspect is not really clear, at least to me. > 1 jun 2016 kl. 20:04 skrev kraythe : > > Pardon? I just said the users are observing the state and observing it change > in real time. > > On Wednesday, June 1, 2016 a

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

Yes, indeed, thanks a lot for writing that up! Sent from my iPhone > On 23 May 2016, at 06:47, Ryan Tanner wrote: > > Great post Matthew! > >> On Sunday, May 22, 2016 at 4:51:39 PM UTC-6, Matthew Howard wrote: >> ugh double-post... I left out the Pat Helland link >> https://www.youtube.com/wa

Re: [akka-user] AsyncWriteJournal - question about asyncWriteMessages

Sent from my iPhone > On 21 May 2016, at 23:05, Maciej Ciołek wrote: > > Hello, > I would like to ask about the docs in AsyncWriteJournal: > > asyncWriteMessages: > Calls to this method are serialized by the enclosing journal actor. If you > spawn work in asynchronous tasks it is alright tha

Re: [akka-user] ANNOUNCE: New Remoting Milestone 1

Very exciting indeed, can’t wait to play with it! > 20 maj 2016 kl. 19:03 skrev Filippo De Luca : > > Very good news indeed > > On 20 May 2016 at 18:02, Vitor Vieira > wrote: > That's awesome! Can't wait to see the final benchmarks! > > Cheers! > > Vitor Vieir

Re: [akka-user] ANNOUNCE: Akka 2.4.5 Released!

Great work, everyone! With special thanks to Jan :-) Sent from my iPhone > On 18 May 2016, at 02:14, Giovanni wrote: > > Great! > > giovanni > >> On Tue, May 17, 2016 at 6:01 PM, Johan Andrén >> wrote: >> Dear hakkers, >> >> we—the Akka committers—are proud to announce a new minor release

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

Hi Robert, I feel your pain, but unfortunately the pain is real as it results from a fundamental conflict: if the users expect the system to behave (strictly) serializable then the system cannot scale or be highly available because it is limited by the CAP theorem. Without giving up this expect

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

Hi Robert! > 13 maj 2016 kl. 19:37 skrev kraythe : > > Well we dont have to deal with that. Its so rare that its not in the > software. Security team would deal with that. This is exactly the point: what is the probability that the system crashes while performing a given transaction? Usually

Re: [akka-user] Akka Remoting Ports

Perhaps a more definitive answer: what you are asking for is not possible because that would require binding to the listen port also for the outgoing connections, but that is not legal (it results in a BindException saying “Address already in use”). This is why the source port of TCP connections

Re: [akka-user] onComplete missing when persisting messages from stream with akka persistence

Hi Magnus, Not all stages are capable of always knowing in advance (i.e. Without actually asking for more elements) that the stream is about to end. Having additional demand is necessary in general if you need the completion signal. You say this "breaks the protocol"—which protocol do you mean

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

he above snippet are the folds on individual > substreams done in parallel ? > > Thanks again for the help .. > Regards. > > >> On Wed, Apr 27, 2016 at 2:53 AM, Roland Kuhn wrote: >> >>> 26 apr 2016 kl. 20:14 skrev Debasish Ghosh : >>&

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

ation. It will be clunky .. I am already starting to feel the loss > of the 1.0 API, which I thought was very idiomatic from groupBy point of view. > > Let me see if I can at all get a solution for this .. > > regards. > > On Tue, Apr 26, 2016 at 10:33 PM, Roland Kuhn <m

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

> I do a group by accountNo, which gives me 3 substreams. Each substream needs > to go into a fold sink where I fold using a Monoid. The Monoid has the logic > of merging transactions belonging to the same accountNo. The logic that u > suggest will not do this. I need to access th

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

If you need the results from the substreams you’ll have to merge them back into the mainstream and aggregate them there: transactions.groupBy(100, ...).fold(...).mergeSubstreams.grouped(100).to(Sink.head) Regards, Roland > 26 apr 2016 kl. 17:36 skrev debasish : > > Viktor - > > Here's the s

Re: [akka-user] Future to CompletionStage

If you show a bit more context of what you are trying to achieve then we might be able to help you with that :-) Happy hakking, Roland > 15 apr 2016 kl. 13:05 skrev Federico Jakimowicz : > > Sure, well to be honest and I know this will not speak well about me... I got > a bit rusty so I need

Re: [akka-user] Future to CompletionStage

There’s a Java 8 ask implementation in PatternsCS that will give you a CompletionStage instead of a Future. May I ask why you prefer the vastly more verbose anonymous class syntax instead of a lambda? Regards, Roland > 15 apr 2016 kl. 03:06 skrev Federico Jakimowicz : > > Hi, > > I'm defini

Re: [akka-user] Akka streams: stage that combines consecutive elements

Well, you could also concat an EOF marker and use that to flush … > 12 apr 2016 kl. 11:33 skrev Endre Varga : > > No, for that you need to write a custom stage. > > -Endre > > On Tue, Apr 12, 2016 at 11:01 AM, Arno Haase > wrote: > Hi Endre, > > thanks

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

[forget the last paragraph, found the answer in the first post] > 5 apr 2016 kl. 18:00 skrev Roland Kuhn : > >> >> 5 apr 2016 kl. 17:50 skrev Michi > <mailto:michael.tha...@physik.tu-muenchen.de>>: >> >> Hi Endre, >> >> I wrote a small tes

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

> 5 apr 2016 kl. 17:50 skrev Michi : > > Hi Endre, > > I wrote a small test program that creates a socket channel, closes it and > creates another one using the same port: > > import java.io.IOException; > import java.net.InetSocketAddress; > import java.net.SocketAddress; > import java.net.St

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

> 2 apr 2016 kl. 10:31 skrev Guido Medina : > > I was only thinking in a consistent life cycle for both. > > With the new behavior I think I will never use preStart again in Akka Typed. > > That will be the only way we the users make sure we have control on > triggering conditions to execute p

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

Created ticket 20205 . > 2 apr 2016 kl. 09:56 skrev Patrik Nordwall : > > +1 to changing in Akka Typed > -1 to changing untyped, or adding more hooks (the call chain is complicated > as is) > > /Patrik > fre 1 apr. 2016 kl. 14:44 skrev Guido Medina

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

Hi Guido, I agree with your point; I’m currently leaning towards changing the behavior of Akka Typed (which is still experimental) to be what I consider more consistent now, but leaving untyped actors unchanged. Any objections? Regards, Roland > 1 apr 2016 kl. 13:58 skrev Guido Medina : > >

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

Another angle on this discussion comes into play when considering Akka Typed: there we make it very obvious that PreStart and PostStop are signals that the actor may react to if it so chooses. In this spirit it would make sense to disregard the outcome of such signal processing if it fails and c

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

I'm no Klang but I can assure you that all callbacks MUST be dispatched on the provided ExecutionContext—otherwise someone will invariably find a way to trigger a StackOverflowError. These docs should probably be removed completely since we also moved to Scala futures. Regards, Roland Sent f

Re: [akka-user] Usage of EventFilters in akka.testkit

Yes, indeed, thanks for sharing! It would be awesome if you could add this to the docs, if you don’t mind. Regards, Roland > 23 mar 2016 kl. 10:17 skrev Sven Hodapp : > > I've found a solution: > > EventFilter.info(pattern="log content", occurrences=1) intercept { > ac ! Consume

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

Yes, and for the immediate case you can use Future.successful. Regards, Roland Sent from my iPhone > On 20 Mar 2016, at 15:41, john.vie...@gmail.com wrote: > > Something very simple which come to my mind is to mapAsync to the ask > pattern and then do a "schedule of 10 secs" if the element i

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

ka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com > <mailto:akka-user+unsubscr...@googlegroups.com>. > To post to this group, send email to akka-user@googlegroups.com > <mailto:akka

Re: [akka-user] Restart does not work with my zipper? What am I doing wrong?

ribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com > <mailto:akka-user+unsubscr...@googlegroups.com>. > To post to this group, send email to akka-user@googlegroups.com > <mailto:akka-user@googlegroups.com>

Re: [akka-user] awaitTermination not working?

ived 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 > <mailto:akka-user+unsubscr...@googlegroups.com>. >

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

receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com > <mailto:akka-user+unsubscr...@googlegroups.com>. > To post to this group, send email to akka-user@googlegroups.com > <mailto:akka-user@googlegroups.com>. > Visit this group at https://g

Re: [akka-user] Re: Akka.NET or Alternative

mailto:akka-user+unsubscr...@googlegroups.com>. > To post to this group, send email to akka-user@googlegroups.com > <mailto:akka-user@googlegroups.com>. > Visit this group at https://groups.google.com/group/akka-user > <https://groups.google.com/group/akka-user>. >

Re: [akka-user] change of Tech Lead

nsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com > <mailto:akka-user+unsubscr...@googlegroups.com>. > To post to this group, send email to akka-user@googlegroups.com > <mailto:akka-user@googlegroups.co

[akka-user] change of Tech Lead

Dear fellow hakkers, as of today I am passing on the baton of Akka Tech Lead @ Lightbend to Patrik Nordwall. Don’t worry, I will stay around and keep working on Akka, but it will no longer be my day job come April: I am co-founding actyx —a new start-up in Munich that

  1   2   3   4   5   6   7   8   >