Hi Harit,
You should try akka streams:
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC2/
It has all you need.
There are also activator tutorials:
http://www.typesafe.com/activator/template/akka-stream-java8
http://www.typesafe.com/activator/template/akka-stream-scala
-Endre
I have struggled a lot with the same challenge. The MDC feature of the
logging frameworks need a little more manual intervention when operating
in an asynchronous runtime like Akka. MDC is tightly coupled to a thread,
but communication with and between Actors happen in different threads.
Hi,
On Wed, May 6, 2015 at 3:49 PM, akka-streams-beginner vadik...@gmail.com
wrote:
I posted this question to stackoverflow (
http://stackoverflow.com/questions/30077766/how-to-attach-multiple-actors-as-sources-to-an-akka-stream),
but then was pointed to this group, so I'll ask here:
I am
Hello,
You could have a look at the akka-http websocket example by Johannes
Rudolph: https://github.com/jrudolph/akka-http-scala-js-websocket-chat
He doesn't combine two ActorRef sources, but he combines an ActorRef sink
with an ActorRef source. The key is in the matValue function he uses in
Hi,
I am not sure if this is an Akka related question. You should probably post
it on the Play ML instead.
-Endre
On Fri, May 8, 2015 at 11:46 AM, Nweike Onwuyali nweikeonwuy...@gmail.com
wrote:
I am building a Play/Akka Actors application . My Play application uses
Web Socket to get
There are also some fixes pending for a 2.3.11 release which is almost out
of the door. I recommend waiting for that and updating.
-Endre
On Thu, May 7, 2015 at 9:57 PM, Moiz Raja moizr...@gmail.com wrote:
Looks like a lot of remoting/clustering fixes went into 2.3.10. We were
facing an issue
Hi Alejandro,
You have a number of options
- when you have a single persistence Id, write a view for that
- when you want to aggregate events of several persistence ids, you can do so
via the event store (approach of Martin (with Kafka) and Greg (event store) )
Or you can aggregate the
On Thu, May 7, 2015 at 9:26 PM, Moiz Raja moizr...@gmail.com wrote:
This is a top level one - but it is not the only top level actor in the
actor system.
The only safe way to reuse a name is to watch the actor from the *parent*
actor, and once received a Terminated message, create an actor
Hi Endre,
I will do so
On Friday, May 8, 2015 at 10:46:39 AM UTC+1, Nweike Onwuyali wrote:
I am building a Play/Akka Actors application . My Play application uses
Web Socket to get messages for three
different areas in a single View page.
- The first is getting mails
- The second is
Right now, what would be the best alternative in order to create
projections, allowing views to subscribe to arbitrary events as described
by Roland above? (or at least a coarse approximation)
--
Read the docs: http://akka.io/docs/
Check the FAQ:
Hi Endre,
I am not seeing the early stop you mention. Are you talking about this
line?
https://github.com/chanan/java-cqrs-starter/blob/feature/ask-not-working/app/actors/GameActor.java#L45
That is inside the context().become and should only fire after the reply
from the query cluster is
It seems like you stop your actor too early, therefore messages destined to
it fall into the void (dead letters).
-Endre
On Wed, May 6, 2015 at 6:03 PM, Chanan Braunstein
chanan.braunst...@pearson.com wrote:
Hi Endre,
I got rid of the persistence to make it easier to recreate the problem.
I am building a Play/Akka Actors application . My Play application uses Web
Socket to get messages for three
different areas in a single View page.
- The first is getting mails
- The second is getting newsfeed
- The third is getting notification.
When the view page loads, i am
On Fri, May 8, 2015 at 1:07 PM, Chanan Braunstein chan...@gmail.com wrote:
Hi Endre,
I am not seeing the early stop you mention. Are you talking about this
line?
https://github.com/chanan/java-cqrs-starter/blob/feature/ask-not-working/app/actors/GameActor.java#L45
That is inside the
I used revolver and it still works...
On Friday, 8 May 2015 01:07:05 UTC+2, Anton Kulaga wrote:
I wonder what should I use to automatically restart my akka-http app as
soon as some of its sources have been changed? Sbt-revolver looks more dead
than alive.
--
Read the docs:
Hi,
started to play with Akka remoting and I hit a problem with singleton
actors.
I have a 3 nodes Akka cluster with a singleton actor running somewhere
under the /user/root/singleton path.
I would like to send a message to this actor from any node in the cluster
triggered by someone
Hi Jacobus,
I like your analogy of putting a Ferrari on the back of a truck. However,
you can unload the Ferrari when you have reached the racing track. If you
can't convince them that it is easier and better to run Akka outside the
JEE container you can use the JEE Container for deployment,
After digging into akka.persistence.Eventsourced: *the implementation
allows only one recovery, when the actor is started and before any commands
are processed.* There does not seem to be a way to return to an awaiting
recovery state without fiddling with the private behaviour of a
Hi,
In the last milestone release that I was using, I used
Source[T](Props[MyTPublisherActor]) to convert a PublisherActor into a
source. On upgrading to the latest RC, this code doesn't compile. Is there
something I should have imported to implicitly add this apply method back
in? The associated
... and there is s SingletonProxy that you can use from the the Play frontend
nodes.
/Patrik
8 maj 2015 kl. 17:29 skrev Akka Team akka.offic...@gmail.com:
Hi Ugo,
Have you looked at the Cluster Singleton module?
http://doc.akka.io/docs/akka/2.3.10/contrib/cluster-singleton.html
It
Hi Matthew,
It is in the docs:
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC2/scala/stream-integrations.html
The construct is now:
val jobManagerSource =
Source.actorPublisher[JobManager.Job](JobManager.props)
We now has less overloaded apply() methods than before because it
It really depends on the market you're in. Some markets (first I can think
of are betting/gambling/banking) are very much against change. If you work
in that sector you have two choices: 1) you resign and you go work with
your friends in a startup working 24/7 but with the freedom to choose the
Hi Olger
Could you please elaborate a bit on your appoach? I'm not sure I follow.
Thanks.
On Fri, May 8, 2015 at 4:17 AM, Olger Warnier ol...@spectare.nl wrote:
Hi Alejandro,
You have a number of options
- when you have a single persistence Id, write a view for that
- when you want to
Thanks for the swift reply. So creating junctions will actually create
Graphs which you explicitly need to connect. This must have been changed
then, because I remember in earlier versions you didn't need to make any
explicit calls to the builder and you could just wire/connect them using
the
Hi Jeoren
On Fri, May 8, 2015 at 2:55 PM, Jeroen Rosenberg jeroen.rosenb...@gmail.com
wrote:
Thanks for the swift reply. So creating junctions will actually create
Graphs which you explicitly need to connect. This must have been changed
then, because I remember in earlier versions you didn't
Hi Idar
I just confirmed with some of our team mates that it depends upon our
customers.
1. Some customers use local disk and remove logs after processing. There
are customers who use NAS based storage. None uses SSD as per my
understanding.
2. The logs differ in size a lot.
This is what I have in the pom
dependency
groupIdio.kamon/groupId
artifactIdkamon-core_2.11/artifactId
version0.3.5/version
/dependency
dependency
groupIdio.kamon/groupId
artifactIdkamon-log-reporter_2.11/artifactId
version0.3.5/version
@AkkaTeam, thank you very much, seems like a weekend reading :). I will get
back based on my progress/questions.
Thank you
On Thursday, May 7, 2015 at 11:55:01 PM UTC-7, Akka Team wrote:
Hi Harit,
You should try akka streams:
Hi Jeoren.
On Fri, May 8, 2015 at 2:03 PM, Jeroen Rosenberg jeroen.rosenb...@gmail.com
wrote:
I'm trying to consume a stream from a streaming API (based on akka-http
and akka-streams 1.0-RC2). I'm currently using spray client, since I
couldn't figure out how to do it with Akka Http client
I'm trying to consume a stream from a streaming API (based on akka-http and
akka-streams 1.0-RC2). I'm currently using spray client, since I couldn't
figure out how to do it with Akka Http client yet, but this is another
topic (some pointers are appreciated, though). Anyway, I'm creating a
Hi Jacobus,
If you can look behind the somewhat provocative title, I think Eberhard
Wolff gives a pretty comprehensive overview of why you should look beyond
app servers in Java Application Servers Are Dead:
http://jaxenter.com/java-application-servers-dead-1-111928.html
Hello TS,
I have been trying to find some additional info regarding this issue, but
couldn't find anything yet :(... is it possible for you to provide us a
little example to reproduce the issue?
On Fri, May 8, 2015 at 2:59 AM TS test.tester1...@gmail.com wrote:
Ivan, Any updates on this.
Oops, you are right, I will move it into the receive loop and try again
shortly, thanks!
--
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
No that does not fix the issue.
The sender is a problem if it ever got that far, but the problem is it does
even seem to reach this actor. If it did this line:
https://github.com/chanan/java-cqrs-starter/blob/master/app/actors/GameActor.java#L61
would have been output into the log which it is
Never mind. I was missing some configuration.
I do see
kamon.logreporter.LogReporterSubscriber : No user metrics reported
I need to get the kamon configuration for actorCount etc.
On Friday, May 8, 2015 at 6:16:44 PM UTC-7, TS wrote:
OK.
Good news: Using 2.3.10, no errors.
However, I
Oh, that can be a problem! We have not tested Kamon with 2.4 yet and
probably the issue you are facing is due to Kamon's bytecode being liked to
certain Akka internals that changed between 2.3 and 2.4. Is it possible for
you to use Akka 2.3? I will let you know when we get ready to support Akka
what is the result of the log processing of a single file? is it some
aggregation or summary, or are you performing some action for each log line?
it seems to me the most performant solution would be to not use actors
at all, but to create a dedicated dispatcher and process each log file
in
OK.
Good news: Using 2.3.10, no errors.
However, I am using kamon log reporter. I do not see any actor metrics on
my logs. Should I enable something on application.conf?
On Friday, May 8, 2015 at 4:40:14 PM UTC-7, Ivan Topolnjak wrote:
Oh, that can be a problem! We have not tested Kamon
38 matches
Mail list logo
