Re: [akka-user] FSM gets a message before a transition finishes?

'ktoso' Malawski hAkker - Typesafe, Inc -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed

Re: [akka-user] Visualisation of running system

around tracing, I’m aware of Kamon: http://kamon.io and AkkaTracing:  https://github.com/levkhomich/akka-tracing // Was not able to try them out yet. I hope that helps (a bit) :-) --  Konrad 'ktoso' Malawski hAkker - Typesafe, Inc -- Read the docs: http://akka.io/docs/ Check the FAQ

Re: [akka-user] Testing that an actor throws an exception

of these options fits you! :-) --  Konrad 'ktoso' Malawski hAkker - Typesafe, Inc -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] Re: Is it possible to use EventsourcedProcessor with FSM[S, D]?

Thanks, your feedback is well appreciated! --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You

Re: [akka-user] [akka-streams]: actor producers, load balancers

Producer are you implementing? :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] Is there an 'onRecovered' hook in EventsourcedProcessor? (Implementing a 'redo transaction')

” around, and then you get your “FIRST” msg, you know recovery has finished and you can run your logic. I hope this helps, happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional

Re: [akka-user] scheduled events deadlocking

with TestKit section of the docs. I hope this helps, happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com

Re: [akka-user] How to Store the Message Object/Class to a database?

Glad I could help! Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] There are now akka-stream in master. Why?

is also very welcome. Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] There are now akka-stream in master. Why?

No worries, https://github.com/akka/akka/tree/release-2.3-dev/akka-stream Happy hakking :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] EventBus publish last event

calling `isTerminated` all the time). The change required making the bus require an ActorSystem - which should not be a problem, since you’re most of the time implementing actor based apps anyway with these - migration guide here. Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http

Re: [akka-user] EventBus publish last event

required making the bus require an ActorSystem - which should not be a problem, since you’re most of the time implementing actor based apps anyway with these - migration guide here. Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs

Re: [akka-user] Akka Persistence 2.3.4 and State machines

myself). --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message

Re: [akka-user] [akka-persitence 2.3.4] documentation inconsistency

://github.com/akka/akka/issues/15508 If you’re free or someone would like to help us out time-wise, we would very much welcome a pull request to fix this :-) Thanks again for reporting, happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io

Re: [akka-user] Persistence questions

.  * If this user comes back, you simply start the actor, it does the replay (or from snapshot, that you did before killing it) and is ready to rock and roll. That’s the general idea. And I think the design becomes very clear if you keep the 1:1 mapping. I hope this helps! --  Konrad 'ktoso' Malawski hAkker

Re: [akka-user] How to run akka stream distributedly in a cluster?

That’s currently not supported. Streams are a very fresh module, and we’re still working to get the in-jvm semantics and APIs *right* before we go distributed. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http

Re: [akka-user] How to run akka stream distributedly in a cluster?

combinators please check if they’re already in our todo’s or open a ticket:  https://github.com/akka/akka/issues?labels=t%3Astreampage=1state=open --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka

Re: [akka-user] [akka-stream 0.3] Exception when shutdown actor-system

. For more options, visit https://groups.google.com/d/optout. -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user

Re: [akka-user] maximum-frame-size and Akka performance

the connection. See: http://www.eaipatterns.com/MessageSequence.html 3) One other approach would be to use akka-io to deal with the file transfer. The receiving end would need more work here. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs

Re: [akka-user] maximum-frame-size and Akka performance

Yes it will degrade, because you’ll clog the connection between system `A` and `B` while pumping through LargeMessage, and the other waiting SmallMessages won’t get through while the large one is being written. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read

Re: [akka-user] Contents link in HTML documentation pages

Thanks a lot, I’ll have a look at it today :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group

Re: [akka-user] Using EventStream in non-actor context

://doc.akka.io/docs/akka/2.3.4/scala/typed-actors.html ), so the non-actors won’t even know that they’re talking with an actor. How does that sound? :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io

Re: [akka-user] Testing PersistentActor, receiveCommand is never called (Akka 2.3.4)

easier) but we have not discussed it in detail yet, let me know if you have a wish list for that kind of utility so we’ll keep them in mind :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs

Re: [akka-user] updating persistent store to different plugin

for the feedback! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message

