Thanks for pointing this out - good catch!
Fixed: https://github.com/typesafehub/activator-akka-stream-scala/pull/25
// Note to self, doubleckeck if travis actually works as expected on these
repos.
On Sat, May 2, 2015 at 1:50 AM, Richard Rodseth rrods...@gmail.com wrote:
You're probably aware
Hi Simone!
All examples in the docs are compiled and tested before we release them, so let
ma assure you the code is valid.
The entire code is listed here if you’d like to have a look at the complete
file:
Hi all,
I'm a beginner with Akka Stream, but I found a couple of problems trying to
compile the quick start example
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC2/scala/stream-quickstart.html#stream-quickstart-scalaprovided
in the docs.
1. FlowGraph does not have a
Hey Konrad,
Thanks for the fast reply. I made a summary of my problem in this gist.
https://gist.github.com/sscarduzio/7b65ecc3685bbe335e6b
Also the code from github is not working, it must be some problem with my
environment :(
_S
On Sat, May 2, 2015 at 7:04 PM, Konrad Malawski
Seems you forgot to extend RawDocument in Document, which manifested itself in
being unable to wire up flows of not-compatible types.
I forked and fixed the minor typos in your code:
https://gist.github.com/ktoso/8140969c4aead4103317
Happy hakking, I hope you’ll enjoy Akka Streams as much as we
Hi Konrad,
Unfortunately I have problems to see your changes, when I click your gist
link I see identical code to mine.
_S
On Sat, May 2, 2015 at 7:38 PM, Konrad Malawski
konrad.malaw...@typesafe.com wrote:
Seems you forgot to extend RawDocument in Document, which manifested
itself in being
Hey nevermind, I made it work!
https://gist.github.com/sscarduzio/7b65ecc3685bbe335e6b#file-workinggraph-scala
Wohoo! ;)
IntelliJ still gives me all kinds of errors. I guess it's about corrupted
cache.
Once again, my golden rule is confirmed: only trust sbt compile output.
_S
On Sat, May 2,
I am very new to `Akka` and using `Java` to program my system.
**Problem definition**
- I have a `TenantMonitor` which when receives `TenantMonitorMessage()`,
starts a new actor `DiskMonitorActor`.
- The `DiskMonitorActor` may fail for various reasons and may throw
`DiskException`. The
Yep, I got Intellij working too at the end.
My build.sbt had this enablePlugins(JavaAppPackaging) line which
failed and prevented the internal build system from downloading the
latest version of akka stream. It all worked when I removed that line
in build.sbt.
Then I also realised the graph I
Hello,
I have a cluster system and I am trying to do a request-response across
nodes.However the response is not going to the correct actor (going to dead
letter). It gets to the destination and gets back to the correct node, but
on the source node I am getting:
[INFO] [05/02/2015
Seems I pasted the wrong gist-link, I meant:
https://gist.github.com/ktoso/32e8e098616ddd3e9776 (green in intellij for me).
In general if you see errors about being unable to find a matching method for
~ types are wrong between the inlet/outlet.
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @
The best I could write is to make sure that the `DiskMonitor` is stopped
once the exception occurs
@Test
public void testSupervisorForFailure() {
new JavaTestKit(system) {{
final MapString, String configValues =
As per docs
http://doc.akka.io/docs/akka/snapshot/java/testing.html#akka-testkit,
under (Expecting Log Messages)
ote
Be sure to exchange the default logger with the TestEventListener in your
application.conf to enable this function:
1. akka.loggers = [akka.testkit.TestEventListener]
So,
13 matches
Mail list logo
