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
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
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
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 =
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;
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:
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
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
ion 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 <joseph.c@gmail.com
> >:
>
>> W
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
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]
e 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 remote path:
>> akka
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
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
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:
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 =
X 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:30, Владимир М
me machine.
What can be done to prevent this issue? Please help.
--
Thanks
Joseph
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/c
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:
>>
gt; 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/general
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 <josep...@gmail.com
> > wrote:
>
>> This email comes without context: what exactly are you referrin
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!
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:
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's
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 {
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.
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
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
tm_source=digest_medium=email>
> Back to top <#1507c032c1327adf_digest_top>
> Behavior of Akka when you sleep in an actor
> <http://groups.google.com/group/akka-user/t/62b5fb43f2f62e70?utm_source=digest_medium=email>
> Konrad Malawski <kt...@typesafe.com>: Oct 18 02:29
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:
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/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search
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
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
?
Thank you very much in advance.
Regards,
Renien Joseph
--
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/group/akka-user
---
You received this message because you
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 goo...@rkuhn.info wrote
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 sean.wa...@reactibility.com
wrote:
FYI myself and Duncan Devore are in the final processes of getting a
distributed system design book (with domain driven design, CQRS
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 eric...@gmail.com wrote
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:17 PM, Joseph Pachod joseph.pac...@gmail.com
wrote:
Hello
Our small software shop has recently been bought
, 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...
--
Read the docs: http://akka.io/docs/
Check
was 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 only a library
.
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:54 AM, joseph joseph.pac...@gmail.com wrote:
Hi Roland
Thanks a lot for your answer.
The end target would
46 matches
Mail list logo