update akka version (#137)

Author: BrandonArp

pom.xml

@@ -71,8 +71,8 @@
 
   <properties>
     <!--Dependency versions-->
-    <akka.version>2.5.13</akka.version>
-    <akka.http.version>10.1.3</akka.http.version>
+    <akka.version>2.5.16</akka.version>
+    <akka.http.version>10.1.5</akka.http.version>
     <apache.httpclient.version>4.5.5</apache.httpclient.version>
     <apache.httpcore.version>4.4.9</apache.httpcore.version>
     <arpnetworking.commons.version>1.16.1</arpnetworking.commons.version>

src/main/java/com/arpnetworking/http/Routes.java

@@ -32,7 +32,6 @@
 import akka.http.javadsl.model.ws.Message;
 import akka.japi.JavaPartialFunction;
 import akka.japi.function.Function;
-import akka.japi.pf.PFBuilder;
 import akka.pattern.PatternsCS;
 import akka.stream.OverflowStrategy;
 import akka.stream.javadsl.Flow;
@@ -105,10 +104,10 @@ public Routes(
     public Flow<HttpRequest, HttpResponse, NotUsed> flow() {
         return Flow.<HttpRequest>create()
                 .mapAsync(1, this)
-                .recover(
-                        new PFBuilder<Throwable, HttpResponse>()
-                                .match(Exception.class, e -> HttpResponse.create().withStatus(StatusCodes.INTERNAL_SERVER_ERROR))
-                                .build());
+                .recoverWithRetries(
+                        0,
+                        Exception.class,
+                        () -> Source.single(HttpResponse.create().withStatus(StatusCodes.INTERNAL_SERVER_ERROR)));
     }
 
     @Override