Hi there,
Apologies if this question has been asked elsewhere, and if I'm not correct
in my thought process.
I was looking around for a ConcurrentMultiMap implementation and came
across the one in akka after searching.
The implementation I'm referencing is the following:
-
https://github.
On 13.01.14 15:26, Vadim Bobrov wrote:
There are numerous ways (impl options) for resending messages.
Using a channel is only one.
Other than persistent channel what are the options?
In akka-persistence, channels are the only option, outside
akka-persistence, anything that can store
We've had some recent "production issues" and it looks like this is the
exact issue biting us; (this results in a need to restart our appservers
rather periodically.)
The app is on akka 2.1.4.
I scanned the akka 2.1.x to 2.2.x migration guide a while ago (and also
just now), and it didn't seem
On Tue, Jan 14, 2014 at 1:50 AM, Hanumesh Mekala wrote:
> I also have the Similar problem, still unresolved.
> Initially, I have developed a test framework, which makes a https requests
> with multiple test data.
>
> Everything works fine with JDK1.6_43. But now I installed JDK1.7_45. When
> I ran
I also have the Similar problem, still unresolved.
Initially, I have developed a test framework, which makes a https requests
with multiple test data.
Everything works fine with JDK1.6_43. But now I installed JDK1.7_45. When I
ran the test framework now, the tests failed as some point, though it
Yes
On Jan 13, 2014 10:04 PM, "vijay krishna"
wrote:
> I see what you mean, its the code in my custom serializer that should
> handle it and has nothing to do at the application.conf level right?
>
> --
> >> Read the docs: http://akka.io/docs/
> >> Check the FAQ: http://
I see what you mean, its the code in my custom serializer that should handle it
and has nothing to do at the application.conf level right?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ: http://akka.io/faq/
>> Search the archives: https://groups
Hi Ryan -
Why do you deploy the actors rather than starting up the actors on the
worker nodes and having them register with the master from there? Is it
to keep a proper supervision hierarchy?
Thanks,
On Saturday, January 11, 2014 5:00:49 PM UTC-5, Ryan Tanner wrote:
>
> Eric,
>
> We give e
I guess that is a question for the guy who wrote the custom serializer..
Cheers,
√
On Mon, Jan 13, 2014 at 8:26 PM, vijay krishna wrote:
> I meant to say register a new class without stopping the actor system.
>
> --
> >> Read the docs: http://akka.io/docs/
> >> Check
I meant to say register a new class without stopping the actor system.
--
>> 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 y
I startup an actor system with a custom serializer and certain number of
classes registered with the serializer.
Now while the actor system is up and running is it possible to register new
classes with the seriaizer with stopping it?
--
>> Read the docs: http://akka.io/docs/
I still feel like it's somewhat ambiguous in a remoting context, because there
is not a one-to-one relationship, but the only remaining issue I really have is
that there seems to be no way of preventing a fair amount of scary logs on the
server when the client process exits:
[INFO] [01/10/2014
Interesting!
What unbounded mailbox impl did you use?
On Mon, Jan 13, 2014 at 5:36 PM, Igor Konev wrote:
> Hi Jonas,
>
> I used a modified version of the Akka throughput performance benchmark. It
> was necessary to configure each group of actors with different mailbox
> types. DisruptorMailbox
Hi Jonas,
I used a modified version of the Akka throughput performance benchmark. It
was necessary to configure each group of actors with different mailbox
types. DisruptorMailbox is a bounded mailbox type and if every actor had
used only it, this would have caused a deadlock. The destination a
Andy, I just realized I failed to thank you for the suggestion. Thanks! :)
It didn't work for me though, apparently because of the difference in
versions (leveldbutil refused to understand my database format). My leveldb
is whatever is installed by default on Ubuntu/CentOS and I have yet to
fig
> There are numerous ways (impl options) for resending messages. Using a
> channel is only one.
>
Other than persistent channel what are the options? I actually believe it is
important to note in the documentation that messages in mailbox are not
preserved by a processor, it was not obviou
how do you run the LevelDB journal, with native = on or off? Please note
> that native = off (LevelDB Java port) is only for testing purposes and
> doesn't do data compression. With the native LevelDB journal I end up
> with 40M disk space after 1M messages and 200M and 5M messages (whereas
>
It's ReactiveMongo that can't handle Akka 2.3 (since it is incompatible
with 2.2)
On Mon, Jan 13, 2014 at 3:01 PM, Sandeep Singh wrote:
> Tried but same error
> "org.reactivemongo" %% "reactivemongo" % "0.10.0" excludeAll(
> ExclusionRule(organization = "com.typesafe"))
>
> On Monday, Januar
Tried but same error
"org.reactivemongo" %% "reactivemongo" % "0.10.0" excludeAll(
ExclusionRule(organization = "com.typesafe"))
On Monday, January 13, 2014 7:19:53 PM UTC+5:30, Sandeep Singh wrote:
>
> Yupp saw that but can't change my version, i need some features from
> 2.3-M2, is there a
Ask if the reactive mongo guys have aversion released against 2.3-M2
Cheers,
√
On Mon, Jan 13, 2014 at 2:49 PM, Sandeep Singh wrote:
> Yupp saw that but can't change my version, i need some features from
> 2.3-M2, is there a way around this ?
>
> On Monday, January 13, 2014 7:09:08 PM UTC+5:30,
Yupp saw that but can't change my version, i need some features from
2.3-M2, is there a way around this ?
On Monday, January 13, 2014 7:09:08 PM UTC+5:30, √ wrote:
>
> ReactiveMongo uses another version of Akka which is not compatible with
> the version you are using:
>
> https://github.com/Reac
ReactiveMongo uses another version of Akka which is not compatible with the
version you are using:
https://github.com/ReactiveMongo/ReactiveMongo/blob/master/project/ReactiveMongo.scala#L124
Cheers,
√
On Mon, Jan 13, 2014 at 2:11 PM, Sandeep Singh wrote:
> I'm using sbt,
> Here's my build.sbt
>
I'm using sbt,
Here's my build.sbt
name := "Steelix"
scalaVersion := "2.10.3"
resolvers ++= Seq(
"Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/";,
"spray repo" at "http://repo.spray.io";
)
libraryDependencies ++= Seq(
"com.typesafe.akka" %% "akka-actor" % "2.3-M2",
"com.
Thanks Alec! I will do it like that.
Markus
Alec Zorab schrieb am 13:44 Montag, 13.Januar 2014:
That's certainly how I tend to do it. We use the same thing for injecting
configs, dbs etc. Almost anything that you want to be a "singleton" but you
need to be able to swap in different impleme
That's certainly how I tend to do it. We use the same thing for injecting
configs, dbs etc. Almost anything that you want to be a "singleton" but you
need to be able to swap in different implementations for testing, etc.
On 13 January 2014 12:39, Markus Jais wrote:
> Hi Alec,
>
> thanks. That l
Hi Alec,
thanks. That looks great.
Would it make sense to hide the extension in a trait and use it as a mixin?
Meaning, the trait could have the code like:
counter = CountExtension(context.system)
and in my Actor I only have some like:
class MyActor with Counting {
counter.increment()
}
Ma
On Mon, Jan 13, 2014 at 11:52 AM, Roger Alsing wrote:
> I'm trying to understand why the fork join pool scales better than the
> thread pool.
>
LMGTFY? :)
https://www.google.com/search?q=akka+scale+ForkJoinPool&oq=akka+scale+ForkJoinPool
> My understanding is that FJP can partition tasks into
Akka will never throw an AbstractMethodError, something is wrong with your
classpath.
Cheers,
√
On Mon, Jan 13, 2014 at 11:39 AM, Sandeep Singh wrote:
> My whole actor code
>
> class Getter(url: String, depth: Int, id: ActorRef) extends Actor {
>
> implicit val executor = context.dispatcher.a
I'm trying to understand why the fork join pool scales better than the
thread pool.
My understanding is that FJP can partition tasks into subtasks to optimize
the work done on the underlying threads.
How does this affect the mailboxes in Akka?
Since a given mailbox can only process one message a
My whole actor code
class Getter(url: String, depth: Int, id: ActorRef) extends Actor {
implicit val executor = context.dispatcher.asInstanceOf[Executor with
ExecutionContext]
def client: WebClient = AsyncWebClient
client get url pipeTo self
def receive = {
case body: String =>
Hi,
The log output says that it fails creating an actor.
There is just to much missing from you code and the logs to say anything more
useful. Could you please provide more information?
B/
On Monday, 13 January 2014 at 09:28, sand...@techaddict.me wrote:
> I wrote this code this is a recie
Thanks!
Yes, nice idea. I will try it, mentioning the source.
And nice to see .actorOf. I'm using .actorOf(type, or .actorOf(actor.
Ummm... I was thinking of extending the Akka ideas to
typedref = system.typedActorOf where T is any classical type.
And then
typedref.Post(Action)
that is
type
Use an akka extension:
http://doc.akka.io/docs/akka/2.2.3/scala/extending-akka.html
On 13 January 2014 10:15, Markus Jais wrote:
> Hello,
>
> I need to integrate a Java library that is used to collects lot's of
> runtime information about errors, failures, etc.
> It has many data collectors. T
Hello,
I need to integrate a Java library that is used to collects lot's of runtime
information about errors, failures, etc.
It has many data collectors. There may be better ways to do this but I need to
use this library for current projects.
The collectors should exist once per JVM (we are not
I wrote this code this is a recieve function of an actor,
def receive = {
case body: String =>
import reactivemongo.api.MongoDriver
import reactivemongo.api.collections.default._
import reactivemongo.api._
import reactivemongo.bson._
import scala.concurrent.
Nice to see others playing with Akka like actors on .NET.
You can have a look at my take if you want:
https://github.com/rogeralsing/Pigeon
I set the actorcontext in a thread local when a given actor is active, this
gives me access to implicit sender.
//Roger
Den söndagen den 12:e januari 2014
36 matches
Mail list logo
