[akka-user][deprecated] Remoting With Artery

2020-05-16 Thread Joseph Mansigian
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

[akka-user][deprecated] Handling Exceptions in Ask Pattern

2018-04-02 Thread Joseph Mansigian
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

[akka-user] Play Controller/Akka Actor Ask Pattern Question

2018-01-27 Thread Joseph Mansigian
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

[akka-user] Parsing Configuration

2017-11-26 Thread Joseph Mansigian
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 =

[akka-user] Preventing Memory Leaks

2017-11-19 Thread Joseph Mansigian
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;

[akka-user] Config Exception

2017-09-05 Thread Joseph Mansigian
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-user] Compatibility Question

2017-09-01 Thread Joseph Mansigian
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

[akka-user] Re: Akka Messages Duplicated

2017-06-03 Thread Joseph Mansigian
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

[akka-user] Akka Messages Duplicated

2017-06-02 Thread Joseph Mansigian
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

Re: [akka-user] Path to Actor changed by Akka

2017-04-15 Thread Joseph Mansigian
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

[akka-user] Path to Actor changed by Akka

2017-04-14 Thread Joseph Mansigian
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

[akka-user] Dispatcher Problem

2017-01-06 Thread Joseph Mansigian
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]

[akka-user] Re: Emulate Geo Dispersed Actors on Local Machine

2017-01-05 Thread Joseph Mansigian
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

[akka-user] Emulate Geo Dispersed Actors on Local Machine

2017-01-04 Thread Joseph Mansigian
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

[akka-user] Akka Remote Development on One Machine

2016-10-16 Thread Joseph Mansigian
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

[akka-user] Successor Technology to Microkernal

2016-09-29 Thread Joseph Mansigian
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?

[akka-user] Scala Akka Alignment

2016-09-20 Thread Joseph Mansigian
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-user] Problem Configuring ActorSystem

2016-08-31 Thread Joseph Mansigian
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

[akka-user] Using remote-actors

2016-06-30 Thread Andreas Joseph Krogh
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 =

[akka-user] Re: Cluster sharding monitoring

2016-04-04 Thread joseph
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, Владимир М

[akka-user] Dead letters during hand-over of cluster singleton actors

2016-03-29 Thread joseph
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

Re: [akka-user] Message Ordering in Akka

2016-02-04 Thread Joseph Noir
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: >>

Re: [akka-user] Message Ordering in Akka

2016-02-04 Thread Joseph Noir
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

Re: [akka-user] Message Ordering in Akka

2016-02-04 Thread Joseph Noir
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

[akka-user] Re: Message Ordering in Akka

2016-02-03 Thread Joseph Noir
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!

[akka-user] Re: Message Ordering in Akka

2016-02-02 Thread Joseph Noir
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:

[akka-user] Message Ordering in Akka

2016-02-02 Thread Joseph Noir
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:

[akka-user] Asking a node to leave using akka-cluster command-line tool.

2016-01-12 Thread joseph
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

Re: [akka-user] Re: ClassCastException when persisting events using akka-persistence

2016-01-06 Thread joseph
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 {

Re: [akka-user] Re: ClassCastException when persisting events using akka-persistence

2016-01-05 Thread joseph
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.

[akka-user] ClassCastException when persisting events using akka-persistence

2016-01-05 Thread joseph
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-user] Example code of Servlet and Actor messaging each other

2015-10-20 Thread Joseph Mansigian
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

Re: [akka-user] Abridged summary of akka-user@googlegroups.com - 10 updates in 5 topics

2015-10-18 Thread Joseph Mansigian
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

[akka-user] Servlet and Actor

2015-10-17 Thread Joseph Mansigian
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:

[akka-user] Akka Mobile

2015-08-29 Thread Joseph Mansigian
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:

[akka-user] Cluster sharding with Persistence: Failing require statement,

2015-06-26 Thread joseph
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

[akka-user] Multi-agent Systems That Learn

2015-05-11 Thread Joseph Mansigian
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

[akka-user] Management tools for akka-cluster

2015-04-21 Thread Joseph Elliott
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

[akka-user] How can I access akka.routing.Router?

2015-02-10 Thread Renien Joseph
? 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

Re: [akka-user] Best book(s) on distributed system ?

2014-10-08 Thread Joseph Pachod
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

Re: [akka-user] Re: Best book(s) on distributed system ?

2014-10-06 Thread Joseph Pachod
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

Re: [akka-user] Best book(s) on distributed system ?

2014-10-02 Thread Joseph Pachod
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

Re: [akka-user] Best book(s) on distributed system ?

2014-10-01 Thread Joseph Pachod
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

[akka-user] Best book(s) on distributed system ?

2014-09-30 Thread Joseph Pachod
, 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

Re: [akka-user] master/master or disconnected mode example ?

2014-02-10 Thread joseph
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

Re: [akka-user] master/master or disconnected mode example ?

2014-02-10 Thread Joseph Pachod
. 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