Re: [akka-user] Akka actor as mailer and message attachments

On 04/19/15 13:38, Erol Merdanović wrote: Hi I have created a simple NotificationActor which receives 2 types of message: EmailMessage and MobileTextMessage. Main goal of the actor is to call the external services and send an email or text message. Everything works, but now I want to handle

Re: [akka-user] Using Spray and Akka to Connect to CouchDB

Hi, Thanks for your response. I want to query a couchDB using REST. However, i want to put the business logic of doing so in Actors(Akka) instead of Play models. The Actors will perform the request and also receive the response from the database. The Actors can then forward the results to Play

Re: [akka-user] how to do unit test with persistence Actor

Thank you very much On Monday, April 20, 2015 at 3:04:11 AM UTC+3, Dragisa Krsmanovic wrote: > > Your test starts two actor systems, one for TestKit named "testCart" and > one that you spin up manually with > ActorSystem("ShoppingCartTestSpec-system"). All assertions for Akka TestKit > are for

[akka-user] akka cluster MemberEvent when Member becomes reachable again

Hi, When the failure detector detects that a member is not reachable it sends the MemberUnreachable event to the listeners. I see that there is no corresponding MemberReachable event. If I have an actor that needs to do something useful on detecting the reachability of a member what should I

Re: [akka-user] Akka Persistence - Views with multiple processors

Cool - thanks for validation and tips. Andrew On Tuesday, 14 April 2015 09:20:09 UTC+1, Patrik Nordwall wrote: > > Hi Andrew, > > I think your reasoning is correct. A way to implement the de-duping (if db > operations are not idempotent by themselves) is to save the sequence number > in the ext

[akka-user] Re: Spark without hadoop

Answers inline below. On Sunday, April 19, 2015 at 4:04:15 AM UTC-5, tomerneeraj wrote: > > Hi, > > We would like to use spark without Hadoop. To use it in highly scalable > and high availability mode, yarn and hdfs Api do the purpose of resource > scheduling and shared storage. We have data st

[akka-user] Re: Spark without hadoop

Hi Tomer, 1. Have you looked into Apache Mesos ? 2. What is your streaming data source ? Is it Kafka ? Cheers, -- FG On Sunday, April 19, 2015 at 11:04:15 AM UTC+2, tomerneeraj wrote: > > Hi, > > We would like to use spark without Hadoop. To use it in highly scalable > and high availability

Re: [akka-user] Question about the java "Cluster Router Example of Group of Routees"

On Sat, Apr 18, 2015 at 1:43 PM, wrote: > I am referring to the Sample "Router Example of Group of Routees" on > http://doc.akka.io/docs/akka/2.3.9/java/cluster-usage.html > > In the router config there is the following config: > > routees.paths = ["/user/statsWorker"] > > This means to me that

Re: [akka-user] Serialization: Prioritize custom over built in?

On Fri, Apr 17, 2015 at 8:23 PM, Russell Cohen wrote: > I recently ran into a pretty surprising behavior in akka serialization -- > if your parent class does *not* inherit from java.io.Serializable, akka > will choose arbitrarily between the two! This "feature" is documented >

Re: [akka-user] Re: PubSub and lost (?) messages

On Thu, Apr 16, 2015 at 4:59 PM, Eugene Dzhurinsky wrote: > After I got some more time for investigation, things became clear: > > First of all, when I run my test on slow machine, when the test fails - I > can see the following dead messages in logs: > > 2015-04-16 10:46:01,464 INFO > [RemoteAct

Re: [akka-user] one node within many clusters

An ActorSystem can only belong to one cluster. What you can do is to start two actor systems in the same JVM. Join one to n1 and the other to n3, and then bridge the communication with messages between actors in those two actor systems. /Patrik On Thu, Apr 16, 2015 at 2:21 PM, Brian Silberbauer <

Re: [akka-user] Using Spray and Akka to Connect to CouchDB

If the CouchDB API is HTTP based you can use an async http client, such as the Spray HTTP client, Akka HTTP client or Play WS API, and convert the responses to actor messages if you want to process the result in actors. Perhaps I misunderstand the question completely? /Patrik On Thu, Apr 16, 2015

Re: [akka-user] Understanding Paxos using Scala and Akka Actors

Thanks for sharing! /Patrik On Sun, Apr 5, 2015 at 11:12 PM, Ashish Hanwadikar wrote: > Wrote a blog post on implementing Paxos using Akka actors > : > > https://www.linkedin.com/pulse/

Re: [akka-user] Akka Http websocket: RC1?

Hi Giovanni, the current plan is to have at least server-side support for websockets in 1.0-RC1 with client-side support following soon thereafter. Regards, Roland > 19 apr 2015 kl. 23:50 skrev Giovanni Alberto Caporaletti > : > > Hi, I just wanted to ask the team a quick update on the webso

[akka-user] Re: Akka HTTP authentication

def auth = HttpBasicAuthenticator.provideUserName { case p @ UserCredentials.Provided(name) ⇒ p.verifySecret(name + "-password") case _ ⇒ false } path("secure") { HttpBasicAuthentication("My very secure site")(auth) { user ⇒ complete(HttpResponse(