On Sat, Dec 20, 2014 at 8:50 PM, David Hotham david.hot...@googlemail.com
wrote:
I have discovered that my problem is that my Tcp.Write messages are
sometimes delivered to dead letters:
After that I obviously don't get the expected Ack, and that's why my
system is grinding to a halt.
I
Hi,
On Sun, Dec 21, 2014 at 6:54 PM, 何品 hepin1...@gmail.com wrote:
yes.only one process,in fact one process generated the journal,and then I
download the journal file from my remote server,want to replay it via
persistent view.seems I have some problem with the default leveldb
implement.
Hi Greg,
The API doesn't look like that. Here is an example how it is supposed to
work:
import akka.actor.ActorSystem
import akka.stream.FlowMaterializer
import akka.stream.scaladsl.{ Sink, Source }
import akka.http.model.{ HttpResponse, HttpRequest }
import akka.http.Http
import
Following Sample:
The Producer receives a different demand of elements dependent if the
flow does have processing steps or not.
(*Consumer uses the WatermarkStrategy(30)*)
var flow = Flow.empty[Int]
Hi Wolfgang,
What you see is completely expected. The strategy you added only defines
the strategy for that particular consumer. Once you attach other processing
steps, like those maps they do their own batching strategy independent
from what your consumer does. This is by design, backpressure
Hi Endre!
Thanks for the clarification, it does make sense :)
Is it possible to define the batching strategy for simple operations like
map? Or do I have to write a dedicated processor for handling this.
Wolfgang
Am Montag, 22. Dezember 2014 12:30:15 UTC+1 schrieb Akka Team:
Hi Wolfgang,
Hi Wolfgang,
On Mon, Dec 22, 2014 at 1:10 PM, Wolfgang Friedl
wolfgang.fri...@hotmail.com wrote:
Hi Endre!
Thanks for the clarification, it does make sense :)
Is it possible to define the batching strategy for simple operations
like map? Or do I have to write a dedicated processor for
Hi Endre!
Well my real use case is a little bit more complex and correctly I do have
some performance problems.
I thought I could improve the performance by changing the relation between
Command (Request messages) and Data messages. So far this relation is 1:2
(at least this is what my tests
Hi Wolfgang,
Well my real use case is a little bit more complex and correctly I do have
some performance problems.
This would be probably not solved by a custom schedule at all. In fact
allowing custom schedules would completely deprive us from the flexibility
we need internally to do
Hi Endre!
Thanks for the detailed description, this definitely helps.
I'm looking forward for the final release.
Bester Regards
Wolfgang
Am Montag, 22. Dezember 2014 14:03:12 UTC+1 schrieb Akka Team:
Hi Wolfgang,
Well my real use case is a little bit more complex and correctly I do have
On Mon, Dec 22, 2014 at 2:41 PM, Wolfgang Friedl
wolfgang.fri...@hotmail.com wrote:
Hi Endre!
Thanks for the detailed description, this definitely helps.
I'm looking forward for the final release.
You can still try the steps I recommended. When I say not yet there it
still means above 1-2M
First,No.
In fact I think the problem is cause by leveldb.
the size is about 6.7GB,and I could not dump it to cassandra or so on.
在 2014年12月22日星期一UTC+8下午5时06分45秒，Akka Team写道：
Hi,
On Sun, Dec 21, 2014 at 6:54 PM, 何品 hepi...@gmail.com javascript:
wrote:
yes.only one process,in fact one
should cluster matrix add node to node throughput or network interface
throughput,so we could see how busy between nodes
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives:
Is there an example http file server and client like this that works with
the latest 1.0-M1 version?
On Thursday, November 20, 2014 4:11:38 PM UTC+1, rklaehn wrote:
On Thu, Nov 20, 2014 at 3:31 PM, Allan Brighton alla...@gmail.com
javascript: wrote:
Thanks for the http server example. It
Endre,
Thank you for taking the time to explain everything. It was really helpful
not only in understanding the streams basics but also to create a
better/faster version of what I'm trying to do.
Before I go any further I want to say that I love Akka streams and it is
going to be a useful
15 matches
Mail list logo
