Hi, sorry but even after some small changes I'm still stuck with the
problem, tried with Akka-2.2.4, 2.2.5, 2.3.9 .
>From local actor system all works good.
I don't really understand the error when using remote actor with
actorSelection:
[ERROR] [03/09/2015 18:33:44.918]
[RemoteActorSystem-akk
Hi,
I'm testing the akka http routing DSL
(
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M4/scala/http/routing.html
)
I am quite surprised that I need an ExecutionContext to use an implicit
marshaller (ToResponseMarshallable).
It makes the code quite complicated for a very simple
We will release 1.0 as soon as possible, but not earlier. We will continue
to release frequent milestones until we reach release candidate quality. We
don't have an estimate of how long that will take, but I guess it is in the
magnitude of a few months.
Regards,
Patrik
On Mon, Mar 9, 2015 at 6:48
Hi,
Thanks for your response. Let me (try to) clarify my questions.
I guess I oversimplified my example so it, so I'll try again. I have an
actor (persistent with at-least-once-delivery), and I want it to process
messages "immediately" upon arrival. That is, I don't want to wait for the
persis
Hi George,
I think you will find the answer here:
http://doc.akka.io/docs/akka/2.3.9/java/routing.html#Supervision
Regards,
Patrik
On Mon, Feb 23, 2015 at 1:56 PM, George Lu wrote:
> Dear all,
>
> For learning Akka, I wrote below in Java to test fault-tolerance.
> I have a master actor to assi
Supervision hierarchy is about how to handle failures.
Perhaps setup a pipeline of these actors. Use a parent actor that creates
the other processing actors, with forward references to the next actor in
the chain, i.e. Actor1 takes the ActorRef of Actor2 as constructor
parameter.
Note that this s
Hi George,
I don't fully understand the problem. Perhaps you don't mean integration
test, but unit test with router and listener stubbed out?
/Patrik
On Wed, Mar 4, 2015 at 2:07 PM, George Lu wrote:
> Hi all,
>
> I have an actor which in the constructor creates a router actor which
> creates s
On Wed, Mar 4, 2015 at 11:57 PM, Steve Ramage wrote:
> I'm writing a task dispatching system for scientific data collection on
> timesharing clusters. There is a specific API for submission of tasks and a
> few implementations one of which does the data collection locally, another
> to a MySQL Se
Hello.
We did tests with akka cluster and Unreachable / Reachable state and
discovered the following reproducible behaviour, which might be a problem -
but still unsure :-)
== Environment: ==
- Could be reproduced with 2.3.7 as well as with 2.3.9
- Cluster with 4 nodes, seed nodes = 1,2
On Tue, Mar 10, 2015 at 11:36 AM, Tal Pressman wrote:
> Hi,
>
> Thanks for your response. Let me (try to) clarify my questions.
>
> I guess I oversimplified my example so it, so I'll try again. I have an
> actor (persistent with at-least-once-delivery), and I want it to process
> messages "immedi
On Mon, Mar 9, 2015 at 10:52 PM, wrote:
> How can one pass a list of BigDecimal to an Actor to process efficiently?
> I ask this because Actors should only be sent short messages.
> What if you have a List of 1 million BigDecimal? How is this done with a
> local actor? Remote Actor? I would like
Hi Michael,
On Tue, Mar 10, 2015 at 1:15 PM, michaels wrote:
> Hello.
>
> We did tests with akka cluster and Unreachable / Reachable state and
> discovered the following reproducible behaviour, which might be a problem -
> but still unsure :-)
>
> == Environment: ==
> - Could be reproduc
Hi!
And sorry for the late reply. We discussed this at LambdaDays with Konrad,
it's only normal this doesn't work. I'm exploring other alternatives for
simulating the change in the most lazy possible manner.
A quick clarification: I'm working on a reservation system, and quite a
number of events
Hi Sandro,
This looks bad:
[ERROR] [03/04/2015 19:04:36.647]
[RemoteActorSystem-akka.actor.default-dispatcher-2]
[akka://RemoteActorSystem/system/endpointManager/reliableEnd
pointWriter-akka.tcp%3A%2F%2FRemoteActorSystem-Client%40127.0.0.1%3A63830-0/
endpointWriter] changing Recreate into Create a
I answer to myself: for this, I can use pathPrefix.
It'd be great if composing path would work, or would not compile, forcing
to use pathPrefix for this.
Le mar. 10 mars 2015 à 11:55, Yann Simon a écrit :
> Hi,
>
> when I combine path together, the resource is never found:
> path("v2.0" /
Hi,
when I combine path together, the resource is never found:
path("v2.0" / "tokens") {
post {
complete("it works")
}
}
path("v2.0") {
path("tokens") {
post {
complete("it does not work")
}
}
}
Am I missing something?
Cheers, Yann
--
Hello,
I am currently experimenting with Akka-http on one of our modules. *Below
(or attached) is my current CORS file for spray*. I am struggling with
conversion, for e.g.: I cant find alternative to mapRequestContext. Can any
help me to rewrite/convert this please. So I can use this with akka
Hello Patrik,
added the output of ClusterStatus below,
> == Test Steps: ==
>> 1.) Start 4 JVMs (all on local host) - Nodes form a cluster - Leader = 1
>> - same information on all nodes (VisualVM MBean akka.cluster)
>> 2.) With Sys-Internal Process Explorer Suspend Process of Node 1
>
In terms of engines supporting. Event Store as an example supports
transactions between multiple requests that could support exactly this.
eg
begin transaction
write
write
write
write
commit / rollback
and it can be between multiple actors so long as the transaction id is
shared between them. Th
On Tue, Mar 10, 2015 at 3:03 PM, Manuel Bernhardt <
bernhardt.man...@gmail.com> wrote:
> Hi!
>
> And sorry for the late reply. We discussed this at LambdaDays with Konrad,
> it's only normal this doesn't work. I'm exploring other alternatives for
> simulating the change in the most lazy possible m
You're missing the route concatenation operator ~ between the two Path
directives.
--
>> 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.googl
Hi,
I am not sure where is the right place to put this , but after banging my
head against the wall trying to figure out why my tests are not working is
expected, I thought it's worth sharing.
I have noticed that my test pass with this assertion
expectMsgType[HttpResponse].status === StatusCode
What was puzzling me was:
Cluster Node [akka.tcp://...Node4...] - Marking node(s) as REACHABLE
[Member(address = akka.tcp://Node1..., status = Up)]
but looking at the code revealed that this is only an notification that
Node4 thinks that Node1 is reachable again. The ReachableMember event is
f
Hi Patrik,
thanks for the info ... I tried your suggestion both with Akka-2.2.5 and
2.3.9 but I still have some error, this is the log from 2.3.9:
remote actor lookup using actor selection
Get Actor Selection to greetingActor:
ActorSelection[Anchor(akka.tcp://RemoteActorSystem@127.0.0.1:2552/),
Do you mean, instead of:
path("v2.0") {
path("tokens") {
post {
complete("it does not work")
}
}
}
writing:
path("v2.0") ~
path("tokens") {
post {
complete("it does not work")
}
}
This does not compile AFAIK.
Le mar. 10 mars 2015 à 15:59,
Hi,
by using:
import akka.http.marshallers.sprayjson.SprayJsonSupport._
import spray.json.DefaultJsonProtocol._
I can complete a http response with complete(ast) and the ast value is
marshalled into JSON.
This response is default with the HTTP code OK.
I'd like the change the HTTP code to Create
Hi Yann,
There is an implicit conversion from a status code & entity tuple, thus
this should work:
complete(Created -> ast)
Similarly you can provide a Tuple3 with status code, response headers and
entity.
Agree that the current API doesn't make this obvious.
Mark
On Tuesday, March 10, 20
This thread may help:
https://groups.google.com/forum/#!searchin/akka-user/cors/akka-user/msJfSkHDCxA/foDrnQPBx2gJ
I've not got around to looking at it yet.
On Tuesday, March 10, 2015 at 2:14:53 PM UTC, Ganta Murali Krishna wrote:
>
> Hello,
>
> I am currently experimenting with Akka-http on one
Thanks for the update!
/Patrik
On Tue, Mar 10, 2015 at 5:56 PM, ankit master
wrote:
> Found the solution, just in case anyone gets in the same spot as I was
> earlier, the problem is with the incompatibility between zmq 2.2 and zmq
> 4.0.4, although zmq website advertises zmq latest version stat
Have you followed all of the instructions for interacting with remote
actors here: http://doc.akka.io/docs/akka/2.3.9/scala/remoting.html ?
>From the error it appears to me that:
1. You are attempting to create a remote actor from a peer
2. This peer isn't able to properly interact with [akka.tcp
Hi All,
this question about design, for example now I have some process that load
task list and try process each task, it looks like this:
import scala.concurrent.{ExecutionContext, Future}
case class TaskId(processorName: String, id: String)
case class TaskDetails(id: TaskId, status: String,
31 matches
Mail list logo