Re: [akka-user] Best practices using Akka Persistence with long-running projects?

;-)). I know I’ve just grown your to-read list by quite a bit, but I hope this helps! :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] [2.3.4] Configuring bean without Play.

Nope. Please ask the ebean guys about helping out with this one - I had no idea what ebean is until this email :-) Have a great weekend! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

:-) --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message

Re: [akka-user] akka scheduler with long delays

to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io

Re: [akka-user] Re: akka persistence cleanup old snapshots files

/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] Re: akka persistence cleanup old snapshots files

Please open an issue on our github issue tracker,  https://github.com/akka/akka/issues Thanks a lot! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

in some time next week. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

- a total order per persistenceId based on sequence numbers (= partial ordering in the all events stream) is a must have IMO. - ordering based on timestamps should be an application level concern (= timestamps in application-defined events and (re-)ordering done by application) Agreed, seqNrs

Re: [akka-user] Pleasure doing business with event processor

examples of what you’d need :-) Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka

Re: [akka-user] A few simple questions about versions of Akka, Akka Persistence and Cassandra journal driver

an email to akka-user+...@googlegroups.com. To post to this group, send email to akka...@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Read

Re: [akka-user] Re: What would it take to make actors in another language/platform

any language – producing the bytes is the the one of the smaller problems actually, once we’d set on a serialisation format. There have been some rough ideas, but are currently focusing on tasks at hand (persistence, streams, akka-http etc). --  Konrad 'ktoso' Malawski hAkker @ typesafe http

Re: [akka-user] Synchronising responses sent from parents and children

it, send an email to akka-user+...@googlegroups.com. To post to this group, send email to akka...@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe

Re: [akka-user] akka-persistence (2.3.4) and serialization

hope you see my point and this helps in the long run! -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] akka-persistence cassandra journal plugin api

@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka

Re: [akka-user] Akka Persistence: LogProducer and LogConsumer?

Views” proposal already). Thanks for the interest and ideas! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] sbt dist with version 2.3.2

to the native packager in the docs  https://github.com/akka/akka/issues/15677 Cheers! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] Akka FSM and Akk persistence with Java (8)

work. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because

Re: [akka-user] Difference between PersistentView and Projections

. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you

Re: [akka-user] Re: Storm-like framework implemented on Akka

Have anything changed in this matter? https://spark.apache.org/ Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] Akka Streams and Testing (particularly Ducts)

point. Feel free to add comments and use cases to that issue, we welcome feedback and ideas! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] Performance tuning

Glad you were able to figure it out.  Indeed tweaking the dispatchers is very often the way in such situations, the exact settings are very dependent on the actual workloads ofc. Happy hakking!  --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http

Re: [akka-user] Manifest Event Sourcing Application's Performance

a proper benchmark you need to put some effort into it. Hope this point of view helps. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] Unit testing persistent actors in Akka

I get where you're coming from. People may rely on test with TestActor ref and not do the proper actor specs. Those IT specs are mandatory. Exactly, you’ve defined it way better than I did by going into the nitty-gritty details actually :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe

Re: [akka-user] Akka Actors In Scala Vs Akka Actors In Java:Event Sourcing

. If you really care you should benchmark things :-) -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You

Re: [akka-user] draining daemon system actors' queues on shutdown

Hello Andrew, you might find “the Reaper” pattern of interest to you:  http://letitcrash.com/post/30165507578/shutdown-patterns-in-akka-2 --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka

Re: [akka-user] multiple journals with akka-persistence

on it, but it’s not within the short term plans for now:  https://github.com/akka/akka/issues/15587 --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] Why does Akka persist sharding coordinators when you use Akka persistence ?

. Are there other Akka internal classes that use Akka persistence as well ? No, it’s just the ClusterSingleton and ClusterSharding (in akka-contrib), which we’ll want to promote out of contrib soon. Hope this helps,  Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http

Re: [akka-user] Akka Persistence journal size

to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io

Re: [akka-user] creating akka actors by using context.actorOf

Hello there, Have you read this section of the docs?  http://doc.akka.io/docs/akka/2.3.6/java/untyped-actors.html#creating-actors-with-props context is a method available to Actors, it starts “child actors”, and not “top level actors” (it’s cheaper - do this). --  Konrad 'ktoso' Malawski hAkker

