Hi,
Streams is compiled against Akka 2.3.x which is not guaranteed to be binary
compatible with 2.4. I expect that the above code to work with Akka 2.3.x.
(if not, then this is a bug)
-Endre
On Wed, Jan 7, 2015 at 4:40 AM, tigerfoot gzol...@gmail.com wrote:
Hello,
I've got this code:
def
*Awesome*. This is exactly the answer I was looking for, Ryan!
I need to read and re-read your post a couple more times for it to sink in,
but this seems like a great starting point. A blog article on this topic
would really be appreciated, though! :- )
I'm of the opinion that while Typesafe
Hi
I'm going to be calling some Java multi-threaded code that is currently
using JSR166Y (due to backward compatibility requirements with some legacy
java 6 code).
My Java developer wants to know if he should do a branch to use java7 (or
8) compatible fork join pool instead
The intention is I
Hi Tim,
is it using ForkJoinTask/RecursiveTask directly?
On Wed, Jan 7, 2015 at 12:23 PM, Tim Pigden tim.pig...@optrak.com wrote:
Hi
I'm going to be calling some Java multi-threaded code that is currently
using JSR166Y (due to backward compatibility requirements with some legacy
java 6
Hi all,
I have an actorNotFound problem on Spark 1.2.0 on mesos0.21.0
The full problem is described here:
http://apache-spark-user-list.1001560.n3.nabble.com/akka-actor-ActorNotFound-In-Spark-Streaming-on-Mesos-using-ssc-actorStream-tt21014.html
To sum up:
In local mode path is
Hi Viktor,
Ok sorry - I'm not an expert in these matters - apologies for the
vagueness. I'll do some homework and make him read the docs. Dispatcher
looks a good place to start.
--
Read the docs: http://akka.io/docs/
Check the FAQ:
hi - yes
On 7 January 2015 at 11:32, Viktor Klang viktor.kl...@gmail.com wrote:
Hi Tim,
is it using ForkJoinTask/RecursiveTask directly?
On Wed, Jan 7, 2015 at 12:23 PM, Tim Pigden tim.pig...@optrak.com wrote:
Hi
I'm going to be calling some Java multi-threaded code that is currently
Hmmm, I've reread your question a couple of times and I am not sure what
you are asking, is there something more specific your wonder? (I don't know
what goals you have)
On Wed, Jan 7, 2015 at 12:40 PM, Tim Pigden tim.pig...@optrak.com wrote:
hi - yes
On 7 January 2015 at 11:32, Viktor Klang
Hi Tim,
Akka fork-join-executor-based dispatchers uses Scala's embedded jsr166
version of FJ.
I don't think it lets you work with FJT though.
On Wed, Jan 7, 2015 at 1:16 PM, Tim Pigden tim.pig...@optrak.com wrote:
Hi Viktor,
Ok sorry - I'm not an expert in these matters - apologies for the
The issue of testing business functionality that may be implemented in the
class extending Actor has been raised quite a few times and I haven't found
any good suggestions yet. Most Actor testing examples are focused around
message receipt, type, timing etc. Akka team's response to this
post
Hey guys, is it possible to set custom header (User-Agent) for akka
streams
val connection = Http().outgoingConnection(someServer, 443)
val request:HttpRequest = RequestBuilding.Get(s/some/address.json)
//I want to add header here
//
Glad to help!
On Wednesday, January 7, 2015 3:53:28 AM UTC-7, Kane Rogers wrote:
*Awesome*. This is exactly the answer I was looking for, Ryan!
I need to read and re-read your post a couple more times for it to sink
in, but this seems like a great starting point. A blog article on this
wow thank you so much Will for this Feedback.
I already have a new version
(https://gist.github.com/Alien2150/9468c871135fd94869a2) that can deal with
multiple connections. I think i will embed your feedback and will come up
with a new version. Meanwhile i am struggling with another
issue:
Finally, as Henry mentioned earlier, the code here doesn't do any server
identity checks. If you're using HTTPS, then you should use
HostnameChecker directly or set setEndpointIdentificationAlgorithm(HTTPS)
directly -- otherwise, you may want to look at RFC 6125 for a generic
server identity
If the UserLinksActor is stateless you can use a router pool
http://doc.akka.io/docs/akka/2.3.8/scala/routing.html#Pool instead of
creating a new one each time. Then you can easily control the level of
parallelism.
/Patrik
PS. Akka.system.actorOf inside a future callback inside an actor is scary,
On Wed, Jan 7, 2015 at 6:32 AM, Muthukumaran Kothandaraman
muthu.kmk2...@gmail.com wrote:
Thanks Patrik.
By failure-zones, I mean to assign different dispatchers to different
combinations of topic + subscribers.
For example, Subscriber A and Subscriber B both handle messages from topic
C
Hi Thomas,
There's some things you should watch out for in your code:
* If you want to use TLS 1.2, you should specify getInstance(TLSv1.2)
specifically (JDK 1.7 defaults to TLS 1.0)
* You should disable SSLv3 (at the very least) using setEnabledProtocols().
* You are better off initializing
Hello,
I am experimenting with at-least-once-delivery in akka-persistence. My goal
is to create a future-based service layer on top of an actor system by
using AskSupport.
The deliver method in AtLeastOnceDelivery expects an ActorPath as its
message destination and delivers the message by
Hi,
i created a simple application
(https://gist.github.com/Alien2150/9468c871135fd94869a2) to play around
with the SSL-Stream. But as soon as my client has been closed I am seeing
this log-message (without receiving any OnComplete messages):
[INFO] [01/07/2015 14:12:53.549]
Hello,
I have a setup of 5 nodes running clustered using Akka Cluster (Akka 2.3.7)
and I am using a consistent-hashing router to spread the load among all
nodes. My consistent key is based on a String and I have verified that the
number of actors creating in the cluster is almost evenly
Hi,
I know how to do this now using the new akka-http core API, but how would
it work using the spray-like DSL?
How can I complete an http get using a Future[Source[ByteString]]?
import akka.http.model._
import akka.http.server._
...
def route: Route =
path(get) {
get {
21 matches
Mail list logo
