Quick Background I am running through some examples learning the Akka HTTP stack for creating a new REST project (completely non-UI). I have been using and augmenting the Akka HTTP Microservice Example to work through a bunch of use cases and configurations and have been pleasantly surprised by how well Scala & Akka HTTP work. … Read more
I’m new to Scala, and this problem frustrates me. How can I get all headers from request? val route = { path(“lol”) { //get httpHeaders complete(HttpResponse()) } } Answer You have at least two options here: a) Using extractRequest directive: val route = { path(“example”) { extractRequest { request => request.headers // Returns `Seq[HttpHeader]`; do … Read more
I’m trying out Akka-http and hopefully someone can shed light on a the following questions: How does one create different routes based on the accept: header in the request? For example, i want one code path to handle “json” and one to handle “xml” requests (with default to “json” if header is missing) In cases … Read more
I’m using akka streams and I have a segment of my graph that I need to conditionally skip because the flow can’t handle certain values. Specifically, I have a flow that takes a string and makes http requests, but the server can’t handle the case when the string is empty. But I need to just … Read more
I’ve just started testing out the Akka HTTP Request-Level Client-Side API (Future-Based). One thing I’ve been struggling to figure out is how to write a unit test for this. Is there a way to mock the response and have the future completed without having to actually do an HTTP request? I was looking at the … Read more
I’m trying to write a tool for batch data upload using Akka HTTP 2.0-M2. But I’m facing akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error. I tried to isolate a problem and here is the sample code which also fails: public class TestMaxRequests { private static final class Router extends HttpApp { @Override public Route … Read more
I currently have a directive that I’m using to secure resources in an Akka HTTP app, like so: def authenticate: Directive1[Login] = optionalHeaderValueByName(“Authorization”) flatMap { val accessToken = authz.split(‘ ‘).last case Some(authz) => LoggedInUser findByAccessToken accessToken match { case Some(user) => provide(user) case None => reject(AuthorizationFailedRejection) } case None => reject(AuthorizationFailedRejection) } where LoggedInUser.findByAccessToken() makes … Read more
I need to consume a REST service using Akka’s HTTP client (v2.0.2). The logical approach is to do this via a host connection pool because we expect large numbers of simultaneous connections. The Flow for this consumes a (HttpRequest, T) and returns a (Try[HttpResponse, T). The documentation indicates that some arbitrary type T is needed … Read more
One of the features of Akka HTTP (formally known as Spray) is its ability to automagically marshal and unmarshal data back and forth from json into case classes, etc. I’ve had success at getting this to work well. At the moment, I am trying to make an HTTP client that performs a GET request with … Read more
Can someone please explain the major differences between Akka HTTP and Netty? Netty offers other protocols like FTP as well. Akka HTTP can be used in Scala and Java and is build on the actor model. But apart from this both are asynchronous. When would I use Akka HTTP and when Netty? What are the … Read more
