Fix. Call to unnamed actor

Author: sleipnir

README.md

@@ -90,7 +90,7 @@ The second thing we have to do is add the spawn dependency to the project.
 <dependency>
    <groupId>com.github.eigr</groupId>
    <artifactId>spawn-java-std-sdk</artifactId>
-   <version>v0.3.4</version>
+   <version>v0.3.5</version>
 </dependency>
 ```
 We're also going to configure a few things for our application build to work, including compiling the protobuf files. 
@@ -124,7 +124,7 @@ See below a full example of the pom.xml file:
       <dependency>
          <groupId>com.github.eigr</groupId>
          <artifactId>spawn-java-std-sdk</artifactId>
-         <version>v0.3.4</version>
+         <version>v0.3.5</version>
       </dependency>
       <dependency>
          <groupId>ch.qos.logback</groupId>

pom.xml

@@ -4,7 +4,7 @@
     <groupId>io.eigr.spawn</groupId>
     <artifactId>spawn-java-std-sdk</artifactId>
     <packaging>jar</packaging>
-    <version>0.3.4</version>
+    <version>0.3.5</version>
     <name>spawn-java-std-sdk</name>
     <url>http://maven.apache.org</url>
 

src/main/java/io/eigr/spawn/internal/handlers/ActorServiceHandler.java

@@ -12,11 +12,11 @@
 import io.eigr.spawn.api.Value;
 import io.eigr.spawn.api.actors.ActorContext;
 import io.eigr.spawn.api.actors.ActorFactory;
-import io.eigr.spawn.api.exceptions.ActorInvokeException;
 import io.eigr.spawn.api.actors.workflows.Broadcast;
 import io.eigr.spawn.api.actors.workflows.Forward;
 import io.eigr.spawn.api.actors.workflows.Pipe;
 import io.eigr.spawn.api.actors.workflows.SideEffect;
+import io.eigr.spawn.api.exceptions.ActorInvokeException;
 import io.eigr.spawn.internal.Entity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -63,10 +63,10 @@ public void handle(HttpExchange exchange) throws IOException {
 
         if ("POST".equals(exchange.getRequestMethod())) {
             Protocol.ActorInvocationResponse response = handleRequest(exchange);
-            try(OutputStream os = exchange.getResponseBody()) {
+            try (OutputStream os = exchange.getResponseBody()) {
                 byte[] bytes = response.toByteArray();
                 exchange.getResponseHeaders().set("Content-Type", "application/octet-stream");
-                exchange.  sendResponseHeaders(200, bytes.length);
+                exchange.sendResponseHeaders(200, bytes.length);
                 os.write(bytes);
             }
         }
@@ -80,11 +80,12 @@ private Protocol.ActorInvocationResponse handleRequest(HttpExchange exchange) th
             ActorId actorId = actorInvocationRequest.getActor();
             String actor = actorId.getName();
             String system = actorId.getSystem();
+            String parent = actorId.getParent();
             String commandName = actorInvocationRequest.getActionName();
 
             Any value = actorInvocationRequest.getValue();
 
-            Optional<Value> maybeValueResponse = callAction(system, actor, commandName, value, context);
+            Optional<Value> maybeValueResponse = callAction(system, actor, parent, commandName, value, context);
             log.info("Actor {} return ActorInvocationResponse for command {}. Result value: {}",
                     actor, commandName, maybeValueResponse);
 
@@ -114,8 +115,8 @@ private Protocol.ActorInvocationResponse handleRequest(HttpExchange exchange) th
         throw new ActorInvokeException("Action result is null");
     }
 
-    private Optional<Value> callAction(String system, String actor, String commandName, Any value, Protocol.Context context) {
-        Optional<Entity> optionalEntity = getEntityByActor(actor);
+    private Optional<Value> callAction(String system, String actor, String parent, String commandName, Any value, Protocol.Context context) {
+        Optional<Entity> optionalEntity = getEntityByActor(actor, parent);
         if (optionalEntity.isPresent()) {
             Entity entity = optionalEntity.get();
 
@@ -183,10 +184,18 @@ private Object buildInstanceByArg(Entity entity) throws NoSuchMethodException, I
         return constructor.newInstance();
     }
 
-    private Optional<Entity> getEntityByActor(String actor) {
-        return this.entities.stream()
+    private Optional<Entity> getEntityByActor(String actor, String parent) {
+        Optional<Entity> entity = this.entities.stream()
                 .filter(e -> e.getActorName().equalsIgnoreCase(actor))
                 .findFirst();
+
+        if (entity.isPresent()) {
+            return entity;
+        }
+
+        return this.entities.stream()
+                .filter(e -> e.getActorName().equalsIgnoreCase(parent))
+                .findFirst();
     }
 
     private Protocol.Workflow buildWorkflow(Value valueResponse) {