Re: [akka-user] Akka as Gradle dependency

. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs

Re: [akka-user] Accessing Future's onComplete Internal variables

, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups Akka

Re: [akka-user] IllegalStateException in akka.dispatch.BatchingExecutor$Batch.run

this appeared? Are you using akka streams? Which version of akka etc are you using? Thanks for the additional info, let’s try looking into it. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs

Re: [akka-user] Aeron as Akka's transport layer ?

some of their tricks in our code (NIO hacks). It does a bunch of more things (it’s log) which we could use for things, but no plans yet. The future will be very interesting :-) --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check

Re: [akka-user] Using Akka Persistence with another KV store

://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] Re: Akka, Camel and RabbitMQ - Asynchronously acknowledging specific message

/1.3.1/modules/amqp.html Camel continues to be very useful on oh-so-many cases. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https

Re: [akka-user] Re: [akka-streams] Dynamically add route output port

to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check

Re: [akka-user] Use TypedActor or something else

this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso

Re: [akka-user] dependency between tests when using ImplicitSender and forget to consume a response with any of the expect-methods

://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

Re: [akka-user] dependency between tests when using ImplicitSender and forget to consume a response with any of the expect-methods

Thanks; you too! Happy hakking! — konrad On 23 November 2014 at 00:51:45, Konrad 'ktoso' Malawski (konrad.malaw...@typesafe.com) wrote: We actually often find this rather useful - for example, if there comes a response from the previous test case which I did not expect, it could fail the 2nd

Re: [akka-user] Save 2 snapshots at the same time?

://groups.google.com/d/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received

Re: [akka-user] Confusion about durable mailboxes superseded by akka-persistence?

/optout. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message

Re: [akka-user] Akka streams - stability

We’ll announce when it’s “stable stable” ;-) No huge changes planned, but there still may be a few here and there. Issue tracker is github, as for the rest of Akka as well:  https://github.com/akka/akka/issues?q=is%3Aopen+is%3Aissue+label%3At%3Astream Happy hakking! --  Konrad 'ktoso' Malawski

Re: [akka-user] Maven Testkit Integration

this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives

Re: [akka-user] Akka HTTP client closing connection early

And one minute afterwards… 1.0-M1 released! See details in the announcement email :-) Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io On 4 December 2014 at 18:11:17, Akka Team (akka.offic...@gmail.com) wrote: Hi Tom, There wasn't a fully operating Http Client

Re: [akka-user] Event Sourcing with eventual consistency guarantees

://www.ustream.tv/recorded/46744749 --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io On 25 December 2014 at 21:39:24, Stefan Schmidt (stsme...@gmail.com) wrote: Hi guys, I am currently prototyping a new app which involves transferring money between various accounts. On a very high level I

Re: [akka-user] Event Sourcing with eventual consistency guarantees

compensating actions - by always appending data + making sure *global* invariants are perserved (check Eric Evan’s talk I liked for awesame examples of this). I hope this helps! Merry x-mas hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io On 25 December 2014 at 21:39:24

Re: [akka-user] Running a stream inside an Actor ?

of “materializing a stream from within an actor”. I just noticed we didn’t (yet!) document this trait. We’ll add it to the docs which we will be still improving after the holiday-break.. Happy hakking! --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io On 26 December 2014 at 05:00:18, Soumya

Re: [akka-user] Recording latency of operations that return a Future inside an akka stream

Hi Soumya, I don’t think what you’ll end up measuring this way will be very useful. I mean, between the completion of the future and the triggering of the map there are multiple asynchronous boundaries… So you won’t be measuring how fast the set operation was, but how much time was between

Re: [akka-user] Possibility of deploying actors from single ActorSytem to multiple nodes

And yes, you can of course send messages between actors on different nodes. --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io On 31 December 2014 at 06:23:49, Krishna Kadam (shrikrishna.kad...@gmail.com) wrote: Hi all,       I am a student, trying to horizontally scale a tool. I

Re: [akka-user] akka-http HttpService equivalent

that this is a major improvement over spray, since it never had a Java DSL – with Akka HTTP even Java users will be able to use it :-) Cheers, --  Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io On 4 January 2015 at 14:08:16, Jacek Laskowski (jacek.japila...@gmail.com) wrote: Hi

