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

2017-07-13 Thread Madabhattula Rajesh Kumar
://en.wikipedia.org/ > wiki/User_Datagram_Protocol and take it from there to networking books > and articles. > > In short, if you’re suprised that UDP “dropped”, you should likely not be > using UDP at all :-) > > — Konrad > > > On 13 July 2017 at 21:34:17, Madabha

[akka-user] Akka Streams - UDP messages

2017-07-13 Thread Madabhattula Rajesh Kumar
Hi, I am using Akka Streams to read the messages from UDP port and write into the filesystem. It is not able to read all messages. Some messages are dropping. I have found one example program in the github. https://github.com/jpthomasset/akka-udp-stream val source = UdpSource(new

[akka-user] WebSocket with Akka Streams

2017-04-01 Thread Madabhattula Rajesh Kumar
Hi, I need to read messages from clients(web socket clients) and persist these messages into two files. But, messages are overriding to previous messages. Every time only last message is present in the file. How to append the messages. Please help me to resolve this issue. *Code :- * def

[akka-user] Akka Http :- URL path parameters

2017-03-07 Thread Madabhattula Rajesh Kumar
Hi, How to read url path parameters in Akka Http POST method with multiform form data. Please help me on this. Regards, Rajesh -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html

[akka-user] Akka streams in web application

2016-09-29 Thread Madabhattula Rajesh Kumar
Hi, I am planning to use Akka Streams in web application. Below is my use case. Whenever the request come to web server, I will do some operations like stg01, stg02 ... *I have a below questions :- * - Do we need to close the streams after each request processed ? - If N multiple

Re: [akka-user] How to find Oldest node in Akka Cluster Singleton

2016-07-05 Thread Madabhattula Rajesh Kumar
ub.com/akka/akka/blob/master/akka-cluster/src/main/scala/akka/cluster/Member.scala#L46> > . > > /Patrik > > On Sat, Jul 2, 2016 at 8:20 PM, Madabhattula Rajesh Kumar < > mraj...@gmail.com > wrote: > >> Hi, >> >> In akka cluster singleton how to

[akka-user] How to find Oldest node in Akka Cluster Singleton

2016-07-02 Thread Madabhattula Rajesh Kumar
Hi, In akka cluster singleton how to find "Oldest" node details. Regards, Rajesh -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives:

[akka-user] Akk Cluster Singletion - Oldest node down message

2016-07-02 Thread Madabhattula Rajesh Kumar
Hi, In Akka Cluster Singleton how worker(younger) node receive a message when Cluster Singleton node(Oldest) was down ? In Akka *younger* node I am seeing below WARN message *[WARN] [07/02/2016 00:32:55.720] [ClusterSystem-akka.actor.default-dispatcher-2]

[akka-user] Re: Akka Cluster Singleton - Rejoining to existing cluster

2016-06-26 Thread Madabhattula Rajesh Kumar
rm that is by reading the cluster documentation. >> >> HTH, >> >> Guido. >> >> On Sunday, June 26, 2016 at 11:27:31 AM UTC+1, Madabhattula Rajesh Kumar >> wrote: >>> >>> Hi Team, >>> >>> I have a two nodes(A and B) in a Akka

[akka-user] Akka Cluster Singleton - Rejoining to existing cluster

2016-06-26 Thread Madabhattula Rajesh Kumar
Hi Team, I have a two nodes(A and B) in a Akka cluster. I am using Akka cluster singleton When initial cluster, A is a Oldest node and B is a Younger node. I manually killed A node using control C command. After some time, I started Node A but Node A is not rejoining the cluster. Node A

[akka-user] Code Coverage plugin

2016-04-13 Thread Madabhattula Rajesh Kumar
Hi, Could you please point me the Code Coverage plugin(for Scala ide) for Akka-Scala implementation. Regards, Rajesh -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

Re: [akka-user] Re: Akka Persistence with Cassandra

2016-04-09 Thread Madabhattula Rajesh Kumar
t; README: https://github.com/akka/akka-persistence-cassandra > > On Wed, Apr 6, 2016 at 5:59 AM, Madabhattula Rajesh Kumar < > mraj...@gmail.com > wrote: > >> Hi, >> >> If I use below application.conf (default settings). >> >> akka { >&g

Re: [akka-user] Re: Akka Persistence with Cassandra

2016-04-05 Thread Madabhattula Rajesh Kumar
t 10:23:02 AM UTC+5:30, Patrik Nordwall wrote: > > Could it be something with authentication? > > tis 5 apr. 2016 kl. 05:41 skrev Madabhattula Rajesh Kumar < > mraj...@gmail.com >: > >> >> >> On Monday, April 4, 2016 at 6:29:58 PM UTC+5:30, Madabhattula Ra

[akka-user] Re: Akka Persistence with Cassandra

2016-04-04 Thread Madabhattula Rajesh Kumar
On Monday, April 4, 2016 at 6:29:58 PM UTC+5:30, Madabhattula Rajesh Kumar wrote: > > > Hi, > > I am not able to connect Cassandra journal from Akka Persistence. Please > find below my application.conf and exception details. > > Could you please help me to reso

[akka-user] Re: Akka Persistence with Cassandra

2016-04-04 Thread Madabhattula Rajesh Kumar
Hi Yan, Yes. I have started Cassandra in local. It is running fine Regards, Rajesh On Monday, April 4, 2016 at 9:45:33 PM UTC+5:30, Yan Pei wrote: > > Does your cassandra run in local? > > On Monday, April 4, 2016 at 7:59:58 AM UTC-5, Madabhattula Rajesh Kumar > wrote: >>

[akka-user] Re: Akka Persistence with Cassandra

2016-04-04 Thread Madabhattula Rajesh Kumar
Hi Yan, Yes. I have started Cassandra in local. It is running fine Regards, Rajesh On Monday, April 4, 2016 at 9:45:33 PM UTC+5:30, Yan Pei wrote: > > Does your cassandra run in local? > > On Monday, April 4, 2016 at 7:59:58 AM UTC-5, Madabhattula Rajesh Kumar > wrote: >>

Re: [akka-user] akka streams

2016-03-23 Thread Madabhattula Rajesh Kumar
io/docs – > don't use old versions ;-) > > -- > Cheers, > Konrad 'ktoso’ Malawski > <http://akka.io>Akka <http://akka.io> @ Lightbend <http://typesafe.com> > <http://lightbend.com> > > On 23 March 2016 at 11:51:05, Madabhattula Rajesh Kumar ( > mra

[akka-user] akka streams

2016-03-23 Thread Madabhattula Rajesh Kumar
Hi, Why akka streams are in experimental state? Any API changes/architecture changes are happening in coming releases? Can we use akka streams in production? Regards, Rajesh -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>