Hi Johannes,
thanks for your answer and especially for the sample code (it helped me
quite a lot to understand the approach) !
If I understand it correct this
*Source.subscriber[T].toMat(Sink.publisher[T])(Keep.both).run() *
essentially exposes a* reactive stream* Publisher and
Thanks for your response Roland,
I've been trying to run the test as you suggested but I had no luck. The
test works if I do something like this (I'm testing only the first output):
val out = FlowGraph.closed(collector[Event]) { implicit builder = out =
val eif = builder.add(eventInputFlow)
I was able to resolve this by doing the following in my PersistentView:
case class UpdateView( id: String)
...
ShardRegion.idExtractor {
...
case m:UpdateView = (m.id, Update(await = true ))
}
ShardRegion.ShardResolver {
...
case m:UpdateView = s{m.id.hashCode() % 100}
}
Then in my
Greetings,
I am working on an PersistentActor/PersistentView (for Akka 2.3.12) - when
I go to signal my view via Update:
persist(UpdatedLineItemsEvt(m.orderId, lineItems)) { evt ⇒
val updatedState = applyEvent(evt, state)
viewRegion ! Update(await = true)
sender() !
Hi,
We are starting a new project at work and we chose to use Akka HTTP for the
API. So far everything is working as expected and the docs/tutorials for
spray work without changes or with minimal changes.
However, now that we want to add integration tests for the routes, the
examples that
Hi Yifei,
Metrics (most of them) like that can be collected using Takipi for Akka
https://www.typesafe.com/blog/a-new-way-to-debug-scala-in-production-takipi-for-scala
or kamon.io.
We're working on improving the monitoring situation but don't have anything
concrete to announce yet.
On Tue, Aug
It may be possible to backport the ConsistentRouter, you can give it a
shot, however it would have to be in your codebase as 2.1 has been
EndOfLife-ed some time ago, we don't maintain it anymore.
For a number of other reasons (stability and perf improvements) I'd highly
recommend putting an update
Getting the same on Play 2.4
Here's the stack trace http://pastebin.com/ECSP5V0P
What are the possible causes? There's minimal load on the server (as in .01
- .05) so can't image there's much thread contention going on.
Thanks for any clues, have to bounce the server every hour or two --
Wonder if Connection: reset issue referenced in recent Play commit
https://github.com/playframework/playframework/commit/088d55cadf19a1996171a79ac6134fa0edbcc02c
address a possible problem in 1.0-RC4?
The stack trace gives little to work with (wrt to my own code) so not sure
where the problem
Oh, forgot to mention, on: akka-stream-experimental % 1.0-RC4
On Wednesday, May 21, 2014 at 6:59:35 AM UTC-4, Gal Goffer wrote:
Hi Patrik,
I've seen this as well, but in our case it doesn't look like the result of
an actor termination from within the receive method as described in the
Now, why do ALL subsequent requests on the entire server blow up with
this error?
Oh, I see:
shutting down ActorSystem [application]
java.lang.NoSuchMethodError: play.api.PlayConfig.getOptional
That seems a bit heavy handed...
On Monday, August 17, 2015 at 11:44:48 AM UTC-4, virtualeyes
Think I found the cause, `Future` mailer on successful credit card
transaction (see the errors begin right after most recent transaction with
payment processor).
Not coincidentally I have yet to receive any email order confirmations wrt
to the above.
Time to dig in to the code, thanks for
That's the cause (issue with Play mailer plugin).
Now, why do ALL subsequent requests on the entire server blow up with this
error?
I would assume that a problem with single request would not bring the
server to its knees (again server load is minimal).
On Monday, August 17, 2015 at 11:29:29
It seems I have dead lock on my data, because I am passing the same object
to several actors in parallel.
воскресенье, 16 августа 2015 г., 12:03:43 UTC+3 пользователь Sergey Sopin
написал:
Hello,
I have some problems with Akka and memory, hope you can help me.
I have following code:
Newbie in akka.I want to customize akka logger to use my own.How to proceed
?
Need assistance.Thanks in advance
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives:
One of the possible use cases of event sourcing we’d like to implement is
subscribing to domain events changes.
The requirements are quite high:
Over 10 live topics/entities, preferably up to 1,000,000
Up to 5 updates per second
Low latency - less than 10msec, average
Topic scale (at
A ClusterClient (outside the cluster) will talk to a ClusterReceptionist on
one node (in the cluster). All messages sent via that client instance will
be sent to the same ClusterReceptionist. The ClusterReceptionist will then
route the messages to destination actors (in the cluster). Replies are
Hi Yar. Thanks for getting back! The error message was regarding headers
missing from the *server's* response to the actual POST request (it handled
the pre-flight OPTIONS request just fine, which is why I was puzzled.
I've since resolved the question, as it was a matter (as the blog you
Hello and welcome to the list,
Have you read http://doc.akka.io/docs/akka/current/java/logging.html#SLF4J ?
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 17 August 2015 at 10:06:17, Pinaki C (cpinaki.m...@gmail.com) wrote:
Newbie in akka.I want to customize akka logger to use my
Hi Roland,
In the end I solved it used various type classes from Scalaz and created a
Flowz class to remove the boiler plat from using it with Flow DSL. Then
included the beanstalk deleter as the sink at the end of all possible
routes in my graph.
See the Flowz implementation here:
20 matches
Mail list logo
