[akka-user] Akka scheduler

2016-09-13 Thread José Diaz
Hi guys I am a newbie in akka. I am using scheduler for starts my supervisor. system.scheduler().schedule(Duration.Zero(), Duration.create(collectorInterval,---> 1 Minute TimeUnit.MINUTES), supervisor, Supervisor .START_COLLECTING, system.dispatcher(), null); The code of my Supervisor.java

Re: [akka-user] [Akka-HTTP] How do I not specify the charset?

2016-09-13 Thread Derek Wyatt
We have been able to see it work, if we put the charset *between* the multipart/form-data and the boundary. i.e. Content-Type: multipart/form-data; charset=utf-8; boundary=some-nonsense-here Which should reasonably work for everyone, including this busted app. I know that it messes with

Re: [akka-user] [Akka-HTTP] How do I not specify the charset?

2016-09-13 Thread Derek Wyatt
I'm not arguing that Akka is doing the wrong thing. But, I'm pretty screwed right now because significant functionality of the app for which I'm proxying is broken due to this and it's probably going to be my problem to fix :) So, is there any way that I can hook into the parsing and

[akka-user] Re: [Akka-HTTP] How do I not specify the charset?

2016-09-13 Thread Derek Wyatt
I was able to verify that this is breaking the app in question, but not with Akka. I merely added the charset to the request that was working, and it broke. But I think I have a more fundamental problem: I can't see the raw request that came in from the client. It, of course, is only

Re: [akka-user] [Akka-HTTP] How do I not specify the charset?

2016-09-13 Thread Viktor Klang
"The "charset" parameter is used with some media types to define the character set (section 3.4) of the data. When no explicit charset parameter is provided by the sender, media subtypes of the "text" type are defined to have a default charset value of "ISO-8859-1" when received via HTTP. Data in

[akka-user] [Akka-HTTP] How do I not specify the charset?

2016-09-13 Thread Derek Wyatt
Hi guys, I've written a reverse-proxy with Akka-HTTP and I'm hitting a problem while trying to interact with an ASP.NET app. The only interesting thing I can see is that without the proxy, the Content-Type is lacking a charset but the proxy adds charset=UTF-8. I can't find a way to replicate

Re: [akka-user] Akka Multithreading on Akka-Cluster

2016-09-13 Thread silvio poma
Hi Guido, can you suggest me some guide that explains the configuration changes that need to be done? I've seen that with the M4 it was included the configuration for for usage with Docker, that is what i need. Thanks Silvio Il giorno mercoledì 7 settembre 2016 17:50:44 UTC+2, Guido Medina ha

[akka-user] Re: Debugging marshalling implicits

2016-09-13 Thread Richard Rodseth
Bump. Is this the right way to debug the missing conversion? val prm = implicitly[Future[PimpedResult[(StatusCode, Result[StatusDTO])]] => ToResponseMarshallable] On Wed, Sep 7, 2016 at 8:43 PM, Richard Rodseth wrote: > Can anyone help me with this please? > I have the

Re: [akka-user] Akka Http Logging with traceId

2016-09-13 Thread Arun
Thanks Yann and Jan. The kamon looks clean way of implementation, the page also talks about http://kamon.io/integrations/logback/mdc-in-an-asyncronous-environment/ the way you have describe in your blog as well. I am going ahead with kamon. Thanks to everyone. Regards, Arun On Tuesday,

Re: [akka-user] Akka Multithreading on Akka-Cluster

2016-09-13 Thread silvio poma
I have an http endpoint with a consumerActor (in Node 0) that read the msg from the camel msg and with it create our Message.class than it send to a router1 that forward to one of "N" Worker1 in Node 1, Worker1 make a query on Couchbase process the result and send the Message.class to to a

Re: [akka-user] Akka Multithreading on Akka-Cluster

2016-09-13 Thread Viktor Klang
What is your bottleneck? On Tue, Sep 13, 2016 at 10:13 AM, silvio poma wrote: > Thanks guy, I eventually fixed all the configuration as you suggested and > now everything is working. > I can see a big improvement in the average time of response of my service > but the

Re: [akka-user] Cluster seed nodes resulting in multiple split brains?

2016-09-13 Thread Patrik Nordwall
How do you then handle node crashes and other unexpected failures? It's right that we strongly recommend against auto-down, but you must still use something. I hope that is not completely unclear in the documentation: http://doc.akka.io/docs/akka/2.4/scala/cluster-usage.html#Downing On Mon, Sep

Re: [akka-user] Akka Http Logging with traceId

2016-09-13 Thread Yann Simon
I don't think so. The source thread is the thread used to handle the message, as the log is done in another actor (and maybe in another thread). Le mar. 13 sept. 2016 à 10:28, Arun a écrit : > Thanks Yann. Let me explore these options. > > As per akka documentation >

Re: [akka-user] Akka Http Logging with traceId

2016-09-13 Thread Arun
Thanks Yann. Let me explore these options. As per akka documentation http://doc.akka.io/docs/akka/2.4.10/scala/logging.html , can I use "sourceThread" as traceid? Regards, Arun On Tuesday, September 13, 2016 at 1:23:48 PM UTC+5:30, Yann Simon wrote: > > I wrote that some times ago: >

Re: [akka-user] Akka Multithreading on Akka-Cluster

2016-09-13 Thread silvio poma
Thanks guy, I eventually fixed all the configuration as you suggested and now everything is working. I can see a big improvement in the average time of response of my service but the throughput is still the same of before. Any other suggestions, my target is to have throughput as high as

Re: [akka-user] Akka Http Logging with traceId

2016-09-13 Thread Konrad Malawski
Reactive Monitoring is able to propagate MDC across Actors: https://www.lightbend.com/products/monitoring -- Konrad `ktoso` Malawski Akka @ Lightbend On 13 September 2016 at 08:57:24, Arun (sethia.a...@gmail.com) wrote: Thanks Jan. I am looking for

Re: [akka-user] Akka Http Logging with traceId

2016-09-13 Thread Yann Simon
I wrote that some times ago: http://yanns.github.io/blog/2014/05/04/slf4j-mapped-diagnostic-context-mdc-with-play-framework/ I use a somewhat modified version of that, but it works only with Futures. With actors (and akka-stream and akka-http), I think that you only have 2 options: - use kamon.io

Re: [akka-user] Akka Http Logging with traceId

2016-09-13 Thread Arun
Thanks Jan. I am looking for something similar to http://code.hootsuite.com/logging-contextual-info-in-an-asynchronous-scala-application/ , I could able to find that either by using custom akka dispatcher or custom execution context, we can achieve the same, but I would prefer anything I