[akka-user] Re: Uniqueness of actors in akka Cluster

2015-03-19 Thread Ngoc Dao
You can try Glokka, a library to register and lookup actors by names in an 
Akka cluster:
https://github.com/xitrum-framework/glokka


On Monday, March 16, 2015 at 6:06:58 PM UTC+9, Krishna Kadam wrote:

 Hi all,
 Right now I am using akka named local actors to send perticutar type of 
  message to the same actor every time, but I am doubtful about its 
 uniqueness in clustering of actors.
 In simple words If I create and use clustered actors by name and try to 
 send the perticular type of message to same actor every time, will it work 
 in akka cluster? or do you have any other method do this? 

 please help.



 Thanks and regards
 Krishna Kadam


-- 
  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 
User List group.
To unsubscribe from 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.


Re: [akka-user] Re: Send message from netty code to actor system

2015-02-04 Thread Ngoc Dao
Generally there are 2 ways to design for this problem:

Once you have an actor reference, you can send things to it. So you can 
simply do this:
targetActorRef ! myThing

When the actor is done with the processing, it will call:
myThing.myMethod

This design is OK when the target actor is very reliable and it lies in the 
same node with myThing.

Another way, is to use an actor to wrap around myThing. This wrapper actor 
will communicate with targetActorRef. It may watch targetActorRef to handle 
the case when targetActorRef dies, targetActorRef doesn't respond after 
some timeout etc.


On Wednesday, February 4, 2015 at 10:09:19 PM UTC+9, Jabbar Azam wrote:

 I found some nice example showing integration of netty with akka on 
 github. This is what I'm looking at https://github.com/gibffe/fuse 
 specifically 
 https://github.com/gibffe/fuse/blob/master/src/main/java/com/sulaco/fuse/netty/FuseChannelHandler.java

 Its embarrassingly simple :)

 On Tuesday, 3 February 2015 13:48:47 UTC, Jabbar Azam wrote:

 Oops I meant channel handler.

 On Tuesday, 3 February 2015 13:32:21 UTC, Jabbar Azam wrote:

 Hello,

 Sorry for the late reply. For some reason the forum messages didn't get 
 forwarded to my email.

 I was thinking of using typedactors because I am trying to integrate non 
 actor code(cloudhopper SMPP which uses netty) into an actor system. Netty 
 does use callbacks so I can use asynchronous behaviour.

 Do you think I could encapsulate a netty channel inside an actor? A 
 netty channel can call callbacks whenever something changes in the channel.

 On Friday, 30 January 2015 12:38:14 UTC, Björn Antonsson wrote:

 Hi,

 Are you sure that you need to block the sending code while the actor 
 does its work? Is there an asynchronous API in netty that you can use 
 where 
 the actor would invoke a callback when it has finished processing the 
 packet?

 B/

 On 27 January 2015 at 11:03:26, Jabbar Azam (aja...@gmail.com) wrote:

 I think I need to look at typedactors.

 On Tuesday, 27 January 2015 09:29:43 UTC, Jabbar Azam wrote: 

 Hello, 

 How do I send a message from java non actor based code into an actor 
 system? The code will be running on the same node and will be part of the 
 same source code. So netty will be running, receiving packets, which will 
 send any received packets into an actor system. The actor system will 
 process the packets and then send the response payload back to the netty 
 code.


   --
  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 User List group.
 To unsubscribe from this group and stop receiving emails from 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.


 -- 
 Björn Antonsson
 Typesafe http://typesafe.com/ – Reactive Apps on the JVM
 twitter: @bantonsson http://twitter.com/#!/bantonsson



-- 
  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 
User List group.
To unsubscribe from 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.


[akka-user] Re: Send message from netty code to actor system

2015-02-02 Thread Ngoc Dao
You can try Xitrum web framework (scroll down to see the Akka actor 
example):
http://xitrum-framework.github.io/


On Tuesday, January 27, 2015 at 6:29:43 PM UTC+9, Jabbar Azam wrote:

 Hello,

 How do I send a message from java non actor based code into an actor 
 system? The code will be running on the same node and will be part of the 
 same source code. So netty will be running, receiving packets, which will 
 send any received packets into an actor system. The actor system will 
 process the packets and then send the response payload back to the netty 
 code.




-- 
  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 
User List group.
To unsubscribe from 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.


[akka-user] Re: How to identify that akka cluster has formed?

2015-01-22 Thread Ngoc Dao
You can try Glokka:
https://github.com/xitrum-framework/glokka

It let you name your actors in a cluster, then get the actors back by name.


On Monday, January 5, 2015 at 7:36:58 PM UTC+9, Krishna Kadam wrote:

 Hi patrik,

 I am doing a masters project in which I have streaming data and want to 
 send a particular type of message to the same actor every time, so that 
 certain type of messages are processed by akka actors in their arrival 
 order. Also I want to deploy these actors on multiple machines for 
 execution purpose. Can I scale this process by deploying it to multiple 
 nodes? also Can I have better performance by deploying single actor system 
 to multiple nodes for execution?
  

 Thanks  Regards
 Krishna Kadam



-- 
  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 
User List group.
To unsubscribe from 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.


[akka-user] Re: Distributed cache with Akka

2015-01-20 Thread Ngoc Dao
Not related to Akka, but you should try Hazelcast:
http://hazelcast.org/

Hazelcast is designed for this problem.

There's code and data in your program.
If you want to distribute code = use Akka,
if you want to distribute data = use Hazelcast.


On Tuesday, January 20, 2015 at 10:42:09 AM UTC+9, as...@indexia.co wrote:

 Hey,

 I'm trying to build a small akka app that supports authentication via 
 tokens,

 What would be the simplest approach to store user tokens in a distributed 
 map cache for all akka nodes 
 as I can't guarantee that users will be served by the same akka node,


 Thanks.


-- 
  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 
User List group.
To unsubscribe from 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.


Re: [akka-user] Akka 2.3.2 Released

2014-04-22 Thread Ngoc Dao
 I am missing akka-testkit 2.3.2 for Scala 2.11 from maven central.

Hi, can you release akka-cluster for Scala 2.11 too?

-- 
  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 
User List group.
To unsubscribe from 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.