[akka-user] Can typesafe/config can do command line parsing?

Hi All, I really like typsafe config library but it looks like it doesn't do any command line parsing and create --help docs and so on similar to Apache commons CLI however the dependencies are too big for Apache commons CLI. wondering if there are any typesafe libraries that can do CLI

[akka-user] question on Akka concurrency and ForkJoinPool

Hi All, I came across this paper and I quoting the paragraph below where I have the question. The author seems to suggest JVM threads are different from the threads used by Akka kernel ? I am not sure what is the

Re: [akka-user] Can Akka Actors be considered as green threads?

re remote. > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > > On 31 March 2017 at 12:53:32, kant kodali (kant...@gmail.com ) > wrote: > -- >>>>>>>>>> Read the docs: http:

[akka-user] Can Akka Actors be considered as green threads?

Hi All, I wonder what is an Actor underneath ? I mean I understand that they are Object that have a state, mailbox , listeners and all that but the moment I hear Actors can "crash" and "restart and run or process again" I think of it as some scheduling/processing entity and I wonder if that

Re: [akka-user] Can we use activator for Spark projects?

o> @ Lightbend <http://lightbend.com> > > On 27 March 2017 at 12:46:17, kant kodali (kanth...@gmail.com) wrote: > > Hi All, > > Can we use activator for Spark projects along with typesafe config > library? Any examples? > > Thanks! > > -- > >>>>>&g

[akka-user] Can we use activator for Spark projects?

Hi All, Can we use activator for Spark projects along with typesafe config library? Any examples? Thanks! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the

[akka-user] Does Event Bus require Publisher and Subscriber to be started in certain order?

Hi All, Does Event Bus require Publisher and Subscriber to be started in certain order? Isn't there a Listener which will push messages to subscribers whenever they become alive? I am playing with the LookUpBus Example from here but

[akka-user] Cannot use a method returning play.mvc.WebSocket[?0] as a Handler for requests

Hi All, I originally posted this question on SO and tried it myself but unable to find what I am doing wrong? I get the following error. I followed this documentation https://www.playframework.com/documentation/2.5.x/JavaWebSockets. [error] /Users/hello/Documents/java/test_app/conf/routes:8:

Re: [akka-user] Does Activator require SBT ? Can it work with gradle?

t; > On 22 March 2017 at 13:46:46, kant kodali (kant...@gmail.com ) > wrote: > > oh if you guys are deprecating activator what is its replacement? Any > pointer on the web I can follow? > > On Wednesday, March 22, 2017 at 4:32:35 AM UTC-7, Konrad Malawski wrote: >> >&

Re: [akka-user] Does Activator require SBT ? Can it work with gradle?

re. Your normal development you do in whichever thing you want. > It is also being deprecated in favour of new tools we're working on at > Lightbend. > > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 22 March 2017 at

[akka-user] Does Activator require SBT ? Can it work with gradle?

Hi All, I love the activator tool. Whoever implemented a big thanks! I am wondering if it require SBT ? can it work with gradle (since we currently use gradle)? Thanks! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: How to group a list of actors in Akka?

Thanks! I ended up using LookupEventBus and that solved my problem! On Tuesday, March 21, 2017 at 3:16:52 AM UTC-7, kant kodali wrote: > > Hi All, > > How to group a list of actors? I want to send message A to group of Actors > M and message B to group of Actors N. Is there a w

Re: [akka-user] How to group a list of actors in Akka?

e a reason not to just have the parent maintain separate lists of > the different groups? You seem to be trying to find a built-in solution to > a problem that folks usually just solve manually (because it is usually > extremely easy to do so). > > On Tue, Mar 21, 2017 at 4:18 PM, kant kodal

Re: [akka-user] How to group a list of actors in Akka?

Can two actors have the same name? For Example, Can I create same instance of Actor class in a For loop so I can access all the actors by that name? On Tue, Mar 21, 2017 at 6:12 AM, Justin du coeur wrote: > Right -- that's probably the way I would tend to construct

