I have an actor system configured with remote and pinned dispatcher
my-setting {
akka {
actor {
provider = "akka.remote.RemoteActorRefProvider"
my-pinned-dispatcher {
executor = "thread-pool-executor"
type = PinnedDispatc
On Sat, May 31, 2014 at 4:56 AM, Eugene Dzhurinsky
wrote:
> Hello!
>
> I have a cluster with set of FSM actors deployed there. I also have a
> *ClusterClient* configured to send a message to the dedicated actor
> service, which then processes the passed data and now it has to *respond
> to the se
Howdy All,
I've been reading lots of threads on the Akka User mailing list and pull
requests and blog posts within the community but I am confused about what
currently are the "best practices" for:
1. Distributed and Resilient Pub-Sub within Akka
It seems to me that a resilient pub-sub is a k
My questions pertain to the choice of ack based write throttling in the
reactive streams implementation using Akka. I currently have multiple, Akka
based, Protocol Buffers via TCP services running in production at my
company, and, like the group at spray, I tend to prefer nack based write
throt
On Sunday, June 1, 2014 7:42:49 PM UTC+4, Konrad Malawski wrote:
>
> Yes, perhaps I should explain our current workflow with these branches
> actually:
>
> master will eventually become akka 2.4.x
>
> release-2.3 will eventually become akka 2.3.4 (and 2.3.5 if it’s needed
> etc).
>
> release-2.3-
Yes, perhaps I should explain our current workflow with these branches
actually:
master will eventually become akka 2.4.x
release-2.3 will eventually become akka 2.3.4 (and 2.3.5 if it’s needed
etc).
release-2.3-dev is used only for streams development. It is separate to
keep iterating / releasi
Aha, thanks, I see, it's just a way to organize branches.
--
>> 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
---
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
>>>
Sorry, my mistake, I mean "There are *no* akka-stream...". I haven't found
a way to edit the subject.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: ht
Uhm, I don’t think it ever had streams in it, hm! :-)
The streams are in active development and are located in the release-2.3-dev
branch.
Slightly hidden we know, on the other hand, it’s very aggressively changing, so
that may be a good thing…
Anyhow, you’re free to give it a spin! Feedback is
I just have noticed master hasn't anymore akka-stream subproject. Does it
mean akka (and Scala in whole) reactive streaming is preparing for the next
reincarnation? :)
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/
Hello Ian,
replies in-line :-)
I'm recently read about reactive streams, and want to know some more about
> it.
>
Awesome, you're in the right place then :-)
> how does one deal with time. specifically how do I set up a periodic
> scheduler to tell the flow that it's time to emit results. (and i
Even i am facing almost the same issue.I am not able to load config files
using *"class MyTestSpec extends TestKit(ActorSystem("*
*MyActorSystem", ConfigFactory.load()))*
Could you please provide pointers how to specify
-Dconfig.file=... VM parameter when running testcase.I have couple files
13 matches
Mail list logo
