From 632e46c2a0bcde213e278f738879639752d01f9a Mon Sep 17 00:00:00 2001
From: Kotharu <bkotharu@BANL1699b0a1d.local>
Date: Sun, 21 Oct 2018 18:40:44 +0530
Subject: [PATCH] Initial Commit

---
 .../com/baeldung/akkahttp/AkkaHttpServer.java | 20 ++++++++++---------
 .../akkahttp/UserRegistryMessages.java        |  2 ++
 .../com/baeldung/akkahttp/UserRoutes.java     |  5 ++++-
 3 files changed, 17 insertions(+), 10 deletions(-)

diff --git a/akka-http/src/main/java/com/baeldung/akkahttp/AkkaHttpServer.java b/akka-http/src/main/java/com/baeldung/akkahttp/AkkaHttpServer.java
index 03992b6a36..d4c859891a 100644
--- a/akka-http/src/main/java/com/baeldung/akkahttp/AkkaHttpServer.java
+++ b/akka-http/src/main/java/com/baeldung/akkahttp/AkkaHttpServer.java
@@ -23,17 +23,19 @@ public class AkkaHttpServer extends AllDirectives {
     }
 
     public static void main(String[] args) throws Exception {
-            ActorSystem system = ActorSystem.create("helloAkkaHttpServer");
-            final ActorMaterializer materializer = ActorMaterializer.create(system);
+        ActorSystem system = ActorSystem.create("helloAkkaHttpServer");
+        final ActorMaterializer materializer = ActorMaterializer.create(system);
 
-            ActorRef userActorRef = system.actorOf(UserActor.props(), "userActor");
+        ActorRef userActorRef = system.actorOf(UserActor.props(), "userActor");
 
-            AkkaHttpServer app = new AkkaHttpServer(system, userActorRef);
+        AkkaHttpServer app = new AkkaHttpServer(system, userActorRef);
 
-            final Flow<HttpRequest, HttpResponse, NotUsed> routeFlow = app.userRoutes.routes().flow(system, materializer);
+        final Flow<HttpRequest, HttpResponse, NotUsed> routeFlow = app.userRoutes.routes()
+            .flow(system, materializer);
 
-            final CompletionStage<ServerBinding> binding = Http.get(system).bindAndHandle(routeFlow,
-                            ConnectHttp.toHost("localhost", 8080), materializer);
+        final CompletionStage<ServerBinding> binding = Http.get(system)
+            .bindAndHandle(routeFlow, ConnectHttp.toHost("localhost", 8080), materializer);
 
-            System.out.println("Server is online at http://localhost:8080/");
-    }
\ No newline at end of file
+        System.out.println("Server is online at http://localhost:8080/");
+    }
+}
\ No newline at end of file
diff --git a/akka-http/src/main/java/com/baeldung/akkahttp/UserRegistryMessages.java b/akka-http/src/main/java/com/baeldung/akkahttp/UserRegistryMessages.java
index 831819849a..1f88e5f646 100644
--- a/akka-http/src/main/java/com/baeldung/akkahttp/UserRegistryMessages.java
+++ b/akka-http/src/main/java/com/baeldung/akkahttp/UserRegistryMessages.java
@@ -1,5 +1,7 @@
 package com.baeldung.akkahttp;
 
+import java.io.Serializable;
+
 /**
  * Defines all messages related to User Actor
  * 
diff --git a/akka-http/src/main/java/com/baeldung/akkahttp/UserRoutes.java b/akka-http/src/main/java/com/baeldung/akkahttp/UserRoutes.java
index aa3c9b612f..aeddf9224d 100644
--- a/akka-http/src/main/java/com/baeldung/akkahttp/UserRoutes.java
+++ b/akka-http/src/main/java/com/baeldung/akkahttp/UserRoutes.java
@@ -1,10 +1,12 @@
 package com.baeldung.akkahttp;
 
-import java.time.Duration;
 import java.util.Optional;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.TimeUnit;
 
+import com.baeldung.akkahttp.UserRegistryMessages.ActionPerformed;
+import com.baeldung.akkahttp.UserRegistryMessages.CreateUser;
+
 import akka.actor.ActorRef;
 import akka.actor.ActorSystem;
 import akka.event.Logging;
@@ -16,6 +18,7 @@ import akka.http.javadsl.server.PathMatchers;
 import akka.http.javadsl.server.Route;
 import akka.pattern.PatternsCS;
 import akka.util.Timeout;
+import scala.concurrent.duration.Duration;
 
 public class UserRoutes extends AllDirectives {