Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

> <https://github.com/akka/akka-http/milestone/1?closed=1> milestone on > github. > > For this release we had the help of 14 committers – thank you! > > A special thanks to Jonas Fonseca <https://github.com/jonas> who did a > tremendously awesome job at migrating

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

Shapes don't need separate java or scala api, it's shared. You can just subclass a shape and make a class that directly represents your shape. If you want AmorphousShape then sure, but please note that it's purpose is to "forget about the types of those". If you want a well typed one simply

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

llowing dependency: "com.typesafe.akka" %% "akka-http-experimental" % "3.0.0-RC1" — Eric On Oct 18, 2016, at 10:42, Konrad Malawski <konrad.malaw...@lightbend.com> wrote: Yes, that's what all the fuss is about ;-) In fact, in RC it's already removed: http://search.mave

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

/doc.akka.io/docs/akka-http/current/scala/http/introduction.html still says: Akka HTTP is provided in a separate jar file, to use it make sure to include the following dependency: "com.typesafe.akka" %% "akka-http-experimental" % "3.0.0-RC1" — Eric On Oct 18, 201

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

e/1?closed=1> milestone on > github. > > For this release we had the help of 14 committers – thank you! > > A special thanks to Jonas Fonseca <https://github.com/jonas> who did a > tremendously awesome job at migrating all the docs from sphinx > (restructuredtext)

Re: [akka-user] Type mismatch, expected: ToResponseMarshallable, actual: HttpEntity.Strict

Make sure you have the latest version of the scala plugin. And I'd rather ask such questions on the Intellij issue tracker. Akka itself is doing the right thing as you mentioned... :) -- Konrad `ktoso` Malawski Akka @ Lightbend On 16 October 2016 at

Re: [akka-user] Re: Akka stream - implements Pause/Resume

Have you read the blog post? In the async callback you can push(), that's what I meant. -- Konrad `ktoso` Malawski Akka @ Lightbend On 14 October 2016 at 10:11:09, Konrad 'ktoso' Malawski (ktos...@gmail.com) wrote: Please read this: -

Re: [akka-user] Akka stream - implements Pause/Resume

Please read this: - http://blog.akka.io/integrations/2016/08/29/connecting-existing-apis - and this: http://doc.akka.io/docs/akka/2.4/scala/stream/stream-customize.html Specifically, your trigger should be implemented as async-callback, as it comes from the outside but should "wake up" the stage

Re: [akka-user] Re: Completion of a Graph with a Cycle

Have you seen http://doc.akka.io/docs/akka/2.4/scala/stream/stream-dynamic.html#Controlling_graph_completion_with_KillSwitch ? -- Konrad `ktoso` Malawski Akka @ Lightbend On 12 October 2016 at 15:42:01, external.stefan.wach...@bosch-si.com (

Re: [akka-user] Re: Memory leak: unexpected mailbox filling up

That problem does not happen in Akka Streams, it explicitly manages flow-control by the way. On Thu, Oct 6, 2016 at 10:03 AM, Viktor Klang wrote: > Of course it builds up if you can't process the messages equal-or-faster > than you get them? > > -- > Cheers, > √ > > On

Re: [akka-user] Control how much cpu are used by the actor system?

That's what containers are for though. Run your jvm in a container and restrict resources available to that one On 30 Sep 2016 19:48, "Roland Kuhn" wrote: > Hi Jean-François, > > the JVM does not offer the functionality you seek, you'll have to use your > operating system’s

Re: [akka-user] akka 2.4.10 - connection reset by peer when consuming stream with parallelism == 1

That means the other side has closed the connection. It could be an idle timeout. Are you sure data is consistently flowing, and not being idle for minutes? On 30 Sep 2016 16:59, "Eric Torti" wrote: > Hey guys, > > I am new to akka streams so I may be missing something big

Re: [akka-user] Unmarshalling using javadsl

If you're a Java user I'm not quite sure how you arrived at the concept of per request actors, esp implemented like that. a) This won't work - completing must be done in a route. And ... b) use the entityAs() directive, it is documented, please check the docs. Also:

Re: [akka-user] Akka HTTP Stream listener stops processing databytes after a while