Re: [akka-user] How to disable TLSv1 when I configure "akka.remote.netty.ssl.security.protocol" property as TLSv1.2.

That seems like a good catch indeed! Thanks for finding this. I've made an issue and PR for it: https://github.com/akka/akka/issues/21077 https://github.com/akka/akka/pull/21078 If reviewed by team we could include this patch very soon. Thanks for reporting! -- Konrad W dniu czwartek, 28

[akka-user] [ANNOUNCE] Akka 2.4.9-RC1 Released! (Akka HTTP Performance and Entity Streaming)

plans and progress. Credits: commits added removed 3957531748 Konrad `ktoso` Malawski 11 693 239 Johan Andrén 7 828 295 Endre Sándor Varga 6 776 410 Hawstein 5 171 81 Nafer Sanabria 2 4 4 kenji yoshida 2 55 22 Alexa

[akka-user] [ANNOUNCE] Akka 2.4.9-RC2 released!

Dear hAkkers, We—the Akka committers—are pleased to announce the availability of Akka 2.4.9-RC2. This release does not change much over the previous Release Candidate, except fixing one OSGi plugin induced packaging problem which might have caused compilation errors, see issue #21105

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

Figured I should link to the 2.4.9 annoucement from this old thread (as it shows up high in google). In 2.4.9 we did quite some improvements, annoucement here: http://akka.io/news/2016/08/19/akka-2.4.9-released.html Highlights of the

[akka-user] Re: Akka stream - Flow in Pause

Seems like double posted the same question? Please don't double post the same question :-) I answered in that thread: https://groups.google.com/forum/#!topic/akka-user/7VqlP1w_CN8 -- Konrad Akka Team W dniu piątek, 14 października 2016 09:02:59 UTC+2 użytkownik regis leray napisał: > > I'm

[akka-user] Re: Akka stream - implements Pause/Resume

Please read this: - http://blog.akka.io/integrations/2016/08/29/connecting-existing-apis - and this: http://doc.akka.io/docs/akka/2.4/scala/stream/stream -customize.html Specifically, your trigger should be implemented as async-callback, as it comes from the outside but should "wake up" the

[akka-user] ANNOUNCE: Akka HTTP 3.0.0-RC1

Dear hakkers, We are proud to announce the first Release Candidate of the Akka HTTP's "fully stable" release–the only missing, bit was the Routing DSLs, which we now deem stable enough to support for an extended period of time. This release marks the first of the 3.0.0 series of this project

[akka-user] ANNOUNCE: Akka 2.4.14 released!

Dear hakkers, We are proud to announce the fourteenth maintenance release of Akka 2.4 which contains a number of improvements and bugfixes. Some notable changes are: - When reading snapshots fails for a persistent actor it will now cause recovery failure #21842

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

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 gitter! Please note that while the version number changed significantly, the actual surface APIs did not by much. The

Re: [akka-user] Persistence Query and Sharding

*Eventually* all events with the given tag. Note also that that stream is infinite, unlike the “currentEventsByTag” which is finite and whatever was currently visible by that tag when it was reading. — Konrad `kto.so` Malawski Akka @ Lightbend On 1 August

Re: [akka-user] akka-1.3.1.xsd schema location

Hi there, you could get them from here: https://github.com/akka/akka.github.com/tree/968159d916d9a54c5d247c5b228398e1e0d43d68 (old version of what was the website, and had all these files). — Konrad `kto.so` Malawski Akka @ Lightbend On 1 August 2017 at

Re: [akka-user] Flow.fromSinkAndSource and backpressure

Hi Jeff, Alexey, that’s not correct, back-pressure works there - because it has to: it is enforced by the reactive-streams protocol that we follow by heart in Akka streams. Yes, back-pressure works, the one sentence explanation would be: “independently on each side of the newly constructed

Re: [akka-user] Flow.fromSinkAndSource and backpressure

Good point, I missed that word in the question - thanks and sorry about that :) A full clarification was still useful I hope though, cheers! — Konrad `kto.so` Malawski Akka @ Lightbend On 2 August 2017 at 15:45:51, Alexey Shuksto (seig...@gmail.com) wrote:

Re: [akka-user] Akka cluster on Hadoop YARN

