1 files changed, 165 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-M1-20060522/java/sca/containers/container.java/src/main/java/org/apache/tuscany/container/java/context/JavaAtomicContext.java b/sca-java-1.x/tags/java-M1-20060522/java/sca/containers/container.java/src/main/java/org/apache/tuscany/container/java/context/JavaAtomicContext.java
new file mode 100644
index 0000000000..27581198aa
--- /dev/null
+++ b/sca-java-1.x/tags/java-M1-20060522/java/sca/containers/container.java/src/main/java/org/apache/tuscany/container/java/context/JavaAtomicContext.java
@@ -0,0 +1,165 @@
+/**
+ *
+ *  Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package org.apache.tuscany.container.java.context;
+
+import org.apache.tuscany.core.builder.ObjectFactory;
+import org.apache.tuscany.core.context.AtomicContext;
+import org.apache.tuscany.core.context.ContextInitException;
+import org.apache.tuscany.core.context.QualifiedName;
+import org.apache.tuscany.core.context.TargetException;
+import org.apache.tuscany.core.context.event.InstanceCreated;
+import org.apache.tuscany.core.context.impl.AbstractContext;
+import org.apache.tuscany.core.injection.EventInvoker;
+import org.apache.tuscany.core.injection.ObjectCallbackException;
+import org.apache.tuscany.core.injection.ObjectCreationException;
+
+/**
+ * Manages Java component implementation instances
+ *
+ * @version $Rev$ $Date$
+ */
+public class JavaAtomicContext extends AbstractContext implements AtomicContext {
+
+    private boolean eagerInit;
+
+    private EventInvoker<Object> initInvoker;
+
+    private EventInvoker<Object> destroyInvoker;
+
+    private boolean stateless;
+
+    // the cached target instance
+    private Object cachedTargetInstance;
+
+    // creates a new implementation instance with injected references and properties
+    private ObjectFactory objectFactory;
+
+    public JavaAtomicContext(String name, ObjectFactory objectFactory, boolean eagerInit, EventInvoker<Object> initInvoker,
+                             EventInvoker<Object> destroyInvoker, boolean stateless) {
+        super(name);
+        assert (objectFactory != null) : "Object factory was null";
+        if (eagerInit && initInvoker == null) {
+            ContextInitException e = new ContextInitException("No intialization method found for implementation");
+            e.setIdentifier(getName());
+            throw e;
+        }
+        this.objectFactory = objectFactory;
+
+        this.eagerInit = eagerInit;
+        this.initInvoker = initInvoker;
+        this.destroyInvoker = destroyInvoker;
+        this.stateless = stateless;
+    }
+
+    public void setName(String name) {
+        super.setName(name);
+    }
+
+    protected int type;
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+    public void init() throws TargetException {
+        getInstance(null);
+    }
+
+    public void destroy() throws TargetException {
+        if (cachedTargetInstance != null) {
+            if (destroyInvoker != null) {
+                try {
+                    destroyInvoker.invokeEvent(cachedTargetInstance);
+                } catch (ObjectCallbackException e) {
+                    TargetException te = new TargetException(e.getCause());
+                    te.setIdentifier(getName());
+                    throw te;
+                }
+            }
+        }
+        lifecycleState = STARTED;
+    }
+
+    public synchronized Object getInstance(QualifiedName qName) throws TargetException {
+        //TODO implement returning of proxy and wire chain for service
+        if (cachedTargetInstance != null) {
+            return cachedTargetInstance; // already cached, just return
+        }
+
+        if (getLifecycleState() == ERROR || getLifecycleState() == CONFIG_ERROR) {
+            return null;
+        }
+        synchronized (this) {
+            try {
+                Object instance = objectFactory.getInstance();
+                // handle @Init
+                if (initInvoker != null) {
+                    initInvoker.invokeEvent(instance);
+                }
+                publish(new InstanceCreated(this));
+                lifecycleState = RUNNING;
+                if (stateless) {
+                    return instance;
+                } else {
+                    cachedTargetInstance = instance;  // cache the instance
+                    return cachedTargetInstance;
+                }
+            } catch (ObjectCreationException e) {
+                lifecycleState = ERROR;
+                TargetException te = new TargetException("Error creating component instance", e);
+                te.setIdentifier(getName());
+                throw te;
+            }
+        }
+
+    }
+
+    public Object getTargetInstance() throws TargetException {
+        //TODO refactor when getInstance() returns a proxy
+        return getInstance(null);
+    }
+
+    public boolean isEagerInit() {
+        return eagerInit;
+    }
+
+    public boolean isDestroyable() {
+        return (destroyInvoker != null);
+    }
+
+    public void start() throws ContextInitException {
+        if (getLifecycleState() != UNINITIALIZED && getLifecycleState() != STOPPED) {
+            throw new IllegalStateException("Context must be in UNINITIALIZED state [" + getLifecycleState() + "]");
+        }
+        if (objectFactory == null) {
+            lifecycleState = ERROR;
+            ContextInitException e = new ContextInitException("Object factory not found");
+            e.setIdentifier(getName());
+            throw e;
+        }
+        lifecycleState = INITIALIZED;
+    }
+
+    public void stop() {
+        lifecycleState = STOPPED;
+    }
+
+}