From 420526884c2571aa4b17c69e98128bfd0612046e Mon Sep 17 00:00:00 2001
From: wjaniszewski <wjaniszewski@13f79535-47bb-0310-9956-ffa450edef68>
Date: Thu, 19 Mar 2009 21:28:08 +0000
Subject: Added timeout feature for reference bindings. Added reference cookies
 - need more testing. Added some comments to organize tasks.

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@756212 13f79535-47bb-0310-9956-ffa450edef68
---
 .../testing/ErlangBindingProcessorTestCase.java    | 52 ++++++++++++++++++++++
 1 file changed, 52 insertions(+)

(limited to 'sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing')

diff --git a/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java b/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
index 72574b2fb6..6a229d1ea2 100644
--- a/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
+++ b/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
@@ -28,6 +28,7 @@ import javax.xml.stream.XMLStreamReader;
 
 import org.apache.tuscany.sca.assembly.Composite;
 import org.apache.tuscany.sca.binding.erlang.ErlangBinding;
+import org.apache.tuscany.sca.binding.erlang.impl.ErlangBindingImpl;
 import org.apache.tuscany.sca.contribution.processor.DefaultStAXArtifactProcessorExtensionPoint;
 import org.apache.tuscany.sca.contribution.processor.ExtensibleStAXArtifactProcessor;
 import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
@@ -46,6 +47,16 @@ import org.junit.Test;
 public class ErlangBindingProcessorTestCase {
 
     private static final String COMPOSITE =
+        "<?xml version=\"1.0\" encoding=\"ASCII\"?>" + "<composite xmlns=\"http://www.osoa.org/xmlns/sca/1.0\" xmlns:tuscany=\"http://tuscany.apache.org/xmlns/sca/1.0\" targetNamespace=\"http://binding-erlang\" name=\"binding-erlang\">"
+            + " <component name=\"HelloWorldComponent\">"
+            + "   <implementation.java class=\"services.HelloWorld\"/>"
+            + "      <service name=\"HelloWorldService\">"
+            + "          <tuscany:binding.erlang node=\"SomeNode\" timeout=\"1000\" cookie=\"cookie\"/>"
+            + "      </service>"
+            + " </component>"
+            + "</composite>";
+    
+    private static final String COMPOSITE_DEFAULT_TIMEOUT =
         "<?xml version=\"1.0\" encoding=\"ASCII\"?>" + "<composite xmlns=\"http://www.osoa.org/xmlns/sca/1.0\" xmlns:tuscany=\"http://tuscany.apache.org/xmlns/sca/1.0\" targetNamespace=\"http://binding-erlang\" name=\"binding-erlang\">"
             + " <component name=\"HelloWorldComponent\">"
             + "   <implementation.java class=\"services.HelloWorld\"/>"
@@ -54,6 +65,16 @@ public class ErlangBindingProcessorTestCase {
             + "      </service>"
             + " </component>"
             + "</composite>";
+    
+    private static final String COMPOSITE_ZERO_TIMEOUT =
+        "<?xml version=\"1.0\" encoding=\"ASCII\"?>" + "<composite xmlns=\"http://www.osoa.org/xmlns/sca/1.0\" xmlns:tuscany=\"http://tuscany.apache.org/xmlns/sca/1.0\" targetNamespace=\"http://binding-erlang\" name=\"binding-erlang\">"
+            + " <component name=\"HelloWorldComponent\">"
+            + "   <implementation.java class=\"services.HelloWorld\"/>"
+            + "      <service name=\"HelloWorldService\">"
+            + "          <tuscany:binding.erlang node=\"SomeNode\" timeout=\"0\"/>"
+            + "      </service>"
+            + " </component>"
+            + "</composite>";
 
     private static XMLInputFactory inputFactory;
     private static StAXArtifactProcessor<Object> staxProcessor;
@@ -87,6 +108,37 @@ public class ErlangBindingProcessorTestCase {
         ErlangBinding binding =
             (ErlangBinding)composite.getComponents().get(0).getServices().get(0).getBindings().get(0);
         assertEquals("SomeNode", binding.getNode());
+        assertEquals(1000, binding.getTimeout());
+        assertEquals("cookie", binding.getCookie());
+    }
+    
+    /**
+     * Tests using default "resultTimeout" value
+     * 
+     * @throws Exception
+     */
+    @Test
+    public void testLoadDefaultTimeout() throws Exception {
+        XMLStreamReader reader = inputFactory.createXMLStreamReader(new StringReader(COMPOSITE_DEFAULT_TIMEOUT));
+        Composite composite = (Composite)staxProcessor.read(reader);
+        ErlangBinding binding =
+            (ErlangBinding)composite.getComponents().get(0).getServices().get(0).getBindings().get(0);
+        assertEquals(ErlangBindingImpl.DEFAULT_TIMEOUT, binding.getTimeout());
+        assertEquals(null, binding.getCookie());
     }
 
+    /**
+     * Tests "resultTimeout" attribute set to 0 
+     * 
+     * @throws Exception
+     */
+    @Test
+    public void testLoadZeroTimeout() throws Exception {
+        XMLStreamReader reader = inputFactory.createXMLStreamReader(new StringReader(COMPOSITE_ZERO_TIMEOUT));
+        Composite composite = (Composite)staxProcessor.read(reader);
+        ErlangBinding binding =
+            (ErlangBinding)composite.getComponents().get(0).getServices().get(0).getBindings().get(0);
+        assertEquals(ErlangBindingImpl.DEFAULT_TIMEOUT, binding.getTimeout());
+    }
+    
 }
-- 
cgit v1.2.3