Hi
I'm trying to use the akka-http client *outside a flow, just as http
client.*
I've an actor :
val poolConfig = ConnectionPoolSettings(100, 0, 128, 20, 100.second,
ClientConnectionSettings(context.system))
val connectionPool = Http().cachedHostConnectionPool[NetworkResponse](
"adfonic.net",
> for example:
>
> final Flow<Pair, ByteString, BoxedUnit> bytestringFlow =
> Flow.of(Pair.class).flatMapConcat((Pair pair) -> {
>Try responseTry = (Try) pair.first();
>Source<ByteString, Object> dataBytes =
> responseTry.get().entity().getDataBytes();
&
>
> Hacker √ complained about this in the 4'th Mail in this thread.
>
> Pleas forgive if I am wrong!
> Many Greetings John
>
>
> Am Dienstag, 2. Februar 2016 10:41:07 UTC+1 schrieb Richard Grossman:
>>
>> Hi
>>
>> If it can help someone in s
> I hope this answers your questions, but please do not hesitate to ask.
>
> Regards,
>
> Roland
>
> 26 jan 2016 kl. 16:04 skrev Richard Grossman <rich...@gmail.com
> >:
>
> Same Here
> We've not much communication from typesafe. There is still push forward
&g
request and make all the stuff by myself without any usage of
akka-stream
Thanks for your patience
On Monday, January 25, 2016 at 11:29:38 AM UTC+2, drewhk wrote:
>
> HI Richard,
>
>
>
> On Sun, Jan 24, 2016 at 3:01 PM, Richard Grossman <rich...@gmail.com
> > wrote:
Hi
I've written a Flow that make an http call like this
val connectionPool = Http().superPool[SubRequest](settings = poolConfig,
log = adapter)
val flow: Flow[SubRequest, Response, Unit] =
Flow[SubRequest]
.completionTimeout(1000 millis)
.map(subR => HttpRequest(HttpMethods.GET, subR.url) ->
Hi
I need to exactly the same I must get the response on http call into my
flow.
I see that you think this tickets can solve your problem is it true ?
Thanks
On Tuesday, August 4, 2015 at 6:45:07 PM UTC+3, john@gmail.com wrote:
>
> i think I need to wait for
Same Here
We've not much communication from typesafe. There is still push forward for
Akka using still spay as Http layer but in the other side Akka Stream and
akka Http promise to fix all the issues we encounter with Akka.
Please Typesafe could you please give orientation about what the
works with futures
> then maybe that is the way to go, and integrate it with your stream if
> necessary with a mapAsync.
>
> -Endre
>
> On Thu, Jan 21, 2016 at 11:11 AM, Richard Grossman <rich...@gmail.com
> > wrote:
>
>> Hi
>>
>> I need to figu
Hi
I really need to start from something to try to use Akka-Http client.
The server side have some sample project to start with but nothing on
client site.
No sample how to use the API, how to control timeouts, how to deal with
Http low api protocols
If I want to assure back-pressure in a
Hi
I need to figure out a looping flow.
1/ I get a list of request each request is an http call.
2/ I make the http call get a result back
3/ If I get a valid response I need to break the flow not continuing to
loop on the rest of the request in the sequence
*The http call have to be serial
Hi
The question is not easy to explain I'll try to do my best
My Flow include a mapConcat Part when I get 1 element and flatten in in
multiple element.
The number of element emitted is variable at this stage. thus 1 in -> n out
.
Now I would like to balance but on n element not on fixed element
Work Perfectly Thanks
On Wednesday, January 20, 2016 at 11:55:58 AM UTC+2, Richard Grossman wrote:
>
> Hi
>
> When working with simple flows you can add between steps log directive.
> like Flow.log("start").map
> But when working with GraphBuilder :
> you
Hi
When working with simple flows you can add between steps log directive.
like Flow.log("start").map
But when working with GraphBuilder :
you use the builder to add the step and connect them using the DSL
How to log between these steps ?
Thanks
--
>> Read the docs:
Hello
I see that nobody answer to this
Any news ?
On Tuesday, November 10, 2015 at 8:04:37 PM UTC+2, Richard Grossman wrote:
>
> Hi
>
> I need to make a http service that must end the process in limited amount
> of time.
> Meaning if the process take longer than 0.5s then I r
t;> Konrad 'ktoso’ Malawski
>> Akka <http://akka.io> @ Typesafe <http://typesafe.com>
>>
>> On 15 November 2015 at 11:21:15, Richard Grossman (rich...@gmail.com
>> ) wrote:
>>
>> Thanks
>> Is there any impact on serving ?
>>
>>
>> On
PM, Konrad Malawski <
>>> konrad@typesafe.com> wrote:
>>>
>>>> Hi all,
>>>> thanks for trying out the early Milestone and reporting the problem!
>>>> We believe there is a bug in how the idle timeout was added, not sure
>>>
Thanks
Is there any impact on serving ?
On Sunday, November 15, 2015 at 8:53:05 AM UTC+2, Ryan Brozo wrote:
>
> I am also getting the exact same error in 2.0-M1.
>
> I tried some logging using the logRequestResult directive to see which
> requests are getting the InternalServerError. But it
I send a request all is working but get this after 2 s
I've configured in application.conf
akka.http.server.idle-timeout = 2 s
Internal server error, sending 500 response
java.util.concurrent.TimeoutException: No elements passed in the last 2
seconds.
at
Hi
I need to make a http service that must end the process in limited amount
of time.
Meaning if the process take longer than 0.5s then I reply an error code to
the client.
In Spray there was a parameter in config called globalTimout to make this.
Is there something like this in Akka-Http
Hi
As someone that have a Akka actor based application in production and
handling ~ 2 billions request/day
I really encourage you to start working with Akka-http and akka-Stream
instead just Akka actor based.
The concern are not about the developement (easier with akka actor) but the
tuning
Hi
I've define a flow like this:
def makeAST = Flow[String].log("Parse Json") map { json =>
Try {
val jsonMessage = parse(json)
val jsonNode = asJsonNode(jsonMessage)
val report = validator.validate(jsonSchema, jsonNode)
if (!report.isSuccess) throw new
t; the documentation is actually compiled and tested: you overlooked "-> 42"
> in the example, which in your case needs to be "-> ()" (in the argument to
> Source.single).
>
> Regards,
>
> Roland
>
> 8 sep 2015 kl. 18:14 skrev Richar
Hi
I'm confronted to this problem :
I'm using this dependencies:
akka-http-experimental_2.11 V1.0 latest release
My code is pretty simple as exactly like the sample on the documentation
class HttpFlow(implicit system: ActorSystem, actorMaterializer:
ActorMaterializer) {
protected implicit
Any New on this I get the same problem
here is my code
def asyncHandler(request : HttpRequest) : Future[HttpResponse] = {
request match {
case HttpRequest(POST, Uri.Path("/rtb"), _, _, _) =>
val eee = Source.single(request).via(flowAsync).runWith(Sink.head)
Hi
I last dev from our application we get :
EventStreamError
Message : null
Is there some way to have more info on what is null ?
Thanks
--
Read the docs: http://akka.io/docs/
Check the FAQ: http://akka.io/faq/
Search the archives: https://groups.google.com/group/akka-user
Hi
I'm using Akka 2.2.3 and after make my routing by code I want to move it
into application.conf to be deploy
My problem is that I've a hierarchy of actor like this (taking the /user as
base of course)
I create Actor2 from Actor1
Actor1 Actor2 Actor3 Actor4
So I've 1 dispatcher
27 matches
Mail list logo