There has not been much interest in that from what I can cell. Rather people are using k8s, marathon/mesos etc to run Akka applications nowadays. — Konrad `kto.so` Malawski Akka @ Lightbend On 15 August 2017 at 12:03:14, Juan Rodríguez Hortalá (

Re: [akka-user] Performance of Akka-Http 2.5.4

When wanting to discuss any benchmarks, please share actual code as otherwise it's impossible to comment on what you're actually benchmarking. Same goes for benchmark setup, you did not explain how the benchmark was run and what network it was on etc. We have continuously confirmed same

Re: [akka-user] Re: Akka Camel and Akka Streams

And it is listed under Alpakka projects too :-) http://developer.lightbend.com/docs/alpakka/current/external-connectors.html#camel — Konrad On 12 July 2017 at 15:06:01, 'Martin Krasser' via Akka User List ( akka-user@googlegroups.com) wrote: Hi Andreas, the replacement for akka-camel is the

Re: [akka-user] Akka Streams - UDP messages

Hi there, you do realize that UDP, the protocol itself, does not guarantee delivery of anything? It absolutely may and will in practice drop packets - it is designed to do exactly that. Start reading about UDP here https://en.wikipedia.org/wiki/User_Datagram_Protocol and take it from there to

Re: [akka-user] Re: withSupervisionStrategy passed a japi Function but compiler complains that its expecting a scala Function1

...@lightbend.com) wrote: Well that's exactly the thing we fixed. As you've found in the docs. We'll release a stable this week, please upgrade then. -- Konrad `ktoso` Malawski Akka <http://akka.io> @ Lightbend <http://lightbend.com> On 26 October 2016 at 13:29:52, murtuza chhil (chil.

Re: [akka-user] Re: Akka Typed and MDC

The "power mode” ;-) On 11 July 2017 at 00:02:12, Justin du coeur (jduco...@gmail.com) wrote: Oh, sweet -- ExtensibleBehavior looks enormously useful... On Mon, Jul 10, 2017 at 9:29 AM, Konrad 'ktoso' Malawski <ktos...@gmail.com> wrote: > Once I wrote the response I though

Re: [akka-user] How to download and install newest Akka

Akka is just a Scala/Java library, you’d use it like any other Scla/Java library. So you could add it as dependency in your maven file, or first learn how to use sbt: http://www.scala-sbt.org/ and to the same there. Akka dependencies are listed on http://akka.io/docs/ Happy hakking — Konrad

Re: [akka-user] Use of high performance bounded mail box.

The current default, more than anything, is bound to be the default since it was the default since the inception of Akka and going for a bounded one by default now could make some users unhappy. Having that said, we're actively looking forward to pick a bounded impl for Akka Typed. Then people

Re: [akka-user] Akka Typed API discussion

Hi Bryan, The forum differs a bit depending on what you want to chat about. Do you have a few issues to talk about and they’re specific enough (and potentially could have an actionable outcome I’d assume/hope)? Then http://github.com/akka/akka would be the best, one ticket per specific issue, not

[akka-user] Re: Akka Typed and MDC

Akka Typed is still not quite "done" so missing or undecided upon APIs may still be here and there. That's one of them, so I opened a ticket to discuss and decide what to do about it in Typed. https://github.com/akka/akka/issues/23326 Having that said, you can always just directly use the

[akka-user] Re: Akka Typed and MDC

Once I wrote the response I though that for using the library directly you'll also want to know about the possibility to implement: /** * Extension point for implementing custom behaviors in addition to the existing * set of behaviors available through the DSLs in

Re: [akka-user] Akka-Typed MutableBehavior: return type of onMessage

Exactly the same. Becoming an different behavior. On July 19, 2017 at 0:16:18, Mushtaq Ahmed (mushta...@gmail.com) wrote: > Actor.immutable returning Behaviour[T] makes sense as it uses recursion to > return updated state or Actor.stopped etc. > > But in MutableBehavior, I end up using this

Re: [akka-user] [ANNOUNCE] ChanaMQ - an Akka based AMQP messaging broker

Dispatchers are documented http://doc.akka.io/docs/akka/current/scala/dispatchers.html ForkJoinPool based. Stages get fused so it’s a bit more tricky than that. — Konrad `kto.so` Malawski Akka @ Lightbend On 28 July 2017 at 05:49:20, Caoyuan

  1   2   3   >