Add a log() stage to the flow. -- Konrad `ktoso` Malawski Akka @ Lightbend On 28 September 2016 at 14:21:28, Tal Beno (tal.b...@gmail.com) wrote: I have an app which has 3 HTTP listeners like this one: val futureResponse1: Future[HttpResponse] =

Re: [akka-user] Streams - Tcp outgoing reconnecting

Please check akka/* repositories :-) Such as akka/akka-stream-contrib – akka-contrib-extra is not a supported thing and was mostly driven by conductr some time ago, not very alive right now. In fact, we do have new reconnection facilities in that repo:

Re: [akka-user] [Akka Stream] Happens-before relation and runForEach

final Source source = // ... final MutableInt max = new MutableInt(Integer.MIN_VALUE); final Procedure f = i -> { if (i > max.intValue()) { max.setValue(i); } }; final CompletionStage result = source .runForeach(f, materializer)

Re: [akka-user] Scala Akka Alignment

You can see which version of Scala an Akka artifact is released for by looking at the artifact names: http://search.maven.org/#search%7Cga%7C1%7Ca%3A%22akka-remote_2.11%22 So as you see, it's released for 2.11. That you're talking about jar files makes me thing you're mixing different akka

Re: [akka-user] [Akka-HTTP] Request for comment - Post render regex modifier

6 at 2:53:59 PM UTC-4, Konrad Malawski wrote: > > Hi Derek, > could you re-post this on github.com/akka/akka-http? > I want to have a look but having a very chaotic week - it'd help me/us to > have it as ticket - easier to find and come back to it than on akka-user. > > I think

Re: [akka-user] [Akka-HTTP] Request for comment - Post render regex modifier

Hi Derek, could you re-post this on github.com/akka/akka-http? I want to have a look but having a very chaotic week - it'd help me/us to have it as ticket - easier to find and come back to it than on akka-user. I think we should be able to help in some way or another if servers are doing "weird

Re: [akka-user] OneForOneStrategy thread safety

That depends what you do inside it though. My itself it is safe, it's just a function pretty much. Unless you side effect inside it it's fine. On 15 Sep 2016 4:47 p.m., "Wei" wrote: > Hello, > > Is OneForOneStrategy class thread safe? Can I share one instance of this > class

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

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] Enjoying Akka HTTP performance

> >>> >>> Am Montag, 12. September 2016 14:52:48 UTC+2 schrieb √: >>>> >>>> What does wrk2 say? >>>> >>>> On Mon, Sep 12, 2016 at 2:37 PM, Christian Schmitt < >>>> c.sc...@briefdomain.de> wrote: >>>> &

Re: [akka-user] Enjoying Akka HTTP performance

a-http isn't something I wonder about. You'd be surprised what node people claim about its performance ;-) Am Montag, 12. September 2016 12:12:29 UTC+2 schrieb Konrad Malawski: > > Hi Adam, > thanks for sharing the runs! > Your benchmarking method is good - thanks for doing a proper

Re: [akka-user] Enjoying Akka HTTP performance

Hi Adam, thanks for sharing the runs! Your benchmarking method is good - thanks for doing a proper warmup and using wrk2 :-) Notice that the multiple second response times in node basically mean it's not keeping up and stalling the connections (also known as coordinated emission). It's great to

Re: [akka-user] Configuration of SerializationBindings Programmatically?

parseMap +1 -- Konrad `ktoso` Malawski Akka @ Lightbend On 9 September 2016 at 22:10:33, Viktor Klang (viktor.kl...@gmail.com) wrote: ConfigFactory.parseMap? -- Cheers, √ On Sep 9, 2016 22:01, "kraythe" wrote: > Yeah, that much I

Re: [akka-user] Any form of first-try / first-peek at Artery Akka remoting ?

Yes we're working on it. Yes there's releases, just use them ;-) See 2.4-ARTERY versions: http://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22com.typesafe.akka%22%20AND%20a%3A%22akka-remote_2.11%22 -- Konrad `ktoso` Malawski Akka @ Lightbend On 8

Re: [akka-user] Akka HTTP performance in 2.4.9

Without looking at the code, two things to fix right away in your methodology: 1) You're running `ab` without persistent connections (also known as "useless mode"). Please run: `ab -k` to use keep-alive connections, which is what all http clients and browsers do. 2) Please do not benchmark using

Re: [akka-user] akka serialization - message boundary

This document talks about serialization in the context of persistence, but many of the patterns are the same for remoting: http://doc.akka.io/docs/akka/snapshot/scala/persistence-schema-evolution.html -- Konrad `ktoso` Malawski Akka @ Lightbend On 6

Re: [akka-user] akka serialization - message boundary

Hi there, not quite. If you use java serialization of X that contains Y things, then Java serialization serializes the entire thing. For example, if you serialized a List using java serialization, it also will serialize the things inside the list - that's how it works. Akka always wraps your

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

This is not really enough information to say where or what the bottlenecks are. If you need a full architecture overview that's a commercial thing we can offer. Having that said, you did not mention what HTTP server you're using. Actors are simply multiplexed onto threads, so if you're doing

[akka-user] ANNOUNCE: Akka Community Survey 2016

Dear hakkers, we did a lot this year already. We merged Akka Streams and HTTP into the 2.4 series of Akka, pushed 16 releases of Akka itself, and maintained the various Persistence plugins. We also reached out to create even more community collaboration with projects related to Kafka, and now are

Re: [akka-user] Problem Configuring ActorSystem

You can also just set the provider to "remote" (or "cluster"). It's a bit simpler to not make a typo in those ;) On Thu, Sep 1, 2016 at 6:14 AM, Viktor Klang wrote: > there's a comma in the class name > > -- > Cheers, > √ > > On Sep 1, 2016 5:11 AM, "Joseph Mansigian"

Re: [akka-user] MalformedRequestContentRejection - typed error messages

Hi Tim, I'm sorry but I don't quite get what you're after here? Since you never know where your handler will be used, there is no way to have it strictly typed. The exception handler should match on the type you're expecting and then do stuff with it. HTH On Thu, Aug 18, 2016 at 5:48 PM, Tim

Re: [akka-user] Unmarshaller not working for HttpEntity for text/html response for "Error in stage [unknown-operation]: Promise already completed"

What Akka version are you on? We have a similar issue reported but in a slightly different place... https://github.com/akka/akka/issues/19981 What is the server responding with specifically? I'd be very suprised if on a normal usual response we fail toStricting() this is used by all tools,

Re: [akka-user] Delay within GraphStageLogic

Hi there, you'd extend TimerGraphStageLogic instead and call scheduleOnce or schedulePeriodicallyWithInitialDelay. The timer will call your onTimer method then. This is all documented here: http://doc.akka.io/docs/akka/2.4.9/scala/stream/stream-customize.html#Using_timers Please read all the

Re: [akka-user] [akka-stream] Multi input/output flow

ards, Sergey четверг, 25 августа 2016 г., 21:16:44 UTC+3 пользователь Konrad Malawski написал: > > If it has more than 1 input and 1 output it's not a Flow anymore, so let's > not refer to it as a Flow. > It's a Graph of a given Shape. > > There's nothing special about Shape, so if you w

Re: [akka-user] [akka-stream] Multi input/output flow

I need something new here. Could you please tell me how to create such multi inlet/outlet shape? Or please explain me if I don't understand something. Thanks a lot! четверг, 25 августа 2016 г., 17:50:00 UTC+3 пользователь Konrad Malawski написал: > > Handlers have no shape. The GraphStage d

Re: [akka-user] [akka-stream] Multi input/output flow

Handlers have no shape. The GraphStage does. So your stage has some shape. And then you set as many handlers as you need. Still simple sources and sinks, but we just published a blog post explaining it a bit more: http://blog.akka.io/integrations/2016/08/25/simple-sink-source-with-graphstage

Re: [akka-user] Akka based java web application deployment in Websphere 7

ctly. I'd like to just mention that this isn't really the optimal way, but I understand it may be a situation of "Either in websphere, or not at all". If able to, Akka deployed standalone as runnable jar is the preferred way, as it's the most lightweight. Hope this helps, happy hakking.

Re: [akka-user] Issue with default query parameters and custom unmarshalling

Hmm... it could be. Quick question – do you perhaps have the ask pattern imported in this file? It could cause ambiguity with the ? from ask I just thought. -- Konrad `ktoso` Malawski Akka @ Lightbend On 22 August 2016 at 18:26:01,

Re: [akka-user] Akka Streams Graph Editor tool

e: Hi again, Omnigraffle is very good program, but I use Windows :( Can you recommend something for it? Thanks! Regards, Sergey воскресенье, 17 июля 2016 г., 16:05:59 UTC+3 пользователь Konrad Malawski написал: > > You may enjoy these Omnigraffle stencils: https://www. > graffleto

Re: [akka-user] [Akka-HTTP] How do I drop the connection from the Server?

FYI for readers of this thread: We chatted this over on twitter https://twitter.com/derekwyatt/status/766652868052918272 In general it is not legal HTTP to not send a response code, so the typical proper way is to Connection: close and a 500 response code I'd say. The really killing a connection

Re: [akka-user] Meaning of the $ in the actor's path

That it's a name generated by akka. You did not name your actor, so a default name was generated for it. Those are generated by using base64 on a sequence number. It's best practice to actually explicitly name your actor btw. On 19 Aug 2016 00:41, "Mark Kaberman" wrote: >

Re: [akka-user] How materialized value is defined?

Please read the docs: http://doc.akka.io/docs/akka/2.4/scala/stream/stream-customize.html#Custom_materialized_values -- Konrad `ktoso` Malawski Akka @ Lightbend On 17 August 2016 at 04:52:22, Guofeng Zhang (guofen...@gmail.com) wrote: Hi, The methods

Re: [akka-user] Re: Access Denied Downloading standalone akka_2.11-2.4.9-RC2.zip

Thanks for reporting, re-uploaded it. S3 was behaving weird it seems. -- Konrad `ktoso` Malawski Akka @ Lightbend On 15 August 2016 at 19:02:56, murtuza chhil (chil...@gmail.com) wrote: Its working now. -chhil On Monday, August 15, 2016 at 8:56:37 AM

Re: [akka-user] What means of akka cluster roles leader?

Duh, my bad. I keep mistaking the use of oldest and leader in this somehow. Thanks for the correction Patrik! On 15 Aug 2016 13:50, "Patrik Nordwall" <patrik.nordw...@gmail.com> wrote: > > > On Mon, Aug 15, 2016 at 11:27 AM, Konrad Malawski < > konrad.malaw...@ligh

Re: [akka-user] What means of akka cluster roles leader?

Hi Yutao, look at the return type – Option, so it's a single element. It returns the leader of a given role (role == multiple nodes, 1 of them is the leader). I.e. it would host the the Singleton if it were constrained to this role. -- Konrad `ktoso` Malawski Akka @ Lightbend

Re: [akka-user] Re: Multipart Fileupload problem with Akka 2.4.8 and 2.4.9-RC1

Hi Scott, OSGi messed up our RC1 release. Sorry for the trouble, though glad we did the RC which is there for finding such issues before we release a stable version. The bug is explained in https://github.com/akka/akka/issues/21105 and I've fixed both root cause and sbt plugin so we'll never have

Re: [akka-user] Stream within Actor Supervision

Stream errors are *in* the stream. It does not blow up the Actor, nor should it. What's your use case? -- Konrad `ktoso` Malawski Akka @ Lightbend On 5 August 2016 at 09:31:16, Gary Struthers (agilej...@earthlink.net) wrote: I think I understand. The

Re: [akka-user] Stream within Actor Supervision

If you write *custom* GraphStages, then *you* need to decide what supervision means in that context – then is supports it: https://github.com/akka/akka/commit/5382014133d01cd38729d731763841680f93a42c#diff-3203199ba389ee802eef94486f26dc88R41 -- Konrad `ktoso` Malawski Akka @

Re: [akka-user] Re: Akka Java IO TLS

I have found handing SSL/TLS from JVM a PITA. Why you don't put the SSL termination in front of the Akka HTTP endpoint (e.g. nginx) ? I'd honestly +1 that (a lot). -- Konrad `ktoso` Malawski Akka @ Lightbend -- >> Read the docs:

Re: [akka-user] Stream within Actor Supervision

Hello there, please read the docs on Stream error handling: http://doc.akka.io/docs/akka/2.4.9-RC1/scala/stream/stream-error.html#stream-error-scala -- Konrad `ktoso` Malawski Akka @ Lightbend On 4 August 2016 at 23:47:27, Gary Struthers

Re: [akka-user] Akka Stream

defined by the source. On Thursday, 4 August 2016 13:57:28 UTC+1, Konrad Malawski wrote: > > Yes, this is the right place. > Announcements are here, as well as general community discussions. > > For news only you may want to subscribe to: akka.io/news > And for blogs from the core t

Re: [akka-user] Re: Multipart Fileupload problem with Akka 2.4.8 and 2.4.9-RC1

Glad that was it Scott. I'd recommend keeping an akka.version property in properties in Maven, and bump it there each time instead of specifically keeping the version in all dependencies explicitly. Hope this helps, happy hakking! -- Konrad `ktoso` Malawski Akka @ Lightbend

Re: [akka-user] Akka Stream

Yes, this is the right place. Announcements are here, as well as general community discussions. For news only you may want to subscribe to: akka.io/news And for blogs from the core team there's akka.io/blog -- Konrad `ktoso` Malawski Akka @ Lightbend On

Re: [akka-user] Akka Cluster (with Sharding) not working without auto-down-unreachable-after

Just to re-affirm what Justin wrote there. Auto downing is "auto". It's dumb. That's why it's not safe. The safer automatic downing modes ones are in doc.akka.io/docs/akka/rp-16s01p05/scala/split-brain-resolver.html Yes, that's a commercial thing. If you don't want to use these, use EC2's APIs -

Re: [akka-user] Re: [ANNOUNCE] Akka 2.4.9-RC1 Released! (Akka HTTP Performance and Entity Streaming)

Hi Jason, sadly the sbt-osgi plugin did something rather silly (I went in and fixed the plugin today) breaking the release if Java Marshallers are used. See here for details and workaround: https://github.com/akka/akka/issues/21105 Thanks for trying out the release candidate and thanks for your

Re: [akka-user] Re: How to read XML inputstream (with SAX parser) received by akka-http?

Yeah, that'd be good to collect usecases and demadn there. Though with SAX it won't be automagical ever, they always require manually writing the parsing AFAIR -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 August 2016 at 10:29:21, André

Re: [akka-user] Re: Websockets and Flow.fromSinkAndSource

Please read the docs on this topic: http://doc.akka.io/docs/akka/2.4/scala/http/client-side/websocket-support.html#Half-Closed_WebSockets -- Konrad `ktoso` Malawski Akka @ Lightbend On 1 August 2016 at 20:17:56, Aditya Prasad (akpra...@gmail.com) wrote:

Re: [akka-user] Default for akka.http.server.remote-address-header

If you need it, you'll find the option. Why make everyone pay the price of fabricating that header :-) Also, it's a bit weird – people are not expecting headers that were not in the request to show up. It's a more natural learning curve that you discover the feature and opt into it. -- Konrad

Re: [akka-user] Re: [akka-streams] Trying to mimic socket level programming , connect client and then send data if connection is available

Source.single completes the stream (closes the connection) once it has signalled the data. Simply put a Source.maybe behind it (a.concat(b)) or use a different source, like unfold or an iterator). -- Konrad `ktoso` Malawski Akka @ Lightbend On 1 August

Re: [akka-user] Get ActorSystem as part of a stream materialization process

(feel free to copy paste the entire impl and use as-is if you want to btw) -- Konrad `ktoso` Malawski Akka <http://akka.io> @ Lightbend <http://lightbend.com> On 31 July 2016 at 00:52:56, Konrad Malawski (konrad.malaw...@lightbend.com) wrote: I like the idea, this can indeed be

Re: [akka-user] Get ActorSystem as part of a stream materialization process

tor and kill the stream using KillSwitch, once master actor shuts down. As an alternative I can probably create a branch in the flow, filter off all the possible events/messages and attach the master actor as a Sink.actorRef. WDYT? Thanks. WBR, Alexey On Sat, Jul 30, 2016 at 1:41 PM, Kon

Re: [akka-user] Get ActorSystem as part of a stream materialization process

Not using safe APIs. But instead I'd turn around the question and ask what you're trying to achieve? Perhaps there's a cleaner way than reaching out to the ActorSystem. -- Konrad `ktoso` Malawski Akka @ Lightbend On 30 July 2016 at 22:39:47, oleksiys

Re: [akka-user] Why isn't akka PersistenceQuery using the Event Adapter configuration?

I believe this was by design actually if I remember correctly, as we considered the read side may want to operate on the raw events by default. Let's say that in the same app that needs adapters for the PersistentActors you want to project a view from historical data, thus you may not want to

Re: [akka-user] Dose akka suit parallelism?

Concurrency enables parallelism. So yes. -- Konrad `ktoso` Malawski Akka @ Lightbend On 27 July 2016 at 08:11:51, Qr Wang (zodi...@gmail.com) wrote: Hello everyone, I know akka is a concurrency framework.But does it fit parallelism coding?Or just use --

Re: [akka-user] High-level Server-Side API Minimal Example not working

Hi there, I just copy pasted the file and have to say "it works here". Are you sure you have dependencies for akka-http-experimental in your build? It works since ContentTypes is part of the akka.http.scaladsl.model package, and that we've imported all the symbols from at the top of the file:

Re: [akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

Well the node leaving does nothing but shut down. The other nodes go on with life of course. That's exactly the problem though: You exit the JVM before anyone has the chance to even receive the Leave message. You should await the gossip message, basically: Cluster.subscribe(self,

Re: [akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

What do you do after you call leave? -- Konrad `ktoso` Malawski Akka @ Lightbend On 25 July 2016 at 20:27:29, kraythe (kray...@gmail.com) wrote: In our code prior to shutting down a node we issue the following call. val cluster: Cluster =

Re: [akka-user] Re: akka-http web socket issue

Yes it works. What's wrong about Streamed? That's a feature that it's streaming the data – consume it using the dataBytes contained in the Streamed message. -- Konrad `ktoso` Malawski Akka @ Lightbend On 21 July 2016 at 10:45:03, allobi...@gmail.com

Re: [akka-user] Error about download akka proj from github and open it as a proj in intellij

Hi Leo, what PR are you working on? But I found out there are lots of errors in build.sbt in every directory. For instance, For the most part you can ignore these if intellij doesn't pick them up. The import into intellij from sbt feature works properly. And, I create a test.scala in

Re: [akka-user] akka http client only excecute the `max-connections` times ~

You're not using the data you've requested, thus stalling the connections. This is by design. Akka HTTP is a *streaming* HTTP Client. Please read the docs about this: http://doc.akka.io/docs/akka/2.4/scala/http/implications-of-streaming-http-entity.html -- Konrad `ktoso` Malawski Akka

Re: [akka-user] How to use WebSockets with ActorPublisher?

e to ActorPublisher : > > Source.actorRef[User.OutgoingMessage](10, OverflowStrategy.fail). > mapMaterializedValue > > the actorRef can be passed to a different Actor that would feed it > messages and it would all behave like ActorPublisher, right? > > On Wednesday, July 20, 2016 at 4:21:35 PM U

Re: [akka-user] Creating Actor w/ Props having Value Class Argument(s)

right constructor (always / safely) in runtime. Thanks On Wednesday, July 20, 2016 at 9:44:33 AM UTC-4, Konrad Malawski wrote: > > Because the type (wrapper) is not there at runtime. > AnyVal is a Scala compiler optimisation, so we can't figure out the right > constructor (always / safel

Re: [akka-user] How to use WebSockets with ActorPublisher?

ChangeSource = Source.fromPublisher(stateChangePublisher) And I can send messages to stateChangePublisherRef and push them to Browser... On Wednesday, July 20, 2016 at 4:07:13 PM UTC+2, Konrad Malawski wrote: > > Could you provide a sample snippet that we could help out with? > Context help

Re: [akka-user] How to use WebSockets with ActorPublisher?

Could you provide a sample snippet that we could help out with? Context helps to get quicker help. -- Konrad `ktoso` Malawski Akka @ Lightbend On 20 July 2016 at 16:03:30, Jakub Liska (liska.ja...@gmail.com) wrote: hey, I hit a deadend with combination

Re: [akka-user] Creating Actor w/ Props having Value Class Argument(s)

Because the type (wrapper) is not there at runtime. AnyVal is a Scala compiler optimisation, so we can't figure out the right constructor (always / safely) in runtime. A resolution would be to "if thing has one field, and that value matches we use that field" which could lead to very weird

Re: [akka-user] Re: Make HTTPS request using akka-http to jenkins server

Pretty sure there's a stack trace there though? What happens on default settnigs – dont manually set the JVM default context. -- Konrad `ktoso` Malawski Akka @ Lightbend On 20 July 2016 at 14:13:39, Ajinkya Shukla (ajinkyashukl...@gmail.com) wrote: I get

Re: [akka-user] Make HTTPS request using akka-http to jenkins server

Please read: http://doc.akka.io/docs/akka/2.4.8/scala/http/client-side/client-https-support.html#clientsidehttps and: http://typesafehub.github.io/ssl-config/ Note that you're using SSLContext.getDefault, pretty sure that's not a good idea for you. Also, what's the error? Please post the

Re: [akka-user] Re: Akka WebSocket as an Api

Wanted to ask about your considerations for tradeoffs for using Play vs straight Akka-Http-Stream and Websockets? Akka is a toolkit. Play is a framework. If it's a "web app" Play would be better. If it's "raw api" I would recommend Akka HTTP though quite honestly it's a personal preference thing

Re: [akka-user] Re: actor lookup and restart

Don't do static global state, it's a bad code smell in general. -- Konrad `ktoso` Malawski Akka @ Lightbend On 19 July 2016 at 10:05:11, James (breath...@gmail.com) wrote: Thank you Rob, Another way is to pass the actorRef to a static object, which can

Re: [akka-user] Akks in Scala console

You're missing a bunch of dependencies, you also need akka-actor, akka-http-experimental, akka-http-core etc. Please use a proper build tool, like sbt in which you can add: in build.sbt: libraryDependencies += "com.typesafe.akka" %% "akka-http-spray-json-experimental" % "2.4.8" this will

Re: [akka-user] Akka Streams Graph Editor tool

You may enjoy these Omnigraffle stencils: https://www.graffletopia.com/stencils/1493 by Derek Wyatt -- Konrad `ktoso` Malawski Akka @ Lightbend On 16 July 2016 at 17:44:18, Sergey Sopin (sopin1...@gmail.com) wrote: Hi, Is there any tool which allows to

Re: [akka-user] SBT dependencies for Akka Sample Twitter Streaming Activator Template

I'd propose you open a ticket in that persons / projects github repo: https://github.com/vrcod/akka-sample-twitter-streaming#master It's more likely to result in some response the nearer to the project this is communicated. You also can submit a PR updating the deps, I'm sure the guy would be

Re: [akka-user] problem connecting with TCP for file IO

simply from.via(thingy) etc. Hope that's it, if not let me know and will have a proper look tomorrow. Cheers -- Konrad Malawski From: debasish <ghosh.debas...@gmail.com> <ghosh.debas...@gmail.com> Reply: akka-user@googlegroups.com <akka-user@googlegroups.com> <akka-user@googl

Re: [akka-user] Re: CORS Support Akka-http

Use the community provided ones. There's no need for us to ship one if community has stepped up and provided libraries, as is the case here I believe :-) -- Konrad `ktoso` Malawski Akka @ Lightbend On 14 July 2016 at 15:26:04, Matan Safriel

Re: [akka-user] akka-http receiving file upload without copying the file to memory

m> On 13 July 2016 at 16:04:14, Simao Mata (sima...@gmail.com) wrote: Ah, that explains it then. I am using `formFields('file.as[StrictForm.FileData])` to extract the file from the form. So is there a way I can get that data and not put it in memory? Thanks! On Wed, Jul 13, 2016, at 1

Re: [akka-user] General Question on AKKA

Like we explained many times, Akka Streams is NOT competing with Spark nor Flink–it's complementing them. Those are distributed stream processing engines. Akka Streams is a building block, that could be used to build such. So the question asked here can be translated as "Hadoop or Iterator?",

Re: [akka-user] Using WithoutSizeLimit of akka-http on specific route entity than using max-content-length setting at config level

All directives have proper documentation, please read it: http://doc.akka.io/docs/akka/2.4.8/scala/http/routing-dsl/directives/misc-directives/withoutSizeLimit.html#example Happy hakking -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 July 2016 at

Re: [akka-user] Exception during Actor construction

Please read the cluster docs: http://doc.akka.io/docs/akka/2.4/java/cluster-usage.html#A_Simple_Cluster_Example as the error hints at. -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 July 2016 at 09:23:56, Drisha Roy (drish...@gmail.com) wrote: hi, I

[akka-user] ANNOUNCE: Akka 2.4.8 released!

of those in the future. Thanks a lot! Credits: commits added removed 121292 176 Konrad Malawski 71251 41 Hawstein 5 314 41 Patrik Nordwall 4 81 23 Endre Sándor Varga 4 758 35 gosubpl 3 97 10 Richard Imaoka 3 3

Re: [akka-user] Re: [ANNOUNCE] Announcing the new Akka Team Blog (Let it Crash!)

I added some rel links, that's likely it. Thanks for rasing the issue :) On Jul 6, 2016 19:59, "Andrew Gaydenko" wrote: > Thanks! > At that moment for some reason Firefox hasn't found the refs. Now it does. > Sorry for noise. > > -- > >> Read the docs:

[akka-user] [ANNOUNCE] Announcing the new Akka Team Blog (Let it Crash!)

Dear hakkers, We're very excited to be able to introduce the new and fresh Akka Team Blog! It's available here: blog.akka.io And we've already kick started it with 2 posts: - An Akka Community Update (July 2016) in which

[akka-user] Re: Akka/Spray CPU usage is 100%

I'd suggest moving over to Akka HTTP (as Spray hasn't been developed since 2 years or so). See Akka documentation for using Akka HTTP -- Konrad On Monday, 6 June 2016 18:45:03 UTC+2, abhishek jain wrote: > > I have created a very basic Restful service in Spary. Locally it is all > working

Re: [akka-user] Re: Akka-Http perf difference chunked vs non-chunked

Right we have a ticket that sounds rather similar I believe (auto toStricting up unto a given limit), I agree it's a good idea. -- Konrad `ktoso` Malawski Akka @ Lightbend On 3 June 2016 at 11:21:00, daleksan (david.aleksandrow...@gmail.com) wrote: I can

Re: [akka-user] Considerations when pushing millions of messages through DistributedPubSub?

(Which is the reason we're currently re-implementing remoting, to be able to survive rates of up to a million per second - more on github.com/akka/akka-meta). -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 June 2016 at 22:20:24, loe...@posteo.de

Re: [akka-user] Using Akka HTTP and another lib that also requires an ActorSystem

Don't use objects ;-) Use classes, and pass the system around to those who need it. class MyRepo(system: ActorSystem) { ... } -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 June 2016 at 12:33:23, Luciano Molinari (lucmolin...@gmail.com) wrote: Hi

Re: [akka-user] akka directive for uploading multiple files

Look into the implementation of the directive and extend it for multiple I'd say. We'd be very happy to accept a PullRequest with such feature! -- Konrad `ktoso` Malawski Akka @ Lightbend On 2 June 2016 at 08:25:43, Leo Wolf (leo.lai.w...@gmail.com)

Re: [akka-user] Am I Reinventing the Wheel?

I was working on a supervisor that lazy creates actors based on some key and then will forward messages to that actor. That's Cluster Sharding :-) http://doc.akka.io/docs/akka/snapshot/scala/cluster-sharding.html Technically you can use it on one node too, yeah. Happy hAkking! -- Konrad

Re: [akka-user] spray cache and akka http

I made a ticket for it, we'd happily someone do the porting / contribution: https://github.com/akka/akka/issues/20679 -- Konrad `ktoso` Malawski Akka @ Lightbend On 1 June 2016 at 09:48:12, Mohnish Kodnani (mohnish.kodn...@gmail.com) wrote: Hi, We have a

<    1   2   3   4   5   6   7   8   9   10   >