1 files changed, 318 insertions, 0 deletions
diff --git a/tags/java/sca/2.0-M3-RC5/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java b/tags/java/sca/2.0-M3-RC5/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java
new file mode 100644
index 0000000000..5823b7d050
--- /dev/null
+++ b/tags/java/sca/2.0-M3-RC5/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java
@@ -0,0 +1,318 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.sca.itest.conversational.impl;
+
+import org.apache.tuscany.sca.itest.conversational.ConversationalClient;
+import org.apache.tuscany.sca.itest.conversational.ConversationalReferenceClient;
+import org.apache.tuscany.sca.itest.conversational.ConversationalService;
+import org.apache.tuscany.sca.itest.conversational.ConversationalServiceNonConversationalCallback;
+import org.apache.tuscany.sca.itest.conversational.NonConversationalCallback;
+import org.oasisopen.sca.ComponentContext;
+import org.oasisopen.sca.ServiceReference;
+import org.oasisopen.sca.annotation.Context;
+import org.oasisopen.sca.annotation.ConversationAttributes;
+import org.oasisopen.sca.annotation.Destroy;
+import org.oasisopen.sca.annotation.Init;
+import org.oasisopen.sca.annotation.Reference;
+import org.oasisopen.sca.annotation.Scope;
+import org.oasisopen.sca.annotation.Service;
+
+/**
+ * The client for the conversational itest which presents a stateful
+ * callback interface
+ *
+ * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $
+ */
+
+@Service(interfaces = {ConversationalClient.class})
+@Scope("CONVERSATION")
+@ConversationAttributes(maxAge = "10 minutes", maxIdleTime = "5 minutes", singlePrincipal = false)
+public class ConversationalClientStatefulNonConversationalCallbackImpl implements ConversationalClient,
+    NonConversationalCallback {
+
+    @Context
+    protected ComponentContext componentContext;
+
+    @Reference
+    protected ConversationalServiceNonConversationalCallback conversationalService;
+
+    @Reference
+    protected ConversationalServiceNonConversationalCallback conversationalService2;
+
+    @Reference
+    protected ConversationalReferenceClient conversationalReferenceClient;
+
+    private int clientCount = 0;
+    private int callbackCount = 0;
+
+    // a static member variable that records the number of times this service is called
+    public static StringBuffer calls = new StringBuffer();
+
+    // From ConversationalClient
+    public int runConversationFromInjectedReference() {
+        calls.append("runConversationFromInjectedReference,");
+        conversationalService.initializeCount(1);
+        conversationalService.incrementCount();
+        clientCount = conversationalService.retrieveCount();
+        conversationalService.endConversation();
+
+        return clientCount;
+    }
+
+    public int runConversationFromInjectedReference2() {
+        calls.append("runConversationFromInjectedReference2,");
+
+        conversationalService2.initializeCount(1);
+        conversationalService2.incrementCount();
+
+        // stick in a call to the first reference to
+        // make sure the two references don't clash
+        conversationalService.initializeCount(1);
+
+        clientCount = conversationalService2.retrieveCount();
+        conversationalService2.endConversation();
+
+        // end the conversation through the first reference
+        conversationalService.endConversation();
+
+        return clientCount;
+    }
+
+    public int runConversationFromServiceReference() {
+        calls.append("runConversationFromServiceReference,");
+        ServiceReference<ConversationalService> serviceReference =
+            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
+        ConversationalService callableReference = serviceReference.getService();
+
+        callableReference.initializeCount(1);
+        callableReference.incrementCount();
+        clientCount = callableReference.retrieveCount();
+        callableReference.endConversation();
+
+        // serviceReference.getConversation().end();
+
+        return clientCount;
+    }
+
+    public int runConversationWithUserDefinedConversationId() {
+        calls.append("runConversationWithUserDefinedConversationId,");
+        ServiceReference<ConversationalService> serviceReference =
+            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
+        serviceReference.setConversationID("MyConversation1");
+
+        ConversationalService callableReference = serviceReference.getService();
+
+        callableReference.initializeCount(1);
+        callableReference.incrementCount();
+        clientCount = callableReference.retrieveCount();
+        callableReference.endConversation();
+
+        // serviceReference.getConversation().end();
+
+        return clientCount;
+    }
+
+    public String runConversationCheckUserDefinedConversationId() {
+        calls.append("runConversationCheckUserDefinedConversationId,");
+        ServiceReference<ConversationalService> serviceReference =
+            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
+        serviceReference.setConversationID("MyConversation2");
+
+        ConversationalService callableReference = serviceReference.getService();
+
+        callableReference.initializeCount(1);
+        callableReference.incrementCount();
+        clientCount = callableReference.retrieveCount();
+        return callableReference.endConversation();
+
+    }
+
+    public int runConversationCheckingScope() {
+        calls.append("runConversationCheckingScope,");
+        // run a conversation
+        return runConversationFromInjectedReference();
+
+        // test will then use a static method to find out how many times
+        // init/destroy were called
+    }
+
+    public int runConversationWithCallback() {
+        calls.append("runConversationWithCallback,");
+        callbackCount = 2;
+        conversationalService.initializeCountCallback(1);
+        conversationalService.incrementCountCallback();
+        clientCount = conversationalService.retrieveCountCallback();
+        conversationalService.endConversationCallback();
+
+        return clientCount;
+    }
+
+    public int runConversationHavingPassedReference() {
+        calls.append("runConversationHavingPassedReference,");
+        ServiceReference<ConversationalService> serviceReference =
+            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
+        ConversationalService callableReference = serviceReference.getService();
+
+        callableReference.initializeCount(1);
+        callableReference.incrementCount();
+        conversationalReferenceClient.incrementCount(serviceReference);
+        clientCount = callableReference.retrieveCount();
+        callableReference.endConversation();
+
+        // serviceReference.getConversation().end();
+
+        return clientCount;
+    }
+
+    public String runConversationBusinessException() {
+        calls.append("runConversationbusinessException,");
+        try {
+            conversationalService.initializeCount(1);
+            conversationalService.businessException();
+            clientCount = conversationalService.retrieveCount();
+            conversationalService.endConversation();
+        } catch (Exception ex) {
+            return ex.getMessage();
+        }
+
+        return "No Exception Returned";
+    }
+
+    public String runConversationBusinessExceptionCallback() {
+        calls.append("runConversationbusinessExceptionCallback,");
+        try {
+            conversationalService.initializeCountCallback(1);
+            conversationalService.businessExceptionCallback();
+            clientCount = conversationalService.retrieveCountCallback();
+            conversationalService.endConversationCallback();
+        } catch (Exception ex) {
+            return ex.getMessage();
+        }
+
+        return "No Exception Returned";
+    }
+
+    public String runConversationCallingEndedConversationCheckConversationId() {
+        calls.append("runConversationCallingEndedConversationCheckConversationId,");
+        ServiceReference<ConversationalService> serviceReference =
+            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
+        serviceReference.setConversationID("MyConversation3");
+
+        ConversationalService callableReference = serviceReference.getService();
+
+        callableReference.initializeCount(1);
+        callableReference.incrementCount();
+        clientCount = callableReference.retrieveCount();
+        callableReference.endConversation();
+
+        if (serviceReference.getConversation() == null) {
+            return null;
+        } else {
+            return serviceReference.getConversation().getConversationID().toString();
+        }
+    }
+
+    public String runConversationCallingEndedConversationCallbackCheckConversationId() {
+        calls.append("runConversationCallingEndedConversationCallbackCheckConversationId,");
+        ServiceReference<ConversationalService> serviceReference =
+            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
+        serviceReference.setConversationID("MyConversation3");
+
+        ConversationalService callableReference = serviceReference.getService();
+
+        callableReference.initializeCount(1);
+        callableReference.incrementCount();
+        clientCount = callableReference.retrieveCount();
+        callableReference.endConversationCallback();
+
+        if (serviceReference.getConversation() == null) {
+            return null;
+        } else {
+            return serviceReference.getConversation().getConversationID().toString();
+        }
+    }
+
+    public int runConversationCallingEndedConversation() {
+        calls.append("runConversationCallingEndedConversation,");
+        conversationalService.initializeCount(1);
+        conversationalService.endConversation();
+        return conversationalService.retrieveCount();
+    }
+
+    public int runConversationCallingEndedConversationCallback() {
+        calls.append("runConversationCallingEndedConversationCallback,");
+        conversationalService.initializeCountCallback(1);
+        conversationalService.endConversationCallback();
+        return conversationalService.retrieveCountCallback();
+    }
+
+    public int runConversationAgeTimeout() {
+        calls.append("runConversationAgeTimeout,");
+        // done in other testing
+        return clientCount;
+    }
+
+    public int runConversationIdleTimeout() {
+        calls.append("runConversationIdleTimeout,");
+        // done in other testing
+        return clientCount;
+    }
+
+    public int runConversationPrincipleError() {
+        calls.append("runConversationPrincipleError,");
+        // TODO - when policy framework is done
+        return clientCount;
+    }
+
+    // From ConversationalCallback
+    @Init
+    public void init() {
+        calls.append("init,");
+    }
+
+    @Destroy
+    public void destroy() {
+        calls.append("destroy,");
+    }
+
+    public void initializeCount(int count) {
+        calls.append("initializeCount,");
+        callbackCount += count;
+    }
+
+    public void incrementCount() {
+        calls.append("incrementCount,");
+        callbackCount++;
+    }
+
+    public int retrieveCount() {
+        calls.append("retrieveCount,");
+        return callbackCount;
+    }
+
+    public void businessException() throws Exception {
+        throw new Exception("Business Exception");
+    }
+
+    public String endConversation() {
+        calls.append("endConversation,");
+        return null;
+    }
+
+}