source: java/main/src/main/java/com/framsticks/observers/Observer.java @ 86

Last change on this file since 86 was 86, checked in by psniegowski, 11 years ago

HIGHLIGHTS:

  • use java annotations to mark classes and fields to be used when:
    • using java classes with ReflectionAccess? to represent remote objects with FramsClass? description found by "info ..." requests
    • to build up FramsClass? representation of objects not present at remote server
  • allow using primitive types (instead of wraping counterparts) in reflected classes
  • rework FramsClass? creation process (add FramsClassBuilder?)
  • add more tests

CHANGELOG:
Prepare model.World class.

Minor change.

Use primitive types for Genotype and Creature classes.

Use primitive types in model.Neuro* classes.

Use primitive types in model.Joint* classes.

Use primitive types in model.Part* classes.

Fix primitive values.

Extract FramsClassBuilder?.

Add tests of Model classes.

More fixes.

Refactorize out ParamCandidate?.

Several fixes.

Fix all regressions after introducing annotations.

Use annotations throughout the project.

Add exception classes.

Improve creation of FramsClass?.

More changes.

Many changes regarding annotations.

Annotate classes in com.framsticks.model package.

Remove manual FramsClass? constructor.

Construct FramsClass? for Creature. Add test.

Add default values to the ParamAnnotation?.

Add ParamBuilderTest? and ParamAnnotation?.

Add FramsClassAnnotation?.
File size: 1.9 KB
Line 
1package com.framsticks.observers;
2
3import com.framsticks.core.Entity;
4import com.framsticks.core.Instance;
5import com.framsticks.core.Program;
6import com.framsticks.params.annotations.FramsClassAnnotation;
7import com.framsticks.params.annotations.ParamAnnotation;
8import com.framsticks.util.lang.Casting;
9import org.apache.commons.configuration.Configuration;
10import org.apache.log4j.Logger;
11
12import java.util.*;
13
14/**
15 * @author Piotr Sniegowski
16 */
17@FramsClassAnnotation
18public abstract class Observer extends Entity {
19
20        private final static Logger log = Logger.getLogger(Observer.class.getName());
21
22        public Observer() {
23        }
24
25        @ParamAnnotation
26        protected final Map<String, Endpoint> endpoints = new HashMap<String, Endpoint>();
27
28        protected Endpoint createEndpoint() {
29                return new Endpoint();
30        }
31
32        @Override
33        public void configure(Configuration config) {
34                super.configure(config);
35                for (String n : config.getStringArray("endpoints")) {
36                        if (getEndpoints().containsKey(n)) {
37                                log.fatal("observer already contains endpoint named: " + n);
38                                continue;
39                        }
40                        Configuration instanceConfig = config.subset("endpoints." + n).subset("entity");
41                        Instance i = Casting.tryCast(Instance.class, Program.configureEntity(instanceConfig));
42                        if (i == null) {
43                                log.error("failed to create instance: ");
44                                continue;
45                        }
46                        i.setName(n);
47                        i.configure(instanceConfig);
48                        addEndpointForInstance(i);
49                }
50        }
51
52        public Endpoint addEndpointForInstance(Instance instance) {
53                Endpoint endpoint = createEndpoint();
54                endpoint.configurePublic(this, instance, instance.getName());
55                getEndpoints().put(instance.getName(), endpoint);
56                log.info("instance " + instance + " was added to " + this + " as " + instance.getName());
57                return endpoint;
58        };
59
60        @Override
61        protected void run() {
62                super.run();
63                for (Endpoint e : getEndpoints().values()) {
64                        e.start();
65                }
66        }
67
68
69        public Map<String, Endpoint> getEndpoints() {
70                return endpoints;
71        }
72
73
74
75}
Note: See TracBrowser for help on using the repository browser.