Checkstyle

Author: artem-v

services-api/src/main/java/io/scalecube/services/Reflect.java

@@ -15,7 +15,6 @@
 import io.scalecube.services.auth.Auth;
 import io.scalecube.services.auth.Principal;
 import io.scalecube.services.methods.MethodInfo;
-import java.lang.reflect.Field;
 import java.lang.reflect.Method;
 import java.lang.reflect.Parameter;
 import java.lang.reflect.ParameterizedType;
@@ -27,7 +26,6 @@
 import java.util.function.Function;
 import java.util.stream.Collectors;
 import org.reactivestreams.Publisher;
-import reactor.core.Exceptions;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
@@ -389,15 +387,6 @@ private static boolean isRequestChannel(Method method) {
             || Publisher.class.isAssignableFrom(reqTypes[0]));
   }
 
-  public static void setField(Field field, Object object, Object value) {
-    field.setAccessible(true);
-    try {
-      field.set(object, value);
-    } catch (IllegalAccessException e) {
-      throw Exceptions.propagate(e);
-    }
-  }
-
   public static boolean isService(Class<?> type) {
     return type.isAnnotationPresent(Service.class);
   }

services-api/src/main/java/io/scalecube/services/ServiceInfo.java

@@ -73,15 +73,15 @@ public static class Builder {
     private ServiceMessageDataDecoder dataDecoder;
     private Authenticator authenticator;
 
-    public Builder(ServiceInfo serviceInfo) {
+    private Builder(ServiceInfo serviceInfo) {
       this.serviceInstance = serviceInfo.serviceInstance;
       this.tags.putAll(new HashMap<>(serviceInfo.tags));
       this.errorMapper = serviceInfo.errorMapper;
       this.dataDecoder = serviceInfo.dataDecoder;
       this.authenticator = serviceInfo.authenticator;
     }
 
-    public Builder(Object serviceInstance) {
+    private Builder(Object serviceInstance) {
       this.serviceInstance = serviceInstance;
     }
 

services/src/main/java/io/scalecube/services/Injector.java

@@ -37,7 +37,7 @@ public static Microservices inject(Microservices microservices, Collection<Objec
 
   private static void injectField(Microservices microservices, Field field, Object service) {
     if (field.isAnnotationPresent(Inject.class) && field.getType().equals(Microservices.class)) {
-      Reflect.setField(field, service, microservices);
+      setField(field, service, microservices);
     } else if (field.isAnnotationPresent(Inject.class) && Reflect.isService(field.getType())) {
       Inject injection = field.getAnnotation(Inject.class);
       Class<? extends Router> routerClass = injection.router();
@@ -46,7 +46,16 @@ private static void injectField(Microservices microservices, Field field, Object
         call.router(routerClass);
       }
       final Object targetProxy = call.api(field.getType());
-      Reflect.setField(field, service, targetProxy);
+      setField(field, service, targetProxy);
+    }
+  }
+
+  private static void setField(Field field, Object object, Object value) {
+    try {
+      field.setAccessible(true);
+      field.set(object, value);
+    } catch (Exception e) {
+      throw Exceptions.propagate(e);
     }
   }