ApressJavaCode
diff --git a/‎akka-http/src/main/java/com/baeldung/akkahttp/AkkaHttpServer.java‎
Lines changed: 11 additions & 9 deletions b/‎akka-http/src/main/java/com/baeldung/akkahttp/AkkaHttpServer.java‎
Lines changed: 11 additions & 9 deletions
diff --git a/‎akka-http/src/main/java/com/baeldung/akkahttp/UserRegistryMessages.java‎
Lines changed: 2 additions & 0 deletions b/‎akka-http/src/main/java/com/baeldung/akkahttp/UserRegistryMessages.java‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎akka-http/src/main/java/com/baeldung/akkahttp/UserRoutes.java‎
Lines changed: 4 additions & 1 deletion b/‎akka-http/src/main/java/com/baeldung/akkahttp/UserRoutes.java‎
Lines changed: 4 additions & 1 deletion
@@ -23,17 +23,19 @@ public AkkaHttpServer(ActorSystem system, ActorRef userRegistryActor) {
     }
 
     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/");
-    }
+        System.out.println("Server is online at http://localhost:8080/");
+    }
+}
@@ -1,5 +1,7 @@
 package com.baeldung.akkahttp;
 
+import java.io.Serializable;
+
 /**
  * Defines all messages related to User Actor
  * 
 
@@ -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.Route;
 import akka.pattern.PatternsCS;
 import akka.util.Timeout;
+import scala.concurrent.duration.Duration;
 
 public class UserRoutes extends AllDirectives {
Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,7 @@`
`1`	`1`	`package com.baeldung.akkahttp;`
`2`	`2`
	`3`	`+import java.io.Serializable;`
	`4`	`+`
`3`	`5`	`/**`
`4`	`6`	`* Defines all messages related to User Actor`
`5`	`7`	`*`