Hi Robert,
I made an activator template
http://typesafe.com/activator/template/play-akka-cluster-sample for this.
The main point is that your play application
joins the overall akka cluster. You must take care of the linking, what
should be done
locally and what not.
activator new
Hi Johannes,
On 9 December 2014 at 15:29:53, Johannes Berg (jberg...@gmail.com) wrote:
Hi! I'm doing some load tests in our system and getting problems that some of
my nodes are marked as unreachable even though the processes are up. I'm seeing
it going a few times from reachable to
Hi,
Yes you are right that groupBy is probably not a good solution. The incoming
connections have already been acepted and if you throttle them by delaying the
decision about what to do with them, then you are vulnerable to a DOS attack.
Also you are right that substreams that you cancel will
Value classes don’t exist in the runtime in the constructor argument - see
https://github.com/akka/akka/issues/16444 for why this is not really
solvable using reflection. I don’t think we’re able to solve this (without
forcing some marker traits etc, which we’d like to avoid).
I think you could
Hi,
Actor deployment configuration can only have wildcards for complete sections,
like for example /actorFoo/*/actorBar. It's described in the documentation
here:
http://doc.akka.io/docs/akka/2.3.7/general/configuration.html#Actor_Deployment_Configuration
Do you have to have a UUID in actor
Hi,
That class is not in that package in the current akka codebase. Which version
of akka and Scala are you using?
I would try to get started by using Activator and one of the activator
templates for remoting:
http://typesafe.com/activator/template/akka-sample-remote-scala
I prefer the method os sending a stopping message to oneself, then if you
receive no other message between when you sent it and you received it, you
drained you mailbox. (there's still messages that could be queued behind
it, but that's life.)
On Thu, Dec 11, 2014 at 2:13 AM, Richard Rodseth
Hi Krishna,
is there something in the documentation that doesn't work for you and if
so, what?
http://doc.akka.io/docs/akka/2.3.7/scala/remoting.html
On Thu, Dec 11, 2014 at 5:28 AM, Krishna Kadam shrikrishna.kad...@gmail.com
wrote:
Hi,
This might be a stupid question, I am creating remote
Hello,
I'm migrating to the latest streams, the new client-server stream tcp flow
does require some mind-bending (switching from req-response to a flow both
on the client and the server), but I got it working except one thing I
don't like.
I have a client (Sender) which sends out messages to
Seems I forgot to actually write the title, sorry ;) It should be sth like
No-element never-completed source
Adam
On Thursday, December 11, 2014 11:33:42 AM UTC+1, Adam Warski wrote:
Hello,
I'm migrating to the latest streams, the new client-server stream tcp flow
does require some
Hi Johannes,
It seems like there is a mismatch here. The only way that I can find is to use
the Java API like this
respondWithHeaders(akka.http.model.japi.headers.ContentType.create(ContentType(`text/html`)))
I've opened a ticket here https://github.com/akka/akka/issues/16523
B/
On 10
Hi,
From your logs you see that you have a connection failure. It says connection
timed out this looks exactly like 16505.
Why your remote machine behaves badly I can't know. You should definitley
monitor your machine and JVM to see what it is doing.
B/
On 10 December 2014 at 16:34:22, Jason
Hi again Johannes,
Mathias was kind enough to educate me in the ticket that the
respondWithMediaType way of doing things has been removed since it was
considered an antipattern and you should now use the Marshalling infrastrucutre
instead to acheive the same results.
Please take a look at
Hi Björn,
thanks for the reply; however, although this solution compiles, I get a
runtime warning:
Explicitly set HTTP header 'Content-Type: text/html' is ignored, explicit
`Content-Type` header is not allowed.
Set `HttpResponse.entity.contentType` instead.
-- Johannes
On Thursday, December
Thank Bjorn,
My question is this:
Consider:
package com.admarketplace.amqp
import akka.actor.{Props, ActorSystem, ActorRef, Actor}
import com.admarketplace.amqp.Circular.{Finish, Msg}
class ActorC(actorL:ActorRef) extends Actor{
def receive = {
case msg@Msg(id) =
println(
Hello, everyone!
I'm using akka.io 2.3.7 and I don't see any SSL/TLS support there.
As far as I understand it was removed (since 2.3.x). Is it correct?
Why? Will come back?
And... Is there a clean workaround?
May be this topic was discussed before, but I didn't find an appropriate
link.
On 11 Dec 2014, at 16:07, henry.st...@bblfish.net wrote:
On 11 Dec 2014, at 14:33, pa...@blackopsdev.com
mailto:pa...@blackopsdev.com wrote:
Hello, everyone!
I'm using akka.io 2.3.7 and I don't see any SSL/TLS support there.
As far as I understand it was removed (since 2.3.x). Is it
I'm seeing a disturbing trend when switching data processing flows to use
Akka streams; in one real ETL project, I saw 5 times the CPU usage with no
0 serial-execution speedup. In a simple example, I'm seeing, literally, 99%
Self-Time spent in ForkJoinPool functions:
Machine has a single quad-core, hypther-threaded processor. This is a
screen-grab of the thread activity:
http://screencast.com/t/ofQCund9JCq
I think it is switching threads far too frequently. I'm experimenting with
ways to tune these settings and get better performance.
--
Read the
In my experience if most of your time is in scan, it means that you are
running too high parallelism on your FJP—it is workers looking for work.
On Thu, Dec 11, 2014 at 10:01 PM, Tim Harper timchar...@gmail.com wrote:
Machine has a single quad-core, hypther-threaded processor. This is a
Hello!
I have an FSM actor. which takes a number of references to worker actors
in it's constructor. That works very well if there's a single actor system.
Now I want to create another worker actor *in the cluster* and get a
reference to this actor in the FSM actor *outside of the cluster*, so
21 matches
Mail list logo
