@Test public void testExtractProperties() { Map<String, Object> result = RouterActorRefPropertyExtractor.INSTANCE.extractProperties(tested); assertKeysExist(Arrays.asList("local", "Router Dispatcher", "Router"), result.keySet()); }
public Map<String, Object> extractProperties(ActorRef actorRef) { RoutedActorRef ref = (RoutedActorRef) actorRef; Map<String, Object> result = new HashMap<String, Object>(); RouterConfig routerConfig = ref.routerConfig(); result.putAll(AkkaRouterConfigHelper.getInstance().getRouterConfigInformation(routerConfig)); result.put("local", Boolean.valueOf(ref.isLocal())); return result; }
RouterActorRefPropertyExtractor implements ActorRefPropertyExtractor { public Map<String, Object> extractProperties(ActorRef actorRef) { RoutedActorRef ref = (RoutedActorRef) actorRef; Map<String, Object> result = new HashMap<String, Object>(); RouterConfig routerConfig = ref.routerConfig(); result.putAll(AkkaRouterConfigHelper.getInstance().getRouterConfigInformation(routerConfig)); result.put("local", Boolean.valueOf(ref.isLocal())); return result; } }
RouterActorRefPropertyExtractor implements ActorRefPropertyExtractor { public Map<String, Object> extractProperties(ActorRef actorRef) { RoutedActorRef ref = (RoutedActorRef) actorRef; Map<String, Object> result = new HashMap<String, Object>(); RouterConfig routerConfig = ref.routerConfig(); result.putAll(AkkaRouterConfigHelper.getInstance().getRouterConfigInformation(routerConfig)); result.put("local", Boolean.valueOf(ref.isLocal())); return result; } private  RouterActorRefPropertyExtractor(); }
RouterActorRefPropertyExtractor implements ActorRefPropertyExtractor { public Map<String, Object> extractProperties(ActorRef actorRef) { RoutedActorRef ref = (RoutedActorRef) actorRef; Map<String, Object> result = new HashMap<String, Object>(); RouterConfig routerConfig = ref.routerConfig(); result.putAll(AkkaRouterConfigHelper.getInstance().getRouterConfigInformation(routerConfig)); result.put("local", Boolean.valueOf(ref.isLocal())); return result; } private  RouterActorRefPropertyExtractor(); Map<String, Object> extractProperties(ActorRef actorRef); }
RouterActorRefPropertyExtractor implements ActorRefPropertyExtractor { public Map<String, Object> extractProperties(ActorRef actorRef) { RoutedActorRef ref = (RoutedActorRef) actorRef; Map<String, Object> result = new HashMap<String, Object>(); RouterConfig routerConfig = ref.routerConfig(); result.putAll(AkkaRouterConfigHelper.getInstance().getRouterConfigInformation(routerConfig)); result.put("local", Boolean.valueOf(ref.isLocal())); return result; } private  RouterActorRefPropertyExtractor(); Map<String, Object> extractProperties(ActorRef actorRef); static final RouterActorRefPropertyExtractor INSTANCE; }