Thanks for the quick answer.
With this I can do something with the data, but is it also possible, that
the flow (codec2) sends a bytestring, when it gets produced by the Source?
I tried the following, but here it waits until the source completes before
sending the whole Bytestring. I want that i
On Mon, May 23, 2016 at 6:31 PM, Bruno Filippone
wrote:
> It seems to me that is smart enough after some testing, but the Akka
> documentation suggests to use joinSeedNodes in a different manner:
>
> "You may also use Cluster(system).joinSeedNodes to join programmatically,
> which is attractive w
Sorry you mean other ideas?
I had considered doing the update of the As inside the Bs since the events
that update A are a lot smaller than the number of As. The problem is that
this would extend the update time for B to be so excessive that it would
back up the processing of the Bs. I also de
I looked at
https://www.playframework.com/documentation/2.4.x/JavaAkka#Configuration
It talks about only 2 parameters
akka.actor.default-dispatcher.fork-join-executor.pool-size-max = 64
akka.actor.debug.receive = on
I looked up these parameters on
http://doc.akka.io/docs/akka/snapshot/gener
Hi,
What alternate solutions do you have? (not worrying about implementation
for now)
--
Cheers,
√
On May 31, 2016 18:31, "kraythe" wrote:
> I am seeking advice from those more experienced about some ideas for
> dealing with dependent processing. The use case is simple though I have to
> be a
It returned an Akka Stream there :-)
So you should learn a bit about Akka Streams to know how to handle those:
http://doc.akka.io/docs/akka/2.4.6/scala/stream/stream-quickstart.html
and take it from there.
It's basically as simple as
streamedData.map(_.utf8String).runWith(Sink.foreach(it => printl
I am seeking advice from those more experienced about some ideas for
dealing with dependent processing. The use case is simple though I have to
be a bit coy because of NDAs. I have some ideas myself but was hoping some
of you with more experience than I could throw out some suggestions.
I have
Hi,
I looked into many nice Examples with Akka Websockets (like
https://markatta.com/codemonkey/blog/2016/04/18/chat-with-akka-http-websockets/),
but sadly the used flows only handle strict Messages.
Is is possible to write a Flow from Message to Bytestring that handles
Strict and streamed Me
Hi David,
I can't repeat this, with non-chunked (which in Akka HTTP becomes a
HttpEntity.Default entity) and the latest Akka HTTP I mostly see chunk
sizes around 131 072 bytes, which maches up pretty well with the TCP packet
sizes for the same request.
Locally I see response times of 200-300ms PUT
If you are learning Akka you should use Akka 2.4. Rather much has changed
in Persistence between 2.3 and 2.4
http://doc.akka.io/docs/akka/2.4.6/java/persistence.html
/Patrik
tis 31 maj 2016 kl. 10:53 skrev <281725...@qq.com>:
> In the book <> says that
> "If there is a problem with recovering t
I'm using FST for serialization and am happy with it. It works reasonably
out-of-the-box.
To get it to work with remoting, I had to register specific FST serializers
for ActorRef and Deploy. The first one falling back to
Serialization.serializedActorPath and the latter one delegating to the
de
I there,
I would like to create a service who acts as a relay between plain Http
POST and WebSocket. The idea is to have this service who forward any POST
requests body to a Websocket channel and use the Websocket response as Http
response or send it to another server if the Websocket response
the log is follow:
2016-05-31 07:40:54,053 | WARN | lt-dispatcher-16 | ClusterCoreDaemon
| 167 - com.typesafe.akka.slf4j - 2.3.10 | Cluster Node
[akka.tcp://opendaylight-cluster-data@192.168.23.240:2550] - Marking
node(s) as UNREACHABLE [Member(address =
akka.tcp://opendaylight-
In the book <> says that
"If there is a problem with recovering the state of the actor from the
journal, the actor will be sent a RecoveryFailure message that it can
choose to handle in receiveRecover. If the actor doesn’t handle the
RecoveryFailure message it will be stopped"
But int the functi
Hi Samuel and Marek,
Very interesting solutions thanks!
Le mardi 31 mai 2016 08:43:28 UTC+2, Marek Żebrowski a écrit :
>
> Faced with similar problem we went following route:
> 1. increased max connections to 64 for a host - default 4 is ususally way
> to low for high-traffic scenarios
> 2. add
15 matches
Mail list logo
