summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-20080910/itest/serialization/src/main/java/org
diff options
context:
space:
mode:
authorlresende <lresende@13f79535-47bb-0310-9956-ffa450edef68>2009-11-11 23:13:16 +0000
committerlresende <lresende@13f79535-47bb-0310-9956-ffa450edef68>2009-11-11 23:13:16 +0000
commit3ac2d800d840f03618fc364090d786effde84b1f (patch)
treee334754cd5c37e1465230497b48cc79584c1f571 /branches/sca-java-20080910/itest/serialization/src/main/java/org
parent9bed5ae38c581999db465b42b504026a7097af95 (diff)
Moving 1.x branches
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@835142 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'branches/sca-java-20080910/itest/serialization/src/main/java/org')
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalService.java81
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceCallback.java37
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceImpl.java141
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClient.java51
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClientImpl.java115
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClient.java55
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClientImpl.java132
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessService.java46
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceCallback.java34
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceImpl.java82
-rw-r--r--branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/utils/ServiceReferenceUtils.java127
11 files changed, 0 insertions, 901 deletions
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalService.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalService.java
deleted file mode 100644
index fa0f1c88d6..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalService.java
+++ /dev/null
@@ -1,81 +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.servicereference;
-
-import org.osoa.sca.ServiceReference;
-import org.osoa.sca.annotations.Callback;
-import org.osoa.sca.annotations.Conversational;
-
-/**
- * A very simple Conversational Service
- *
- * @version $Date$ $Revision$
- */
-@Conversational
-@Callback(ConversationalServiceCallback.class)
-public interface ConversationalService {
-
- /**
- * Default value for the user data
- *
- * @See {@link #getUserData()}
- * @See {@link #setUserData(String)}
- */
- String DEFAULT_USER_DATA = "NOT SET";
-
- /**
- * Retrieves the conversation ID for this Service
- *
- * @return The conversation ID for this Service
- */
- Object getConversationID();
-
- /**
- * Creates a self reference to this Service
- *
- * @return A self reference to this Service
- */
- ServiceReference<ConversationalService> createSelfRef();
-
- /**
- * Sets some user data on the instance
- *
- * @param a_Data Some data
- *
- * @See {@link #getUserData()}
- */
- void setUserData(String a_Data);
-
- /**
- * Gets some user data on the instance
- *
- * @return Some data
- *
- * @See {@link #setUserData(String)}
- */
- String getUserData();
-
- /**
- * Method that triggers the callback.
- *
- * @param msg A message to pass with the callback
- * @throws Exception Test failed
- */
- void triggerCallback(String msg) throws Exception;
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceCallback.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceCallback.java
deleted file mode 100644
index 85d5dd860c..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceCallback.java
+++ /dev/null
@@ -1,37 +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.servicereference;
-
-import org.osoa.sca.annotations.Conversational;
-
-/**
- * This is the callback for the ConversationalService.
- *
- * @version $Rev$ $Date$
- */
-@Conversational
-public interface ConversationalServiceCallback {
-
- /**
- * Simple callback method.
- *
- * @param msg The message for the call back
- */
- void callback(String msg);
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceImpl.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceImpl.java
deleted file mode 100644
index 50c98d1afc..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/ConversationalServiceImpl.java
+++ /dev/null
@@ -1,141 +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.servicereference;
-
-import org.apache.tuscany.sca.itest.servicereference.utils.ServiceReferenceUtils;
-import org.junit.Assert;
-import org.osoa.sca.CallableReference;
-import org.osoa.sca.ComponentContext;
-import org.osoa.sca.ServiceReference;
-import org.osoa.sca.annotations.Callback;
-import org.osoa.sca.annotations.Context;
-import org.osoa.sca.annotations.ConversationID;
-import org.osoa.sca.annotations.Scope;
-import org.osoa.sca.annotations.Service;
-
-/**
- * Simple conversational Service implementation
- *
- * @version $Date$ $Revision$
- */
-@Service(ConversationalService.class)
-@Scope("CONVERSATION")
-public class ConversationalServiceImpl implements ConversationalService {
-
- /**
- * The Conversation ID
- */
- private Object m_ConversationID;
-
- /**
- * Injected reference to the call back.
- */
- @Callback
- protected CallableReference<ConversationalServiceCallback> theCallbackRef;
-
- /**
- * Injected reference to the ComponentContext.
- */
- @Context
- protected ComponentContext m_Ctx;
-
- /**
- * Some user data
- */
- private String m_UserData = DEFAULT_USER_DATA;
-
- /**
- * Constructor
- */
- public ConversationalServiceImpl() {
- }
-
- /**
- * Used to inject the Conversation ID
- *
- * @param a_ConversationID the Conversation ID
- */
- @ConversationID
- public void setConversationID(Object a_ConversationID) {
- m_ConversationID = a_ConversationID;
- }
-
- /**
- * Retrieves the conversation ID for this Service
- *
- * @return The conversation ID for this Service
- */
- public Object getConversationID() {
- return m_ConversationID;
- }
-
- /**
- * Creates a self reference to this Service
- *
- * @return A self reference to this Service
- */
- public ServiceReference<ConversationalService> createSelfRef() {
- return m_Ctx.createSelfReference(ConversationalService.class);
- }
-
- /**
- * Sets some user data on the instance
- *
- * @param a_Data Some data
- *
- * @See {@link #getUserData()}
- */
- public void setUserData(String a_Data) {
- m_UserData = a_Data;
- }
-
- /**
- * Gets some user data on the instance
- *
- * @return Some data
- *
- * @See {@link #setUserData(String)}
- */
- public String getUserData() {
- return m_UserData;
- }
-
- /**
- * Method that triggers the callback.
- *
- * @param msg A message to pass with the callback
- * @throws Exception Test failed
- */
- public void triggerCallback(String msg) throws Exception {
- Assert.assertNotNull(theCallbackRef);
-
- // Serialize the CallableReference
- byte[] serializedCR = ServiceReferenceUtils.serialize(theCallbackRef);
- Assert.assertNotNull(serializedCR);
-
- // Deserlaize the CallableReference
- CallableReference<?> cr = ServiceReferenceUtils.deserializeCallableReference(serializedCR);
- Assert.assertNotNull(cr);
- CallableReference<ConversationalServiceCallback> regotCallbackRef
- = (CallableReference<ConversationalServiceCallback>) cr;
-
- // Use the deseralized CallbackReference
- regotCallbackRef.getService().callback(msg);
- }
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClient.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClient.java
deleted file mode 100644
index c268f9bda7..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClient.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.servicereference;
-
-
-/**
- * This is a test client that is used to test Serializing and Deserializing
- * ServiceReferences within a SCA Application
- *
- * @version $Date$ $Revision$
- */
-public interface SCAManagedClient {
-
- /**
- * Tests Serializing a Stateless ServiceReference
- *
- * @throws Exception Test failed
- */
- void testSerializeStatelessServiceReference() throws Exception;
-
- /**
- * Tests Serializing a Nested Stateless ServiceReference.
- *
- * @throws Exception Test failed
- */
- void testSerializeNestedStatelessServiceReference() throws Exception;
-
- /**
- * Tests Serializing a Callback to a Stateless Service as managed
- * SCA code
- *
- * @throws Exception Test failed
- */
- void testSerializeCallbackToStatelessServiceInsideSCA() throws Exception;
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClientImpl.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClientImpl.java
deleted file mode 100644
index cf0307eb8e..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedClientImpl.java
+++ /dev/null
@@ -1,115 +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.servicereference;
-
-import org.apache.tuscany.sca.itest.servicereference.utils.ServiceReferenceUtils;
-import org.junit.Assert;
-import org.osoa.sca.ServiceReference;
-import org.osoa.sca.annotations.Reference;
-import org.osoa.sca.annotations.Service;
-
-/**
- * This is a test client that is used to test Serializing and Deserializing
- * ServiceReferences within a SCA Application
- *
- * @version $Date$ $Revision$
- */
-@Service(SCAManagedClient.class)
-public class SCAManagedClientImpl implements SCAManagedClient, StatelessServiceCallback {
-
- /**
- * Injected reference to the StatelessService
- */
- @Reference(name = "statelessService")
- protected ServiceReference<StatelessService> statelessServiceRef;
-
- /**
- * Injected reference to the Nested StatelessService.
- */
- @Reference(name = "nestedStatelessService")
- protected ServiceReference<StatelessService> nestedStatelessServiceRef;
-
- /**
- * Tests Serializing a Stateless ServiceReference
- *
- * @throws Exception Test failed
- */
- public void testSerializeStatelessServiceReference() throws Exception {
- doTestSerializeStatelessServiceReference(statelessServiceRef);
- }
-
- /**
- * Tests Serializing a Nested Stateless ServiceReference.
- *
- * @throws Exception Test failed
- */
- public void testSerializeNestedStatelessServiceReference() throws Exception {
- doTestSerializeStatelessServiceReference(nestedStatelessServiceRef);
- }
-
- /**
- * Tests Serializing a Stateless ServiceReference.
- *
- * @throws Exception Test failed
- */
- private void doTestSerializeStatelessServiceReference(
- ServiceReference<StatelessService> aServiceRef) throws Exception {
- Assert.assertNotNull(aServiceRef);
-
- StatelessService service = aServiceRef.getService();
- service.getCurrentTime();
-
- // Serialize the ServiceReference
- byte[] serializedSR = ServiceReferenceUtils.serialize(aServiceRef);
- Assert.assertNotNull(serializedSR);
-
- // Deserialize the ServiceReference
- ServiceReference<?> deserializedSR = ServiceReferenceUtils.deserializeServiceReference(serializedSR);
- Assert.assertNotNull(deserializedSR);
- ServiceReference<StatelessService> regotServiceRef = (ServiceReference<StatelessService>) deserializedSR;
- Assert.assertNotNull(regotServiceRef);
-
- // Use the ServiceReference to access the Service.
- StatelessService regotService = regotServiceRef.getService();
- Assert.assertNotNull(regotService);
- }
-
- /**
- * Simple callback method
- *
- * @param msg The call back message
- */
- public void callback(String msg) {
- System.out.println("Stateless Callback with message " + msg);
- }
-
- /**
- * Tests Serializing a Callback to a Stateless Service as managed
- * SCA code
- *
- * @throws Exception Test failed
- */
- public void testSerializeCallbackToStatelessServiceInsideSCA() throws Exception {
- Assert.assertNotNull(statelessServiceRef);
-
- StatelessService service = statelessServiceRef.getService();
- String msg = "A message for the callback " + System.currentTimeMillis();
- service.triggerCallback(msg);
- }
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClient.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClient.java
deleted file mode 100644
index deb8f75816..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClient.java
+++ /dev/null
@@ -1,55 +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.servicereference;
-
-import org.osoa.sca.annotations.Conversational;
-
-
-/**
- * This is a test client that is used to test Serializing and Deserializing
- * ServiceReferences within a SCA Application where the client that the Callback
- * is referring is actually Conversational.
- *
- * @version $Rev$ $Date$
- */
-@Conversational
-public interface SCAManagedConversationalClient {
-
- /**
- * Tests Serializing a Conversational ServiceReference.
- *
- * @throws Exception Test failed
- */
- void testSerializeConversationalServiceReference() throws Exception;
-
- /**
- * Tests Serializing a Nested Conversational ServiceReference.
- *
- * @throws Exception Test failed
- */
- void testSerializeNestedConversationalServiceReference() throws Exception;
-
- /**
- * Tests Serializing a Callback to a Conversational Service as managed
- * SCA code.
- *
- * @throws Exception Test failed
- */
- void testSerializeCallbackToConversationalServiceInsideSCA() throws Exception;
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClientImpl.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClientImpl.java
deleted file mode 100644
index 60ecb7717a..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/SCAManagedConversationalClientImpl.java
+++ /dev/null
@@ -1,132 +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.servicereference;
-
-import org.apache.tuscany.sca.itest.servicereference.utils.ServiceReferenceUtils;
-import org.junit.Assert;
-import org.osoa.sca.ServiceReference;
-import org.osoa.sca.annotations.Reference;
-import org.osoa.sca.annotations.Scope;
-import org.osoa.sca.annotations.Service;
-
-/**
- * This is a test client that is used to test Serializing and Deserializing
- * ServiceReferences within a SCA Application
- *
- * @version $Rev$ $Date$
- */
-@Service(SCAManagedConversationalClient.class)
-@Scope("CONVERSATION")
-public class SCAManagedConversationalClientImpl implements SCAManagedConversationalClient, ConversationalServiceCallback {
-
- /**
- * Injected reference to the ConversationalService.
- */
- @Reference(name = "conversationalService")
- protected ServiceReference<ConversationalService> conversationalServiceRef;
-
- /**
- * Injected reference to the ConversationalService.
- */
- @Reference(name = "nestedConversationalService")
- protected ServiceReference<ConversationalService> nestedConversationalServiceRef;
-
- /**
- * This is the message that we sent to the callback.
- */
- private String messageSentToCallback;
-
- /**
- * Tests Serializing a Conversational ServiceReference.
- *
- * @throws Exception Test failed
- */
- public void testSerializeConversationalServiceReference() throws Exception {
- doTestSerializeConversationalServiceReference(conversationalServiceRef);
- }
-
- /**
- * Tests Serializing a Nested Conversational ServiceReference.
- *
- * @throws Exception Test failed
- */
- public void testSerializeNestedConversationalServiceReference() throws Exception {
- doTestSerializeConversationalServiceReference(nestedConversationalServiceRef);
- }
-
- /**
- * Test Serializing a Conversational ServiceReference.
- *
- * @param aServiceRef The Reference to Serialize
- * @throws Exception Test failed.
- */
- private void doTestSerializeConversationalServiceReference(ServiceReference<ConversationalService> aServiceRef) throws Exception {
- Assert.assertNotNull(aServiceRef);
-
- ConversationalService service = aServiceRef.getService();
- Object origConvID = service.getConversationID();
- Assert.assertNotNull(origConvID);
-
- // Serialize the ServiceReference
- byte[] serializedSR = ServiceReferenceUtils.serialize(aServiceRef);
- Assert.assertNotNull(serializedSR);
-
- // Deserialize the ServiceReference
- ServiceReference<?> deserializedSR = ServiceReferenceUtils.deserializeServiceReference(serializedSR);
- Assert.assertNotNull(deserializedSR);
- ServiceReference<ConversationalService> regotServiceRef = (ServiceReference<ConversationalService>) deserializedSR;
- Assert.assertNotNull(regotServiceRef);
-
- // Use the ServiceReference to access the Service.
- ConversationalService regotService = regotServiceRef.getService();
- Assert.assertNotNull(regotService);
- Object regotConvID = regotService.getConversationID();
- Assert.assertNotNull(regotConvID);
-
- // Make sure we have the same Conversation ID
- Assert.assertEquals(origConvID, regotConvID);
- }
-
-
- /**
- * Tests Serializing a Callback to a Conversational Service as managed
- * SCA code.
- *
- * @throws Exception Test failed
- */
- public void testSerializeCallbackToConversationalServiceInsideSCA() throws Exception {
- Assert.assertNotNull(conversationalServiceRef);
-
- ConversationalService service = conversationalServiceRef.getService();
- messageSentToCallback = "A message for the callback " + System.currentTimeMillis();
- service.triggerCallback(messageSentToCallback);
- }
-
- /**
- * Simple callback method.
- *
- * @param msg The call back message
- */
- public void callback(String msg) {
- System.out.println("Stateless Callback with message " + msg);
-
- // Make sure we received the message we expected
- Assert.assertEquals(messageSentToCallback, msg);
- }
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessService.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessService.java
deleted file mode 100644
index 8a1fe48436..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessService.java
+++ /dev/null
@@ -1,46 +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.servicereference;
-
-import org.osoa.sca.annotations.Callback;
-
-
-/**
- * A very simple Stateless Service
- *
- * @version $Date$ $Revision$
- */
-@Callback(StatelessServiceCallback.class)
-public interface StatelessService {
-
- /**
- * Gets the current time
- *
- * @return The current time
- */
- String getCurrentTime();
-
- /**
- * Method that triggers the callback
- *
- * @param msg A message to pass with the callback
- * @throws Exception Test failed
- */
- void triggerCallback(String msg) throws Exception;
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceCallback.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceCallback.java
deleted file mode 100644
index ffe3a3b8ef..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceCallback.java
+++ /dev/null
@@ -1,34 +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.servicereference;
-
-/**
- * This is the callback for the StatelessService
- *
- * @version $Date$ $Revision$
- */
-public interface StatelessServiceCallback {
-
- /**
- * Simple callback method
- *
- * @param msg The message for the call back
- */
- void callback(String msg);
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceImpl.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceImpl.java
deleted file mode 100644
index 24d43f79e3..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/StatelessServiceImpl.java
+++ /dev/null
@@ -1,82 +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.servicereference;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import org.apache.tuscany.sca.itest.servicereference.utils.ServiceReferenceUtils;
-import org.junit.Assert;
-import org.osoa.sca.CallableReference;
-import org.osoa.sca.annotations.Callback;
-import org.osoa.sca.annotations.Service;
-
-/**
- * Simple Stateless Service implementation
- *
- * @version $Date$ $Revision$
- */
-@Service(StatelessService.class)
-public class StatelessServiceImpl implements StatelessService {
-
- /**
- * Injected reference to the call back
- */
- @Callback
- protected CallableReference<StatelessServiceCallback> theCallbackRef;
-
- /**
- * Constructor
- */
- public StatelessServiceImpl() {
- }
-
- /**
- * Gets the current time
- *
- * @return The current time
- */
- public String getCurrentTime() {
- SimpleDateFormat sdf = new SimpleDateFormat();
- return sdf.format(new Date());
- }
-
- /**
- * Method that triggers the callback
- *
- * @param msg A message to pass with the callback
- * @throws Exception Test failed
- */
- public void triggerCallback(String msg) throws Exception {
- Assert.assertNotNull(theCallbackRef);
-
- // Serialize the CallableReference
- byte[] serializedCR = ServiceReferenceUtils.serialize(theCallbackRef);
- Assert.assertNotNull(serializedCR);
-
- // Deserlaize the CallableReference
- CallableReference<?> cr = ServiceReferenceUtils.deserializeCallableReference(serializedCR);
- Assert.assertNotNull(cr);
- CallableReference<StatelessServiceCallback> regotCallbackRef
- = (CallableReference<StatelessServiceCallback>) cr;
-
- // Use the deseralized CallbackReference
- regotCallbackRef.getService().callback(msg);
- }
-}
diff --git a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/utils/ServiceReferenceUtils.java b/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/utils/ServiceReferenceUtils.java
deleted file mode 100644
index 2749891bd4..0000000000
--- a/branches/sca-java-20080910/itest/serialization/src/main/java/org/apache/tuscany/sca/itest/servicereference/utils/ServiceReferenceUtils.java
+++ /dev/null
@@ -1,127 +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.servicereference.utils;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.ObjectInputStream;
-import java.io.ObjectOutputStream;
-
-import org.osoa.sca.CallableReference;
-import org.osoa.sca.ServiceReference;
-
-/**
- * Utility methods that are used by the ServiceReference Serialization tests
- *
- * @version $Date $Revision$
- */
-public final class ServiceReferenceUtils {
-
- /**
- * Constructor
- */
- private ServiceReferenceUtils() {
- }
-
- /**
- * Serializes the specified Object to a byte[]
- *
- * @param obj The Object to Serialize
- * @return The Serialized Object as a byte[]
- * @throws IOException Failed to Serialize the Object
- */
- public static byte[] serialize(Object obj) throws IOException {
- ByteArrayOutputStream bos = null;
- try {
- ObjectOutputStream oos = null;
- bos = new ByteArrayOutputStream();
- try {
- oos = new ObjectOutputStream(bos);
- oos.writeObject(obj);
- oos.flush();
- } finally {
- if (oos != null) {
- oos.close();
- }
- }
- } finally {
- if (bos != null) {
- bos.close();
- }
- }
-
- return bos.toByteArray();
- }
-
- /**
- * Deserializes the specified byte[] into a ServiceReference
- *
- * @param serializedSR The Serialized ServiceReference to deserialize
- * @return The deserialized ServiceReference
- * @throws IOException Failed to deserialize the ServiceReference
- * @throws ClassNotFoundException Failed to deserialize the ServiceReference
- */
- public static ServiceReference<?> deserializeServiceReference(byte[] serializedSR)
- throws IOException, ClassNotFoundException {
- return (ServiceReference<?>) deserialize(serializedSR);
- }
-
- /**
- * Deserializes the specified byte[] into a CallableReference
- *
- * @param callableRef The Serialized CallableReference to deserialize
- * @return The deserialized ServiceReference
- * @throws IOException Failed to deserialize the CallableReference
- * @throws ClassNotFoundException Failed to deserialize the CallableReference
- */
- public static CallableReference<?> deserializeCallableReference(byte[] callableRef)
- throws IOException, ClassNotFoundException {
- return (CallableReference<?>) deserialize(callableRef);
- }
-
- /**
- * Deserializes the specified byte[] into an Object
- *
- * @param serializedObj The Serialized Object to deserialize
- * @return The deserialized Object
- * @throws IOException Failed to deserialize the Object
- * @throws ClassNotFoundException Failed to deserialize the Object
- */
- public static Object deserialize(byte[] serializedSR) throws IOException, ClassNotFoundException {
- ByteArrayInputStream bis = null;
- try {
- ObjectInputStream ois = null;
- bis = new ByteArrayInputStream(serializedSR);
- try {
- ois = new ObjectInputStream(bis);
- Object obj = ois.readObject();
- return obj;
- } finally {
- if (ois != null) {
- ois.close();
- }
- }
- } finally {
- if (bis != null) {
- bis.close();
- }
- }
- }
-}