This is a good question for Lightbend staff. Remoting with artery is
entirely sufficient for what I am building. When start up I get warnings
not to use it but to use clustering instead.
I find this surprising because at the time of the warnings my use case is
not even known. My question is d
Hello,
I am building an application using Play 2.6 with Scala 2.12.3 and Akka
2.5.4 Actors.
I am using the ask pattern in several places at it is documented at link
below
https://www.playframework.com/documentation/2.6.x/ScalaAkka
The ask patten works well in all regartds except that I do not
Hello All,
I am making a Scala/Akka Actor based application.
It is necessary for me to query an actor from a controller.
The queried actor is always the same; only one of these exist.
>From the controller I am using the "ask' pattern to send a query message to
the actor.
The query message conta
Hello All,
I am working with some legacy Scala with Akka code.
The application.conf file makes use of substitutions.
Instead of receiving an automatic parse of the
application.conf file the code explicitly parses the file
and resolves the substitutions as thus:
val config_raw = ConfigFactory.
I have a Play Framework Scala application in development that stores long
lived ActorRefs in a mutable Map. When an actor is no longer needed it is
sent it a message that informs it to stop itself and it will.
My concern is about the visibility of stopped actors to JVM garbage
collection; espec
Hi,
I am getting an error I don't understand when I try to construct an
ActorSystem using Scala 2.12, Akka 2.5.4, Java 8. The error message is
*error com.typesafe.config.ConfigException$UnresolvedSubstitution:
reference.conf: 826: Could not resolve substitution to a value:
${akka.stream.mat
Hello to Akka Developers,
Can someone suggest to me a current compatible triad of java, scala, akka
versions and the urls of where the scala and akka jar files can be found.
I coded entirely in Scala. I used to have compatible jar files but have
not run things in while and apparently have c
the problem. I
never thought to debug a program that consistently produced correct output.
Thank you.
Joe
On Friday, June 2, 2017 at 3:51:49 PM UTC-4, Joseph Mansigian wrote:
>
> I have an application that uses remote addressing exclusively. The
> application is under development on
I have an application that uses remote addressing exclusively. The
application is under development on one local machine; one actor system
spanning several JVM. When I send a message the message always arrives at
its intended recipient actor and is processed. Program output verifies that
the a
e destination actor is running at the given path?
>
> You can enable more logging:
> http://doc.akka.io/docs/akka/2.5/scala/logging.html#Auxiliary_remote_logging_options
>
> /Patrik
> fre 14 apr. 2017 kl. 15:06 skrev Joseph Mansigian >:
>
>> When sending a mes
When sending a message to a remote actor I get an always repeatable failed
send with a dead letter being produced. The recipient actor is a remote
actor in a different JVM than the sending actor but both sender and
recipient are executing on the same machine. Both sender and recipient
actors
Hello hakkers,
I am getting a *repeatable* problem I do not understand with dead letters.
I believe it has to do with the dispatchers being used. I have not in any
explicit manner tried to select dispatcher(s). Here is a debug excerpt:
* * * * * * *
[DEBUG] [01/06/2017 10:26:54.526]
rse, but you can study the tests of
> akka-remoting and akka-cluster which are implemented this way.
>
> Cheers,
> Rafał
>
> W dniu środa, 4 stycznia 2017 17:52:43 UTC+1 użytkownik Joseph Mansigian
> napisał:
>>
>> After I do an actorSelection on the r
After I do an actorSelection on the remote path:
akka.tcp://community@127.0.0.1:4000/user/speaker
executing actor.Selection.pathString on the ActorSelection above shows the
local path: /user/speaker
When I send a message it ends up in dead letters as you would expect.
This is problematical becau
Hello,
I would like to develop an Akka actor based application that has actors
that span the Internet. It would be very convenient for me if I could do
the early stages of this development all on one machine. I would like to
have two JVM running on one machine but have the actor systems an
I read that the Microkernal was going away. Would you tell me, if you can:
- The name of the successor technology.
- A link to doc on it
- Will new technology be able to put anything found in Akka with Scala in
one package?
- Any idea when it will roll out?
- When will Microkernal be removed?
I am trying to use scala 2.11.8 and akka 2.4.9 for remoting. Not sure if
these versions are compatible. I noticed that there is an akka jar with
scala which is confusing to me since I already hava akka jars on the
classpath. When I run code I am getting:
java.lang.NoSuchMethodError:
akka
I am using Akka with Scala and want to configure an ActorSystem for remote
messaging ( but does not need to be remotely configurable ). The problem I
am having is that I am getting a Class Not Found exception for
akka,remote.RemoteActorRefProvider
when I run the code. I've double checked all
Hi.
I have this object:
object ActorInit {
val system = ActorSystem("VisenaRemoteSystem")
val imapStatsActor =
system.actorSelection("akka.tcp://VisenaRemoteSystem@127.0.0.1:5250/user/ImapStatsActor")
}
Then this code which sends a message to the remote actor:
implicit val timeout = Ti
akka-cluster JMX tool
<http://doc.akka.io/docs/akka/2.4.3/scala/cluster-usage.html#Command_Line_Management>
for manual administration of akka clusters. Not aware of any other tools.
Hope I learn about other tools on this thread. :)
--
Joseph
On Monday, April 4, 2016 at 4:13:16 AM UTC+5
I run the two
nodes on the same machine.
What can be done to prevent this issue? Please help.
--
Thanks
Joseph
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>>
Thank you for the clarification!
Joseph
On Thursday, February 4, 2016 at 2:59:07 PM UTC+1, drewhk wrote:
>
>
>
> On Thu, Feb 4, 2016 at 2:52 PM, Joseph Noir > wrote:
>
>> This email comes without context: what exactly are you referring to?
>>
>>
>&
at
> mailboxes may be full or nodes may crash?
Hopefully, this clarified the question, i.e., even if the message is
delivered to the network buffer it may still not be passed to an actor
because the node may crash or mailboxes may be full.
Joseph
[1]
http://doc.akka.io/docs/akka/current/ge
Ok. If that is the case, is the reason reliability is not guaranteed that
mailboxes may be full or nodes may crash?
Thanks,
Joseph
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>
more than one queue step involved on the recipient side -- one
queue per connection and then a mailbox for each actor? This would allow
reordering in the "connection" specific queues before passing messages to
the mailboxes.
Thanks for taking the time to the discuss this with me!
Jo
On a local node, yes, sure. But how does this work in a distributed setup?
--
>> 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.google.com/grou
Joseph
[1]
http://doc.akka.io/docs/akka/current/general/message-delivery-reliability.html
[2] http://www.infoq.com/articles/no-reliable-messaging
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
command-line tool for this.
joseph@gw01:~$ akka-cluster app01.stg leave akka.tcp:
//sys...@app01.stg:2551
Scheduling akka.tcp://sys...@app01.stg:2551 to LEAVE cluster
joseph@gw01:~$ akka-cluster app02.stg leader
Checking leader status
akka.tcp://system@app01:2551
It says that it
persist wasn't called from a constructor. Sorry, I should have shown this
function definition too.
```
def performIfActorNotLive(ar: ActorRef, f: => Unit) = {
implicit val timeout = Timeout(Duration.create(5, TimeUnit.SECONDS))
try {
(ar ? Identify(1)).mapTo[ActorIdentity].map { a
There are no collections in the pattern matching.
var subrClients = Map.empty[SessionId,SerializedActorPath]
val receiveRecover: Receive = {
case ClientRegistered(sessId, actor)⇒ subrClients += sessId -> actor
case ClientDeRegistered(sessId) ⇒ subrClients = subrClients.
filterNot(
ClassCastException: myapp.actors.subr.Subr$ClientDeRegistered cannot be
cast to myapp.actors.subr.Subr$ClientRegistered
at myapp.actors.subr.Subr$$anonfun$register$1.apply
at akka.persistence.Eventsourced$class.
akka$persistence$Eventsourced$$peekApplyHandler
at akka.persistence.Even
Does anyone know of some example code written in Java in which a servlet
and an actor send messages to each other?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the
digest_top>
> Behavior of Akka when you sleep in an actor
> <http://groups.google.com/group/akka-user/t/62b5fb43f2f62e70?utm_source=digest&utm_medium=email>
> Konrad Malawski : Oct 18 02:29AM +0200
>
> On Thu, Oct 15, 2015 at 4:44 AM, Fahimeh Rahemi
> wrote:
>
> &g
Is it possible for the same Java class to be both a servlet ( in my case a
servlet interacting with embedded Jetty ) and an Akka actor. Is there
example code for making such a class ? Thank you.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
Is there a JVM or Dalvik virtual machine that is a sufficient base to run
Akka on android mobile devices? If none is available now does anyone know
of any development efforts in this direction?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> ht
tion is thrown, the actor restarts, recovers from snapshot,
applies that event and throws an exception again, going into an infinite
restart loop.
Any idea why this could be happening?
Thanks,
Joseph
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>
Hello Tim,
I saw your post about the library you developed and wonder if it can help
me with a problem.
I have a Java/Akka project that is now run from the command line. Currently
anyone who wants to see what it can do has to install/already have:
- git
- java
- scala
- akka
- ya
I have a free open source prototype of a multi-agent system that learns and
forms plans by conversing with members of a community of Akka actors. -
each of which models the behavior of a different technology. Currently
coded in one language - Java. Scala would be coded also if interest shown.
Hello,
I've got an application that uses an Akka cluster v2.3.9 (we are running
several servers at Amazon EC2) and recently the cluster has been behaving
badly. The nodes aren't reconnecting to each other when one of them goes
down. We are running the cluster to take advantage of the Singleto
re anyway I can covert it to a router
object ?
Thank you very much in advance.
Regards,
Renien Joseph
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> htt
e current discussion in categories (like
general distributed system knowledge, building a distributed system using
akka, other (like these interviews with Werner Vogels and others solutions
like for example Finagle)).
Any opinion ?
Best
Joseph
On Mon, Oct 6, 2014 at 7:27 PM, Roland Kuhn wro
ld be put and kept up to date, I would gladly do it. I didn't find any
though.
Best
joseph
On Thu, Oct 2, 2014 at 10:00 PM, Sean Walsh
wrote:
> FYI myself and Duncan Devore are in the final processes of getting a
> distributed system design book (with domain driven design, CQRS-E
Hi Eric
Back from a great Cassandra event and there you're with more greatness,
thanks a lot :)
Glad to have some opinion from someone on the same track, let's dig in
then, really sweet.
Thanks again you all :)
Best
Joseph
On Thu, Oct 2, 2014 at 2:21 PM, Eric Pederson wrote:
&
27;ll read at least the first one, "Introduction to Reliable and
Secure Distributed Programming", with interest, but building from scratch
such a tool feels too.
Thanks again
Best
Joseph
ps : ignore previous partial answer, sorry for this. I've slammed my
fingers with a hammer so
http://www.sics.se/~joe/thesis/armstrong_thesis_2003.pdf
>
> But I’ve learned most from reading papers. I can recommend all the papers
> listed in the references section in my talk:
> www.slideshare.net/jboner/the-road-to-akka-cluster-and-beyond
>
>
> On Tue, Sep 30, 2014 at 2
muter and a big reader, I'm looking for the best resource(s) on
the topic, any hints ?
Thanks in advance
Best
Joseph
PS: I already tried scala/akka/eventsourced (now akka persistence), but
there's quite a step going to a proper distributed systems from there...
--
>>>>>>&
e event or something else... ? Plenty of questions : to
have them already tackled, if only partly, would be of a great help :$ It's
almost to the point where having to do it all from scratch make me wonder
whether akka would be right the right tool for the job. There may be easier
ways...
Thanks
; allowing access to both current state as well as point-in-time.
> Is that what you trying to accomplish or your pieces of data are
> completely independent from one another (no historically significant
> timeline)?
>
> Cheers
> Oleg
>
>
> On Mon, Feb 10, 2014 at 4:
wondering how I would implement such an use case
with it.
Thanks again
best
On Monday, February 10, 2014 8:03:32 AM UTC+1, rkuhn wrote:
>
> Hi Joseph,
>
> what exactly do you want to achieve? I’m asking because Akka itself does
> not really have any end-user features, it is onl
ren't too much spoken of. Did I miss something obvious
? Are they some best practices around or, even better, examples ?
Thanks in advance
joseph
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check t
50 matches
Mail list logo