Moving 1.x branches

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@835124 13f79535-47bb-0310-9956-ffa450edef68

24 files changed, 0 insertions, 2406 deletions

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/AService.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/AService.java
deleted file mode 100644
index e7583c339a..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/AService.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Conversational;

-

-/**

- * Simple conversational Service that uses another Conversational Service

- */

-@Conversational

-public interface AService {

-

-    /**

-     * Returns the state for this service.

-     * 

-     * @return The state for this service

-     */

-    String getState();

-

-    /**

-     * Returns the state for the other service that this service is using

-     * 

-     * @return The state for the other service that this service is using

-     */

-    String getStateOnB();

-

-    /**

-     * Sets the state for this service.

-     * 

-     * @param aState The state for this service

-     */

-    void setState(String aState);

-

-    /**

-     * Sets the state for the other service that this service is using

-     * 

-     * @param aState The state for the other service that this service is using

-     */

-    void setStateOnB(String aState);

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/BService.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/BService.java
deleted file mode 100644
index 77d7f4c007..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/BService.java
+++ /dev/null
@@ -1,42 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Conversational;

-

-/**

- * Simple conversational Service

- */

-@Conversational

-public interface BService {

-    

-    /**

-     * Returns the state for this service.

-     * 

-     * @return The state for this service

-     */

-    String getState();

-

-    /**

-     * Sets the state for this service.

-     * 

-     * @param aState The state for this service

-     */

-    void setState(String aState);

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/Constants.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/Constants.java
deleted file mode 100644
index 3f04e9f09e..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/Constants.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/*

- * 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;

-

-public interface Constants {

-

-    String A_INITIAL_VALUE = "Initial Value of A";

-    String B_INITIAL_VALUE = "Initial Value of B";

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationIdService.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationIdService.java
deleted file mode 100644
index 53dadc3dc7..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationIdService.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Conversational;

-

-@Conversational

-public interface ConversationIdService {

-

-    String getCIDField();

-    String getCIDSetter();

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalCallback.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalCallback.java
deleted file mode 100644
index 640ec22a4f..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalCallback.java
+++ /dev/null
@@ -1,50 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Conversational;

-import org.osoa.sca.annotations.EndsConversation;

-import org.osoa.sca.annotations.Remotable;

-

-

-/**

- * The callback interface used when testing caonversational callbacks

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Remotable

-@Conversational

-public interface ConversationalCallback {

-	

-    public void init();

-    

-    public void destroy();

-    

-    public void initializeCount(int count);

-    

-    public void incrementCount();

-    

-    public int retrieveCount();

-    

-    public void businessException() throws Exception;        

-    

-    @EndsConversation

-    public String endConversation();

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalClient.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalClient.java
deleted file mode 100644
index 7a4c733fb0..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalClient.java
+++ /dev/null
@@ -1,51 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.ServiceReference;

-import org.osoa.sca.annotations.Remotable;

-

-/**

- * The client for the conversational itest. Is implemented by clients

- * offering both stateless and stateful callbacks

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-

-@Remotable

-public interface ConversationalClient { 

-	

-	public int runConversationFromInjectedReference();

-	public int runConversationFromInjectedReference2();

-	public int runConversationFromServiceReference();

-	public int runConversationWithUserDefinedConversationId();

-	public String runConversationCheckUserDefinedConversationId();	

-	public int runConversationCheckingScope();

-	public int runConversationWithCallback(); 

-	public int runConversationHavingPassedReference();

-	public String runConversationBusinessException();

-	public String runConversationBusinessExceptionCallback();

-	public int runConversationCallingEndedConversation();

-	public int runConversationCallingEndedConversationCallback();

-        public String runConversationCallingEndedConversationCheckConversationId(); 

-	public String runConversationCallingEndedConversationCallbackCheckConversationId();

-	public int runConversationAgeTimeout();

-	public int runConversationIdleTimeout();

-	public int runConversationPrincipleError();	

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalReferenceClient.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalReferenceClient.java
deleted file mode 100644
index 8f008fa711..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalReferenceClient.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.CallableReference;

-import org.osoa.sca.annotations.Remotable;

-

-/**

- * The client that calls into an existing conversation by accepting

- * a reference to that conversation

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-

-@Remotable

-public interface ConversationalReferenceClient { 

-	

-    public void incrementCount(CallableReference<ConversationalService> conversationalService);

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalService.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalService.java
deleted file mode 100644
index 546382cfd1..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalService.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Callback;

-import org.osoa.sca.annotations.Conversational;

-import org.osoa.sca.annotations.EndsConversation;

-import org.osoa.sca.annotations.Remotable;

-

-

-/**

- * The service interface used when testing conversations

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Remotable

-@Conversational

-@Callback(ConversationalCallback.class)

-public interface ConversationalService {

-	

-    public void init();

-    

-    public void destroy();

-    

-    public void initializeCount(int count);

-    

-    public void incrementCount();

-    

-    public int retrieveCount();

-    

-    public void businessException() throws Exception;        

-    

-    public void initializeCountCallback(int count);

-    

-    public void incrementCountCallback();

-    

-    public int retrieveCountCallback();

-    

-    public void businessExceptionCallback() throws Exception;    

-    

-    @EndsConversation

-    public String endConversation();

-    

-    public String endConversationCallback();

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalServiceNonConversationalCallback.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalServiceNonConversationalCallback.java
deleted file mode 100644
index f1a21cc18f..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/ConversationalServiceNonConversationalCallback.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Callback;

-import org.osoa.sca.annotations.Conversational;

-import org.osoa.sca.annotations.EndsConversation;

-import org.osoa.sca.annotations.Remotable;

-

-

-/**

- * The service interface used when testing conversations

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Remotable

-@Conversational

-@Callback(NonConversationalCallback.class)

-public interface ConversationalServiceNonConversationalCallback {

-	

-    public void init();

-    

-    public void destroy();

-    

-    public void initializeCount(int count);

-    

-    public void incrementCount();

-    

-    public int retrieveCount();

-    

-    public void businessException() throws Exception;        

-    

-    public void initializeCountCallback(int count);

-    

-    public void incrementCountCallback();

-    

-    public int retrieveCountCallback();

-    

-    public void businessExceptionCallback() throws Exception;    

-    

-    @EndsConversation

-    public String endConversation();

-    

-    public String endConversationCallback();

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/NonConversationalCallback.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/NonConversationalCallback.java
deleted file mode 100644
index a9f264da56..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/NonConversationalCallback.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*

- * 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;

-

-import org.osoa.sca.annotations.Conversational;

-import org.osoa.sca.annotations.EndsConversation;

-import org.osoa.sca.annotations.Remotable;

-

-

-/**

- * The callback interface used when testing caonversational callbacks

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Remotable

-public interface NonConversationalCallback {

-	

-    public void init();

-    

-    public void destroy();

-    

-    public void initializeCount(int count);

-    

-    public void incrementCount();

-    

-    public int retrieveCount();

-    

-    public void businessException() throws Exception;        

-    

-    public String endConversation();

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/AServiceImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/AServiceImpl.java
deleted file mode 100644
index 95c9c7ae6e..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/AServiceImpl.java
+++ /dev/null
@@ -1,111 +0,0 @@
-/*

- * 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 java.lang.reflect.Proxy;

-import org.apache.tuscany.sca.core.invocation.JDKInvocationHandler;

-

-import org.apache.tuscany.sca.itest.conversational.AService;

-import org.apache.tuscany.sca.itest.conversational.BService;

-import org.apache.tuscany.sca.itest.conversational.Constants;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Reference;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.Service;

-

-/**

- * Simple conversational Service that uses another Conversational Service

- */

-@Service(AService.class)

-@Scope("CONVERSATION")

-public class AServiceImpl implements AService {

-

-    /**

-     * The state 

-     */

-    private String state = Constants.A_INITIAL_VALUE;

-    

-    /**

-     * The reference to the other service

-     */

-    private BService b;

-    

-    /**

-     * Constructor

-     *

-     */

-    public AServiceImpl() {

-        System.out.println("---> AServiceImpl constructor for " + this);

-    }

-

-    /**

-     * Inject the reference to the other service

-     * @param aB The other service.

-     */

-    @Reference(name="b")

-    public void setB(BService aB) {

-        System.out.println("---> Setting reference to B on " + this + " to " + aB);

-        this.b = aB;

-    }

-    

-    /**

-     * Returns the state for this service.

-     * 

-     * @return The state for this service

-     */

-    public String getState() {

-        return state;

-    }

-

-    /**

-     * Returns the state for the other service that this service is using

-     * 

-     * @return The state for the other service that this service is using

-     */

-    public String getStateOnB() {

-        return b.getState();

-    }

-

-    /**

-     * Sets the state for this service.

-     * 

-     * @param aState The state for this service

-     */

-    public void setState(String aState) {

-        this.state = aState;

-    }

-

-    /**

-     * Sets the state for the other service that this service is using

-     * 

-     * @param aState The state for the other service that this service is using

-     */

-    public void setStateOnB(String aState) {

-        b.setState(aState);

-    }

-    

-    /**

-     * Sets the conversation ID for this service

-     * @param id The Conversation ID

-     */

-    @ConversationID

-    public void setConversationID(String id) {

-        System.out.println("Conversation ID for " + this + " is set to " + id);

-    }

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/BServiceImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/BServiceImpl.java
deleted file mode 100644
index c1e27641ef..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/BServiceImpl.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/*

- * 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.BService;

-import org.apache.tuscany.sca.itest.conversational.Constants;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.Service;

-

-/**

- * Simple conversational Service

- */

-@Service(BService.class)

-@Scope("CONVERSATION")

-public class BServiceImpl implements BService {

-

-    /**

-     * The state for this service

-     */

-    private String state = Constants.B_INITIAL_VALUE;

-

-    /**

-     * Constructor

-     */

-    public BServiceImpl() {

-        System.out.println("---> BServiceImpl constructor for " + this);

-    }

-    

-    /**

-     * Returns the state for this service.

-     * 

-     * @return The state for this service

-     */

-    public String getState() {

-        return state;

-    }

-

-    /**

-     * Sets the state for this service.

-     * 

-     * @param aState The state for this service

-     */

-    public void setState(String aState) {

-        this.state = aState;

-    }

-

-    /**

-     * Sets the conversation ID for this service

-     * @param id The Conversation ID

-     */

-    @ConversationID

-    public void setConversationID(String id) {

-        System.out.println("Conversation ID for " + this + " is set to " + id);

-    }

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationAgeComponentImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationAgeComponentImpl.java
deleted file mode 100644
index 9deef312ac..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationAgeComponentImpl.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * 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.ConversationalService;
-import org.osoa.sca.annotations.ConversationAttributes;
-import org.osoa.sca.annotations.Scope;
-import org.osoa.sca.annotations.Service;
-
-@Service(ConversationalService.class)
-@Scope("CONVERSATION")
-@ConversationAttributes(maxAge="1 seconds")
-public class ConversationAgeComponentImpl implements ConversationalService {
-
-    private int count;
-    
-    public void businessException() throws Exception {   
-    }
-    
-    public void businessExceptionCallback() throws Exception {   
-    }      
-
-    public void destroy() {
-    }
-
-    public String endConversation() {
-        return null;
-    }
-
-    public String endConversationCallback() {
-        return null;
-    }
-
-    public void incrementCount() {
-    }
-
-    public void incrementCountCallback() {
-    }
-
-    public void init() {
-    }
-
-    public void initializeCount(int count) {
-        this.count = count;
-    }
-
-    public void initializeCountCallback(int count) {
-    }
-
-    public int retrieveCount() {
-        return count;
-    }
-
-    public int retrieveCountCallback() {
-        return 0;
-    }
-
-}
diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationIdComponentImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationIdComponentImpl.java
deleted file mode 100644
index cffa76186a..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationIdComponentImpl.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * 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.ConversationIdService;
-import org.osoa.sca.annotations.ConversationID;
-import org.osoa.sca.annotations.Scope;
-import org.osoa.sca.annotations.Service;
-
-@Service(ConversationIdService.class)
-@Scope("CONVERSATION")
-public class ConversationIdComponentImpl implements ConversationIdService {
-
-    @ConversationID
-    public String cid;
-
-    private String setterCid;
-    
-    public String getCIDField() {
-        return cid;
-    }
-    public String getCIDSetter() {
-        return setterCid;
-    }
-    
-
-    @ConversationID
-    public void setCID(String cid) {
-        this.setterCid = cid;
-    }
-}
diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationMaxIdleComponentImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationMaxIdleComponentImpl.java
deleted file mode 100644
index 1272c7ab7f..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationMaxIdleComponentImpl.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * 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.ConversationalService;
-import org.osoa.sca.annotations.ConversationAttributes;
-import org.osoa.sca.annotations.Scope;
-import org.osoa.sca.annotations.Service;
-
-@Service(ConversationalService.class)
-@Scope("CONVERSATION")
-@ConversationAttributes(maxIdleTime="1 seconds")
-public class ConversationMaxIdleComponentImpl implements ConversationalService {
-
-    private int count;
-
-    public void businessException() throws Exception {   
-    }
-    
-    public void businessExceptionCallback() throws Exception {   
-    }    
-    
-    public void destroy() {
-    }
-
-    public String endConversation() {
-        return null;
-    }
-
-    public String endConversationCallback() {
-        return null;
-    }
-
-    public void incrementCount() {
-    }
-
-    public void incrementCountCallback() {
-    }
-
-    public void init() {
-    }
-
-    public void initializeCount(int count) {
-        this.count = count;
-    }
-
-    public void initializeCountCallback(int count) {
-    }
-
-    public int retrieveCount() {
-        return count;
-    }
-
-    public int retrieveCountCallback() {
-        return 0;
-    }
-
-}
diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulImpl.java
deleted file mode 100644
index 847b038881..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulImpl.java
+++ /dev/null
@@ -1,321 +0,0 @@
-/*

- * 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.ConversationalCallback;

-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.osoa.sca.ComponentContext;

-import org.osoa.sca.ServiceReference;

-import org.osoa.sca.annotations.Context;

-import org.osoa.sca.annotations.ConversationAttributes;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Reference;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.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 ConversationalClientStatefulImpl implements ConversationalClient, ConversationalCallback {

-    

-    @Context

-    protected ComponentContext componentContext;

-    

-    @Reference 

-    protected ConversationalService conversationalService;

-    

-    @Reference 

-    protected ConversationalService 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();

-        

-        String clientConversationId = serviceReference.getConversationID().toString();

-        String serverConversationId = callableReference.endConversation();

-        

-        if (clientConversationId.equals("MyConversation2") &&

-            serverConversationId.equals("MyConversation2") ) {

-            return clientConversationId;

-        } else {

-            return "client = " + clientConversationId +

-                   "server = " + serverConversationId;

-        }  

-              

-    }      

-    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 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 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 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,");

-        callbackCount = 0;

-        return null;

-    }

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java
deleted file mode 100644
index b77e4c0194..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatefulNonConversationalCallbackImpl.java
+++ /dev/null
@@ -1,310 +0,0 @@
-/*

- * 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.NonConversationalCallback;

-import org.osoa.sca.ComponentContext;

-import org.osoa.sca.ServiceReference;

-import org.osoa.sca.annotations.Context;

-import org.osoa.sca.annotations.ConversationAttributes;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Reference;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.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 ConversationalService conversationalService;

-    

-    @Reference 

-    protected ConversationalService 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;

-    }

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatelessImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatelessImpl.java
deleted file mode 100644
index 5b3906fc2c..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalClientStatelessImpl.java
+++ /dev/null
@@ -1,317 +0,0 @@
-/*

- * 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.ConversationalCallback;

-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.osoa.sca.ComponentContext;

-import org.osoa.sca.ServiceReference;

-import org.osoa.sca.annotations.Context;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Reference;

-import org.osoa.sca.annotations.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})

-public class ConversationalClientStatelessImpl implements ConversationalClient, ConversationalCallback {

-   

-    @Context

-    protected ComponentContext componentContext;

-    

-    @Reference 

-    protected ConversationalService conversationalService;

-    

-    @Reference 

-    protected ConversationalService 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,");   

-

-        // now test the second reference        

-        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();

-        

-        String clientConversationId = serviceReference.getConversationID().toString();

-        String serverConfersationId = callableReference.endConversation();

-        

-        if (clientConversationId.equals("MyConversation2") &&

-            serverConfersationId.equals("MyConversation2") ) {

-            return clientConversationId;

-        } else {

-            return "client = " + clientConversationId +

-                   "server = " + serverConfersationId;

-        }     

-    }     

-    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,");

-        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 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 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 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 = 0;

-    }

-    

-    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,");

-        callbackCount = 0;

-        return null;

-    }

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalReferenceClientImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalReferenceClientImpl.java
deleted file mode 100644
index 8fe7c5b6ba..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalReferenceClientImpl.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*

- * 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.ConversationalReferenceClient;

-import org.apache.tuscany.sca.itest.conversational.ConversationalService;

-import org.osoa.sca.CallableReference;

-import org.osoa.sca.annotations.Service;

-

-/**

- * A client component that accepts a reference to an ongoing conversation

- * and takes part in that conversation

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-

-@Service(interfaces={ConversationalReferenceClient.class})

-public class ConversationalReferenceClientImpl implements ConversationalReferenceClient{

-   

-    public void incrementCount(CallableReference<ConversationalService> conversationalService){

-        ConversationalService callableReference = conversationalService.getService();

-        

-        callableReference.incrementCount();        

-    }

-

-

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceRequestImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceRequestImpl.java
deleted file mode 100644
index 9a25f0f59a..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceRequestImpl.java
+++ /dev/null
@@ -1,123 +0,0 @@
-/*

- * 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 java.util.HashMap;

-

-import org.apache.tuscany.sca.itest.conversational.ConversationalCallback;

-import org.apache.tuscany.sca.itest.conversational.ConversationalService;

-import org.osoa.sca.annotations.Callback;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.Service;

-

-

-/**

- * The service used when testing stateful conversations

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Service(ConversationalService.class)

-@Scope("REQUEST")

-public class ConversationalServiceRequestImpl implements ConversationalService {

-    

-    @ConversationID

-    protected String conversationId;

-    

-    @Callback

-    protected ConversationalCallback conversationalCallback; 

-    

-    // static area in which to hold conversational data

-    private static HashMap<String, Integer> conversationalState = new HashMap<String, Integer>();

-   

-    // a static member variable that records the number of times this service is called

-    public static StringBuffer calls = new StringBuffer();

-   

-    @Init

-    public void init(){

-        calls.append("init,");

-    }

-    

-    @Destroy

-    public void destroy(){

-        calls.append("destroy,");

-    }

-    

-    public void initializeCount(int count){

-        calls.append("initializeCount,");

-        Integer conversationalCount = new Integer(count); 

-        conversationalState.put(conversationId, conversationalCount);

-    }

-    

-    public void incrementCount(){

-        calls.append("incrementCount,");

-        Integer conversationalCount = conversationalState.get(conversationId);

-        conversationalCount++;

-        conversationalState.put(conversationId, conversationalCount);

-    }

-    

-    public int retrieveCount(){

-        calls.append("retrieveCount,");

-        Integer count = conversationalState.get(conversationId);

-        if (count != null){

-            return count.intValue();

-        } else {

-            return -999;

-        }

-    }

-    

-    public void businessException() throws Exception {

-        throw new Exception("Business Exception");

-    }    

-    

-    public void initializeCountCallback(int count){

-        calls.append("initializeCountCallback,");

-        initializeCount(count);

-        conversationalCallback.initializeCount(count);

-    }

-    

-    public void incrementCountCallback(){

-        calls.append("incrementCountCallback,");

-        incrementCount();

-        conversationalCallback.incrementCount();

-    }

-    

-    public int retrieveCountCallback(){

-        calls.append("retrieveCountCallback,");

-        return conversationalCallback.retrieveCount();

-    }

-    

-    public void businessExceptionCallback() throws Exception {

-        calls.append("businessExceptionCallback,");        

-        conversationalCallback.businessException();

-    }

-    

-    public String endConversation(){

-        calls.append("endConversation,");

-        conversationalState.remove(conversationId);

-        return conversationId;

-    }

-    

-    public String endConversationCallback(){

-        calls.append("endConversationCallback,");       

-        return conversationalCallback.endConversation();

-    }   

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatefulImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatefulImpl.java
deleted file mode 100644
index efcbdff06f..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatefulImpl.java
+++ /dev/null
@@ -1,117 +0,0 @@
-/*

- * 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.ConversationalCallback;

-import org.apache.tuscany.sca.itest.conversational.ConversationalService;

-import org.osoa.sca.annotations.Callback;

-import org.osoa.sca.annotations.ConversationAttributes;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.Service;

-

-

-/**

- * The service used when testing stateful conversations

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Service(ConversationalService.class)

-@Scope("CONVERSATION")

-@ConversationAttributes(maxAge="10 minutes",

-                        maxIdleTime="5 minutes",

-                        singlePrincipal=false)

-public class ConversationalServiceStatefulImpl implements ConversationalService {

-

-    @ConversationID

-    protected String conversationId;

-    

-    @Callback

-    protected ConversationalCallback conversationalCallback; 

-    

-    // local count - accumulates during the conversation

-    private int count = 0;

-          

-    // a static member variable that records the number of times this service is called

-    public static StringBuffer calls = new StringBuffer();

-   

-    @Init

-    public void init(){

-        calls.append("init,");

-    }

-    

-    @Destroy

-    public void destroy(){

-        calls.append("destroy,");

-    }

-    

-    public void initializeCount(int count){

-        calls.append("initializeCount,");       

-        this.count = count;

-    }

-    

-    public void incrementCount(){

-        calls.append("incrementCount,");        

-        count++;

-    }

-    

-    public int retrieveCount(){

-        calls.append("retrieveCount,"); 

-        return count;

-    }

-    

-    public void businessException() throws Exception {

-        throw new Exception("Business Exception");

-    }     

-    

-    public void initializeCountCallback(int count){

-        calls.append("initializeCountCallback,"); 

-        this.count = count;

-        conversationalCallback.initializeCount(count);

-    }

-    

-    public void incrementCountCallback(){

-        calls.append("incrementCountCallback,"); 

-        count++;

-        conversationalCallback.incrementCount();

-    }

-    

-    public int retrieveCountCallback(){

-        calls.append("retrieveCountCallback,"); 

-        return conversationalCallback.retrieveCount();

-    }

-    

-    public void businessExceptionCallback() throws Exception {

-        calls.append("businessExceptionCallback,");        

-        conversationalCallback.businessException();

-    }    

-    

-    public String endConversation(){

-        calls.append("endConversation,"); 

-        count = 0;

-        return conversationId;

-    }

-    

-    public String endConversationCallback(){

-        calls.append("endConversationCallback,"); 

-        return conversationalCallback.endConversation();

-    }

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatefulNonConversationalCallbackImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatefulNonConversationalCallbackImpl.java
deleted file mode 100644
index 8454b3846b..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatefulNonConversationalCallbackImpl.java
+++ /dev/null
@@ -1,117 +0,0 @@
-/*

- * 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.ConversationalServiceNonConversationalCallback;

-import org.apache.tuscany.sca.itest.conversational.NonConversationalCallback;

-import org.osoa.sca.annotations.Callback;

-import org.osoa.sca.annotations.ConversationAttributes;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.Service;

-

-

-/**

- * The service used when testing stateful conversations

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Service(ConversationalServiceNonConversationalCallback.class)

-@Scope("CONVERSATION")

-@ConversationAttributes(maxAge="10 minutes",

-                        maxIdleTime="5 minutes",

-                        singlePrincipal=false)

-public class ConversationalServiceStatefulNonConversationalCallbackImpl implements ConversationalServiceNonConversationalCallback {

-

-    @ConversationID

-    protected String conversationId;

-    

-    @Callback

-    protected NonConversationalCallback nonConversationalCallback; 

-    

-    // local count - accumulates during the conversation

-    private int count = 0;

-          

-    // a static member variable that records the number of times this service is called

-    public static StringBuffer calls = new StringBuffer();

-   

-    @Init

-    public void init(){

-        calls.append("init,");

-    }

-    

-    @Destroy

-    public void destroy(){

-        calls.append("destroy,");

-    }

-    

-    public void initializeCount(int count){

-        calls.append("initializeCount,");       

-        this.count = count;

-    }

-    

-    public void incrementCount(){

-        calls.append("incrementCount,");        

-        count++;

-    }

-    

-    public int retrieveCount(){

-        calls.append("retrieveCount,"); 

-        return count;

-    }

-    

-    public void businessException() throws Exception {

-        throw new Exception("Business Exception");

-    }     

-    

-    public void initializeCountCallback(int count){

-        calls.append("initializeCountCallback,"); 

-        this.count = count;

-        nonConversationalCallback.initializeCount(count);

-    }

-    

-    public void incrementCountCallback(){

-        calls.append("incrementCountCallback,"); 

-        count++;

-        nonConversationalCallback.incrementCount();

-    }

-    

-    public int retrieveCountCallback(){

-        calls.append("retrieveCountCallback,"); 

-        return nonConversationalCallback.retrieveCount();

-    }

-    

-    public void businessExceptionCallback() throws Exception {

-        calls.append("businessExceptionCallback,");        

-        nonConversationalCallback.businessException();

-    }    

-    

-    public String endConversation(){

-        calls.append("endConversation,"); 

-        count = 0;

-        return conversationId;

-    }

-    

-    public String endConversationCallback(){

-        calls.append("endConversationCallback,"); 

-        return nonConversationalCallback.endConversation();

-    }

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatelessImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatelessImpl.java
deleted file mode 100644
index a7b5b1aff5..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatelessImpl.java
+++ /dev/null
@@ -1,122 +0,0 @@
-/*

- * 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 java.util.HashMap;

-

-import org.apache.tuscany.sca.itest.conversational.ConversationalCallback;

-import org.apache.tuscany.sca.itest.conversational.ConversationalService;

-import org.osoa.sca.annotations.Callback;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Destroy;

-import org.osoa.sca.annotations.Init;

-import org.osoa.sca.annotations.Scope;

-import org.osoa.sca.annotations.Service;

-

-

-/**

- * The service used when testing stateful conversations

- *

- * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $

- */

-@Service(ConversationalService.class)

-public class ConversationalServiceStatelessImpl implements ConversationalService {

-    

-    @ConversationID

-    protected String conversationId;

-    

-    @Callback

-    protected ConversationalCallback conversationalCallback; 

-    

-    // static area in which to hold conversational data

-    private static HashMap<String, Integer> conversationalState = new HashMap<String, Integer>();

-   

-    // a static member variable that records the number of times this service is called

-    public static StringBuffer calls = new StringBuffer();

-   

-    @Init

-    public void init(){

-        calls.append("init,");

-    }

-    

-    @Destroy

-    public void destroy(){

-        calls.append("destroy,");

-    }

-    

-    public void initializeCount(int count){

-        calls.append("initializeCount,");

-        Integer conversationalCount = new Integer(count); 

-        conversationalState.put(conversationId, conversationalCount);

-    }

-    

-    public void incrementCount(){

-        calls.append("incrementCount,");

-        Integer conversationalCount = conversationalState.get(conversationId);

-        conversationalCount++;

-        conversationalState.put(conversationId, conversationalCount);

-    }

-    

-    public int retrieveCount(){

-        calls.append("retrieveCount,");

-        Integer count = conversationalState.get(conversationId);

-        if (count != null){

-            return count.intValue();

-        } else {

-            return -999;

-        }

-    }

-    

-    public void businessException() throws Exception {

-        throw new Exception("Business Exception");

-    }    

-    

-    public void initializeCountCallback(int count){

-        calls.append("initializeCountCallback,");

-        initializeCount(count);

-        conversationalCallback.initializeCount(count);

-    }

-    

-    public void incrementCountCallback(){

-        calls.append("incrementCountCallback,");

-        incrementCount();

-        conversationalCallback.incrementCount();

-    }

-    

-    public int retrieveCountCallback(){

-        calls.append("retrieveCountCallback,");

-        return conversationalCallback.retrieveCount();

-    }

-    

-    public void businessExceptionCallback() throws Exception {

-        calls.append("businessExceptionCallback,");        

-        conversationalCallback.businessException();

-    }

-    

-    public String endConversation(){

-        calls.append("endConversation,");

-        conversationalState.remove(conversationId);

-        return conversationId;

-    }

-    

-    public String endConversationCallback(){

-        calls.append("endConversationCallback,");       

-        return conversationalCallback.endConversation();

-    }   

-}

diff --git a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatelessScopeImpl.java b/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatelessScopeImpl.java
deleted file mode 100644
index 344aa99dff..0000000000
--- a/branches/sca-java-1.1/itest/conversations/src/main/java/org/apache/tuscany/sca/itest/conversational/impl/ConversationalServiceStatelessScopeImpl.java
+++ /dev/null
@@ -1,93 +0,0 @@
-/*

- * 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 java.util.HashMap;

-import java.util.Map;

-

-import org.apache.tuscany.sca.itest.conversational.ConversationalService;

-import org.osoa.sca.annotations.ConversationID;

-import org.osoa.sca.annotations.Service;

-

-@Service(ConversationalService.class)

-public class ConversationalServiceStatelessScopeImpl implements ConversationalService {

-

-    @ConversationID

-    protected String cid;

-

-    static Map<String, Integer> state = new HashMap<String, Integer>();

-    

-    public void destroy() {

-        // TODO Auto-generated method stub

-        

-    }

-

-    public String endConversation() {

-        state.remove(cid);

-        return cid;

-    }

-

-    public String endConversationCallback() {

-        // TODO Auto-generated method stub

-        return null;

-        

-    }

-

-    public void incrementCount() {

-        state.put(cid, Integer.valueOf(state.get(cid)+1));

-    }

-

-    public void businessException() throws Exception {

-        throw new Exception("Business Exception");

-    }

-    

-    public void incrementCountCallback() {

-        // TODO Auto-generated method stub

-        

-    }

-

-    public void init() {

-        // TODO Auto-generated method stub

-        

-    }

-

-    public void initializeCount(int count) {

-        state.put(cid, Integer.valueOf(count));

-    }

-

-    public void initializeCountCallback(int count) {

-        // TODO Auto-generated method stub

-        

-    }

-    

-    public void businessExceptionCallback() throws Exception {

-        throw new Exception("Business Exception");

-    }    

-

-    public int retrieveCount() {

-        return state.get(cid);

-    }

-

-    public int retrieveCountCallback() {

-        // TODO Auto-generated method stub

-        return 0;

-    }

-    

-}