[akka-user] How to group a list of actors in Akka?

Hi All, How to group a list of actors? I want to send message A to group of Actors M and message B to group of Actors N. Is there a way to give them a common name and access them through that name so I can send my messages? or Is there any better way? Thanks! -- >> Read the

Re: [akka-user] Re: How to listen to events on CassandraJournalProvider ?

simply means that when >> you use the CassandraReadJournal there is a thread that polls the DB and >> when there are new events there passes them down the stream. >> >> HTH, >> Tal >> >> >> On Sunday, March 12, 2017 at 4:09:02 PM UTC+2, kant kodali wrote: >

[akka-user] How to get all the Actors that are holding a particular web socket endpoint using Play framework?

Hi All, I have a message queue which doesn't have Actor concepts or anything so what I plan to do is that on the application startup I want to start the consumer which will then keep getting messages from the queue. Now, Play framework creates an Actor for every Web Socket Connection and I

[akka-user] Re: How akka cluster become network partition

Why does one needs to take an approach of Split brain resolver when there is something better? The problem of network partitions is well understood in most distributed nosql databases. For example Cassandra continues to operate with the nodes that are available/reachable/up during network

Re: [akka-user] Re: Cassandra Time Stamp Problem and How Akka can help?

tuff. > > I don't have a straightforward example myself (my system uses all of this, > but is fairly complex) -- anybody else have a good example to point to? > > On Wed, Mar 15, 2017 at 7:29 PM, kant kodali <kant...@gmail.com > > wrote: > >> What is each Entity if I may

[akka-user] Akka Routing question

Hi All, I have a stream of JSON encoded messages and I want to distribute them to group of actors or actor systems based on the field inside a message so say more like hash(key)->Actor but when the Actor dies I want to be able to hash the key to a different Actor that are available but at any

[akka-user] Re: Cassandra Time Stamp Problem and How Akka can help?

example somewhere I can take a look please? Thanks! On Tuesday, March 14, 2017 at 4:52:43 AM UTC-7, kant kodali wrote: > > Hi All, > > I have Kafka as my live streaming source of data (This data isn't really > events but rather just messages with a state) and I want to inse

[akka-user] Re: Naive question

if my current state A = {key1: val1, key2: val2, ...key50: val50} and the next state B = {key1: val1, key2: val2, ...key5: val5} then Persistence actor would store A-B = {key6: val6, key7: val7, ...key50: val50} ? On Tuesday, March 14, 2017 at 10:20:42 AM UTC-7, kant kodali wrote

[akka-user] Re: Naive question

typically with PersistenceActor? Any simplistic example would help a great deal! On Sunday, March 12, 2017 at 7:09:06 AM UTC-7, kant kodali wrote: > > Hi, > > What does it mean when someone says we store the event itself rather than > storing the state/data? such that the events

[akka-user] Cassandra Time Stamp Problem and How Akka can help?

Hi All, I have Kafka as my live streaming source of data (This data isn't really events but rather just messages with a state) and I want to insert this data into Cassandra but I have the following problem. Cassandra uses Last Write Wins Strategy using timestamps to resolve conflicting

[akka-user] Re: How to listen to events on CassandraJournalProvider ?

process has to catch up with a large stream I assume that may not scale well. @Patrick Can I see a ticket or something I can follow? Thanks much! On Sunday, March 12, 2017 at 7:09:02 AM UTC-7, kant kodali wrote: > > Hi All, > > I am trying to understand event sourcing in detail

[akka-user] Naive question

Hi, What does it mean when someone says we store the event itself rather than storing the state/data? such that the events can be replayed to store the state/data. Does it mean storing the functions/transformation itself (simply put the JVM byte code for the function itself) ? Thanks! kant

[akka-user] How to listen to events on CassandraJournalProvider ?

Hi All, I am trying to understand event sourcing in detail and I am new to Akka. One of book I was reading says a Persistence Actor will write events to a Journal so in my case the Journal is Cassandra and one can have Persistence Query Actor listen to the events from the Journal and this is