diff options
Diffstat (limited to 'tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org')
10 files changed, 0 insertions, 642 deletions
diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/AService.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/AService.java deleted file mode 100644 index f5249b3a5b..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/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.vtest.javaapi.conversation.lifetime; - -import org.oasisopen.sca.annotation.Remotable; - -/** - * Simple Remotable Service - */ -@Remotable -public interface AService { - - public void testConversationStarted(); - - public void testConversationStarted2(); - - public void testConversationContinue(); - - public void testConversationContinue2(); - - public void testConversationContinue3(); - - public void testConversationEnd(); - - public void testConversationEnd2(); - - public void testConversationEnd3(); - - public void testConversationEnd4(); - - public void testConversationEnd5(); - - public void testConversationEnd6(); - - public void testConversationEnd7(); - - public void testConversationEnd8(); - - public void testConversationEnd9(); -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/AServiceCallback.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/AServiceCallback.java deleted file mode 100644 index 635e6e74d4..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/AServiceCallback.java +++ /dev/null @@ -1,35 +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.vtest.javaapi.conversation.lifetime; - -import org.oasisopen.sca.annotation.Conversational; -import org.oasisopen.sca.annotation.EndsConversation; -import org.oasisopen.sca.annotation.Remotable; - -/** - * Simple Remotable Service - */ -@Remotable -@Conversational -public interface AServiceCallback { - - @EndsConversation - public void endConversation(); - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/BService.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/BService.java deleted file mode 100644 index b28a31da38..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/BService.java +++ /dev/null @@ -1,47 +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.vtest.javaapi.conversation.lifetime; - -import org.oasisopen.sca.annotation.Callback; -import org.oasisopen.sca.annotation.Conversational; -import org.oasisopen.sca.annotation.EndsConversation; -import org.oasisopen.sca.annotation.Remotable; - -/** - * Simple Local Service - */ -@Remotable -@Conversational -@Callback(AServiceCallback.class) -public interface BService { - - public void setState(String someState); - - public String getState(); - - @EndsConversation - public void endConversation(); - - public void endConversationViaCallback(); - - public void throwNonBusinessException(); - - public void throwBusinessException() throws BServiceBusinessException; - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/BServiceBusinessException.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/BServiceBusinessException.java deleted file mode 100644 index ab186ee7eb..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/BServiceBusinessException.java +++ /dev/null @@ -1,53 +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.vtest.javaapi.conversation.lifetime; - - -/** - * Denotes an error starting the runtime - * - * @version $Rev$ $Date$ - */ -public class BServiceBusinessException extends Exception { - - static final long serialVersionUID = 2096658015909178325L; - - private String message; - - public BServiceBusinessException() { - } - - public BServiceBusinessException(String message) { - super(message); - setMessage(message); - } - - public BServiceBusinessException(Throwable cause) { - super(cause); - setMessage(cause.getMessage()); - } - - public String getMessage() { - return message; - } - - public void setMessage(String message) { - this.message = message; - } -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/CService.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/CService.java deleted file mode 100644 index 020d18b862..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/CService.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.vtest.javaapi.conversation.lifetime; - -import org.oasisopen.sca.annotation.Conversational; -import org.oasisopen.sca.annotation.Remotable; - -/** - * Simple Local Service - */ -@Remotable -@Conversational -public interface CService { - - public void setState(String someState); - public String getState(); - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/DService.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/DService.java deleted file mode 100644 index c339ebd6ea..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/DService.java +++ /dev/null @@ -1,38 +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.vtest.javaapi.conversation.lifetime; - -import org.oasisopen.sca.ServiceReference; -import org.oasisopen.sca.annotation.Conversational; -import org.oasisopen.sca.annotation.Remotable; - -/** - * Simple Local Service - */ -@Remotable -@Conversational -public interface DService { - - public void setState(String someState); - public String getState(); - - public void continueConversation(ServiceReference<BService> b, Object convId); - public void continueConversation2(String filename, Object id, String serializedState); - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/AServiceImpl.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/AServiceImpl.java deleted file mode 100644 index 18d592f9d0..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/AServiceImpl.java +++ /dev/null @@ -1,197 +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.vtest.javaapi.conversation.lifetime.impl; - -import java.io.FileOutputStream; -import java.io.IOException; -import java.io.ObjectOutputStream; - -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.AService; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.AServiceCallback; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.BService; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.BServiceBusinessException; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.CService; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.DService; -import org.junit.Assert; -import org.oasisopen.sca.ComponentContext; -import org.oasisopen.sca.ConversationEndedException; -import org.oasisopen.sca.ServiceReference; -import org.oasisopen.sca.annotation.Context; -import org.oasisopen.sca.annotation.Reference; -import org.oasisopen.sca.annotation.Scope; -import org.oasisopen.sca.annotation.Service; - -@Service(AService.class) -@Scope("CONVERSATION") -public class AServiceImpl implements AService, AServiceCallback { - - @Context - public ComponentContext context; - - @Reference - protected ServiceReference<BService> b; - - @Reference - protected DService d; - - public void testConversationStarted() { - b.getService().setState("Some state"); - Assert.assertNotNull(b.getConversation().getConversationID()); - } - - public void testConversationStarted2() { - ServiceReference<BService> ref = context.getServiceReference(BService.class, "b"); - ref.getService().setState("Some state"); - Assert.assertNotNull(ref.getConversation().getConversationID()); - } - - public void testConversationContinue() { - - b.getService().setState("Some state"); - Object id = b.getConversation().getConversationID(); - b.getService().setState("Some more state"); - Assert.assertEquals(id, b.getConversation().getConversationID()); - } - - public void testConversationContinue2() { - - b.getService().setState("Some state"); - d.continueConversation(b, b.getConversation().getConversationID()); - - } - - public void testConversationContinue3() { - - String serializedState = "Serialized State"; - - String filename = "target/Serialized-Reference.txt"; - b.getService().setState(serializedState); - Object id = b.getConversation().getConversationID(); - writeReference(b, filename); - d.continueConversation2(filename, id, serializedState); - - } - - // Utilities - - private void delayForSeconds(int numSeconds) { - try { - Thread.sleep(numSeconds * 1000);// millisecs - } catch (InterruptedException ex) { - throw new Error(ex); - } - } - - private void writeReference(ServiceReference<BService> ref, String filename) { - - FileOutputStream fos = null; - ObjectOutputStream out = null; - try { - fos = new FileOutputStream(filename); - out = new ObjectOutputStream(fos); - out.writeObject(ref); - out.close(); - } catch (IOException ex) { - ex.printStackTrace(); - } - } - - public void testConversationEnd() { - String someState = "Some state"; - b.getService().setState(someState); - b.getService().endConversation(); - Assert.assertNotSame(someState, b.getService().getState()); - } - - public void testConversationEnd2() { - String someState = "Some state"; - b.getService().setState(someState); - b.getService().endConversationViaCallback(); - Assert.assertNotSame(someState, b.getService().getState()); - } - - public void endConversation() { - System.out.println("A-callback to end conversation"); - } - - public void testConversationEnd3() { - String someState = "Some state"; - b.getService().setState(someState); - delayForSeconds(2); - try { - b.getService().getState(); - } catch (ConversationEndedException e) { - b.getConversation().end();// need to clean up to avoid exception - } - Assert.assertNotSame(someState, b.getService().getState()); - } - - public void testConversationEnd4() { - String someState = "Some state"; - b.getService().setState(someState); - b.getConversation().end(); - Assert.assertNotSame(someState, b.getService().getState()); - } - - public void testConversationEnd5() { - String someState = "Some state"; - b.getService().setState(someState); - try { - b.getService().throwNonBusinessException(); - } catch (Error e) { - // Expected - } - Assert.assertNotSame(someState, b.getService().getState()); - } - - public void testConversationEnd6() { - String someState = "Some state"; - b.getService().setState(someState); - Object id = b.getConversation().getConversationID(); - b.getService().endConversation(); - Assert.assertNotSame(someState, b.getService().getState()); - Assert.assertNotSame(id, b.getConversation().getConversationID()); - } - - public void testConversationEnd7() { - b.getService().setState("Some state"); - b.getService().endConversation(); - Assert.assertNull(b.getConversationID()); - } - - public void testConversationEnd8() { - String someState = "Some state"; - b.getService().setState(someState); - delayForSeconds(2); - b.getService().getState(); - } - - public void testConversationEnd9() { - String someState = "Some state"; - b.getService().setState(someState); - try { - b.getService().throwBusinessException(); - } catch (BServiceBusinessException e) { - // Expected - } - Assert.assertSame(someState, b.getService().getState()); - } - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/BServiceImpl.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/BServiceImpl.java deleted file mode 100644 index 71e09c38b3..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/BServiceImpl.java +++ /dev/null @@ -1,64 +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.vtest.javaapi.conversation.lifetime.impl; - -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.AServiceCallback; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.BService; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.BServiceBusinessException; -import org.oasisopen.sca.annotation.Callback; -import org.oasisopen.sca.annotation.ConversationAttributes; -import org.oasisopen.sca.annotation.Scope; -import org.oasisopen.sca.annotation.Service; - -@Service(BService.class) -@Scope("CONVERSATION") -@ConversationAttributes(maxAge="1 seconds") -public class BServiceImpl implements BService { - - String someState; - - @Callback - protected AServiceCallback callback; - - public void setState(String someState) { - this.someState = someState; - } - - public String getState() { - return someState; - } - - public void endConversation() { - System.out.println("Someone called Bservice.endsConversation()"); - } - - public void endConversationViaCallback() { - callback.endConversation(); - } - - public void throwNonBusinessException() { - throw new Error(); - } - - public void throwBusinessException() throws BServiceBusinessException { - throw new BServiceBusinessException("Business Exception"); - } - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/CServiceImpl.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/CServiceImpl.java deleted file mode 100644 index e182613932..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/CServiceImpl.java +++ /dev/null @@ -1,40 +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.vtest.javaapi.conversation.lifetime.impl; - -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.CService; -import org.oasisopen.sca.annotation.Scope; -import org.oasisopen.sca.annotation.Service; - -@Service(CService.class) -@Scope("CONVERSATION") -public class CServiceImpl implements CService { - - String someState; - - public void setState(String someState) { - this.someState = someState; - } - - public String getState() { - return someState; - } - -} diff --git a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/DServiceImpl.java b/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/DServiceImpl.java deleted file mode 100644 index 15a4ab3b76..0000000000 --- a/tags/java/sca/2.0-M1/vtest/java-api/conversation/lifetime/src/main/java/org/apache/tuscany/sca/vtest/javaapi/conversation/lifetime/impl/DServiceImpl.java +++ /dev/null @@ -1,78 +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.vtest.javaapi.conversation.lifetime.impl; - -import java.io.FileInputStream; -import java.io.IOException; -import java.io.ObjectInputStream; - -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.BService; -import org.apache.tuscany.sca.vtest.javaapi.conversation.lifetime.DService; -import org.junit.Assert; -import org.oasisopen.sca.ServiceReference; -import org.oasisopen.sca.annotation.Scope; -import org.oasisopen.sca.annotation.Service; - -@Service(DService.class) -@Scope("CONVERSATION") -public class DServiceImpl implements DService { - - String someState; - - public void setState(String someState) { - this.someState = someState; - } - - public String getState() { - return someState; - } - - public void continueConversation(ServiceReference<BService> b, Object convId) { - - b.getService().setState("Some more state"); - Assert.assertEquals(convId, b.getConversation().getConversationID()); - } - - public void continueConversation2(String filename, Object convId, String serializedState) { - ServiceReference<BService> b = readReference(filename); - Assert.assertEquals(serializedState, b.getService().getState()); - Assert.assertEquals(convId, b.getConversation().getConversationID()); - } - - // Utilities - @SuppressWarnings("unchecked") - private ServiceReference<BService> readReference(String filename) { - ServiceReference<BService> b = null; - FileInputStream fis = null; - ObjectInputStream in = null; - try { - fis = new FileInputStream(filename); - in = new ObjectInputStream(fis); - ServiceReference<BService> readObject = (ServiceReference<BService>)in.readObject(); - b = readObject; - in.close(); - } catch (IOException ex) { - ex.printStackTrace(); - } catch (ClassNotFoundException ex) { - ex.printStackTrace(); - } - return b; - } -} |