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

[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

[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  – Reactive Apps on the JVM
 twitter: @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

[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?

[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

[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] WebSocket + AKKA + Redis pub/sub

[Ngoc Dao]

The original question about WebSocket + Akka + Redis was 2 years ago.

Now, you don't need Redis any more, because:
* Akka is already very good at messaging.
* Recent versions of Akka have clustering feature: 
http://doc.akka.io/docs/akka/2.3.5/scala/cluster-usage.html

In short, you only need WebSocket + Akka.
To easily work with multiple messaging channels (like multiple chat rooms) 
in a cluster, you can also use this library:
https://github.com/xitrum-framework/glokka

Simple chat example that can run in a cluster:
http://107.167.187.67/websocketChatDemo


On Wednesday, August 20, 2014 12:38:53 AM UTC+9, gitted wrote:
>
> This seems like a fairly common pattern/problem domain that people will be 
> facing when they want to incorporate real-time updates on websites.
>
> Is there anything open source that can help guide me on how to implement 
> this?  I was thinking of using redis also but rabbitmq would be very 
> similiar just the backing queue is different.
>
> On Monday, September 3, 2012 12:10:45 PM UTC-4, Jeremy Pierre wrote:
>>
>> Apologies, I should have jumped in earlier - my team and I are using 
>> websockets via Netty in Akka 2.0.x with RabbitMQ.  Looks like Redis 
>> pub/sub is a bit simpler but maybe I can help. 
>>
>> Can't give a lot of details about what specifically we're working on 
>> but if you have general questions about setup/approach I'll do my 
>> best. 
>>
>> Jeremy 
>>
>> On Mon, Sep 3, 2012 at 5:21 AM, Viktor Klang  
>> wrote: 
>> > Hi Jason, 
>> > 
>> > Apparently no one wants to admit to have done that :-) 
>> > 
>> > Cheers, 
>> > √ 
>> > 
>> > On Tue, Aug 21, 2012 at 12:36 PM, Jason  wrote: 
>> >> I wonder know if anyone have tried to use websocket to send message to 
>> Redis 
>> >> pub/sub? 
>> >> 
>> >> 
>> >> -- 
>>  Read the docs: http://akka.io/docs/ 
>>  Check the FAQ: http://akka.io/faq/ 
>>  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 post to this group, send email to akka...@googlegroups.com. 
>> >> To unsubscribe from this group, send email to 
>> >> akka-user+...@googlegroups.com. 
>> >> Visit this group at http://groups.google.com/group/akka-user?hl=en. 
>> >> 
>> >> 
>> > 
>> > -- 
>> >>>  Read the docs: http://akka.io/docs/ 
>> >>>  Check the FAQ: http://akka.io/faq/ 
>> >>>  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 post to this group, send email to akka...@googlegroups.com. 
>> > To unsubscribe from this group, send email to 
>> akka-user+...@googlegroups.com. 
>> > Visit this group at http://groups.google.com/group/akka-user?hl=en. 
>> > 
>> > 
>>
>

-- 
>>  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

[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.

[akka-user] Re: Akka 2.3.1 Released

[Ngoc Dao]

Hi,
where can I find more info about "Proxy for ClusterSingletons (by Giovanni 
Botta)"?

On Wednesday, March 26, 2014 4:53:11 AM UTC+9, Akka Team wrote:
>
> *Dear hAkkers,*
>
> We—the Akka committers—are pleased to be able to announce the availability 
> of Akka 2.3.1. This is the first maintenance release of the 2.3 branch, 
> containing documentation improvements and fixing several issues including:
>
>- Simplified receive definition and support for supervision strategies 
>for Java 8 
>- Support for receiving ConfirmablePersistent messages and using 
>become() during recovery in EventSourcedProcessor
>- Prevent possible actor leaks during repeated remote deployment after 
>restart
>- More robust failure handling in cluster sharding 
>- Prevent Quarantine state being lost
>- Proxy for ClusterSingletons (by Giovanni Botta)
>- Ability to use an external Camel context (by Thibaut Robert)
>
> This release is backwards binary compatible with version 2.3.0 which means 
> that the new JARs are a drop-in replacement for the old one (but not the 
> other way around) as long as your build does not enable the inliner 
> (Scala-only restriction). Always make sure to use at least the latest 
> version required by any of your project’s dependencies.
> Migrating from Older Relases
>
> When migrating an existing project from Akka 2.2.x please have a look at 
> our migration 
> guide
> .
> 2.3.1 compared to 2.3.0:
>
>- 21 tickets closed
>- 199 files changed, 5753 insertions(+), 2058 deletions(-) 
>- ... and a total of 6 committers!
>
> *Full list of fixed tickets:*
>
>- *2556*, Give AddressTerminated its own event bus 
>- *3843*, Cluster singleton proxy 
>- *3885*, Add the ability to use an external camel context 
>- *3907*, OSGi version range broken for Scala 2.11 
>- *3910*, Zip akka-sample-fsm-java-lambda 
>- *3911*, Add a Java 8 DirectiveBuilder 
>- *3912*, add akka-osgi structure change to 2.2->2.3 migration guide 
>- *3913*, setup mima on release-2.3 branch 
>- *3915*, Support become in EventsourcedProcessor during recovery 
>- *3917*, DOC: Include persistence reference.conf in docs 
>- *3924*, DOC: how to be notified when recovery completed 
>- *3925*, Create Java 8 version of supervision Activator emplate 
>- *3927*, allow Confirmable messages (from PersistentChannel) to be 
>sent to EventsourcedProcessor 
>- *3930*, repeated remote deployment leaks actors 
>- *3933*, Confirmed messages are delivered through channel when non 
>persistent and persistent msgs are responded to with the same channel. 
>- *3937*, ShardCoordinator doesn't handle persistence failure 
>- *3940*, Add sugar to AbstractActor for Java 8 for defining initial 
>receive 
>- *3941*, FAILED: SurviveNetworkInstability (left-over ping) 
>- *3943*, Gate should not overwrite quarantine 
>- *3948*, multi-node-tests: add startNewSystem() and shutdown(... 
>- *3949*, add state label support to LoggingReceive 
>
> Credits
>
> commits   added removed
>  11 681 284 Roland Kuhn
>   7 823 320 Patrik Nordwall
>   62337 519 Björn Antonsson
>   1 107   2 Endre Sándor Varga
>   1 440  34 Giovanni Botta
>   1  62   7 Thibaut Robert
>
> Additional Release Details
>
> The artifacts comprising this release have been published to 
> https://oss.sonatype.org/content/repositories/releases/ and also to Maven 
> Central. In addition, we adopted the sbt standard of encoding the Scala 
> binary version in the artifact name, i.e. the core actor package’s 
> artifactId is “akka-actor_2.10”.
>
> Website:
>
>- http://akka.io 
>
> Maven repository:
>
>- http://repo.akka.io/releases 
>
> Binary distribution:
>
>- http://akka.io/downloads/ 
>
> Documentation:
>
>- http://doc.akka.io/docs/akka/2.3.1/ 
>- http://doc.akka.io/api/akka/2.3.1/ 
>- http://doc.akka.io/japi/akka/2.3.1/ 
>
> Issue tracker:
>
>- http://www.assembla.com/spaces/akka/ 
>
> Mailing list:
>
>- https://groups.google.com/group/akka-user 
>
> Akka is released under the Apache V2 license.
>
> *Happy hAkking!*
>
>
> -- 
> Akka Team
> Typesafe - The software stack for applications that scale
> Blog: letitcrash.com
> Twitter: @akkateam
>  

-- 
>>  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