summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-1.5/modules/binding-erlang/src
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java70
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java31
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java37
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java166
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java160
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory19
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor19
-rw-r--r--branches/sca-java-1.5/modules/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java154
8 files changed, 0 insertions, 656 deletions
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java b/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java
deleted file mode 100644
index a472e88f98..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java
+++ /dev/null
@@ -1,70 +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.binding.erlang;
-
-import javax.xml.namespace.QName;
-
-import org.apache.tuscany.sca.assembly.Binding;
-import org.apache.tuscany.sca.assembly.xml.Constants;
-
-/**
- * @version $Rev: $ $Date: $
- */
-public interface ErlangBinding extends Binding {
-
- final long NO_TIMEOUT = 0;
- // NOTE: default thread pool size
- final int DEFAULT_THREAD_POOL = 20;
-
- QName BINDING_ERLANG_QNAME = new QName(Constants.SCA10_TUSCANY_NS, "binding.erlang");
-
- String getNode();
-
- void setNode(String node);
-
- String getModule();
-
- void setModule(String module);
-
- boolean isMbox();
-
- void setMbox(boolean mbox);
-
- long getTimeout();
-
- void setTimeout(long timeout);
-
- String getCookie();
-
- void setCookie(String cookie);
-
- boolean hasTimeout();
-
- boolean hasCookie();
-
- int getServiceThreadPool();
-
- void setServiceThreadPool(int threads);
-
- boolean isDefaultTimeout();
-
- boolean isDefaultServiceThreadPool();
-
-}
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java b/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java
deleted file mode 100644
index 4c85695dd3..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java
+++ /dev/null
@@ -1,31 +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.binding.erlang;
-
-/**
- * @version $Rev: $ $Date: $
- */
-public interface ErlangBindingFactory {
- /**
- * Create a ErlangBinding model
- * @return The ErlangBinding model
- */
- ErlangBinding createErlangBinding();
-}
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java b/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java
deleted file mode 100644
index 1d2e1eefcf..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.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.binding.erlang.impl;
-
-import org.apache.tuscany.sca.binding.erlang.ErlangBinding;
-import org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory;
-
-/**
- * @version $Rev: $ $Date: $
- */
-public class ErlangBindingFactoryImpl implements ErlangBindingFactory {
-
- /**
- * @see org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory#createErlangBinding()
- */
- public ErlangBinding createErlangBinding() {
- return new ErlangBindingImpl();
- }
-
-}
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java b/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
deleted file mode 100644
index 17fd731063..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
+++ /dev/null
@@ -1,166 +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.binding.erlang.impl;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.tuscany.sca.binding.erlang.ErlangBinding;
-import org.apache.tuscany.sca.policy.Intent;
-import org.apache.tuscany.sca.policy.IntentAttachPointType;
-import org.apache.tuscany.sca.policy.PolicySet;
-import org.apache.tuscany.sca.policy.PolicySetAttachPoint;
-
-/**
- * @version $Rev: $ $Date: $
- */
-public class ErlangBindingImpl implements ErlangBinding, PolicySetAttachPoint {
-
- private String node;
- private String module;
- private boolean mbox;
- private String cookie;
- private int serviceThreadPool = DEFAULT_THREAD_POOL;
-
- private boolean defaultTimeout = true;
- private boolean defaultThreads = true;
-
- private List<Intent> requiredIntents = new ArrayList<Intent>();
- private List<PolicySet> policySets = new ArrayList<PolicySet>();
- private IntentAttachPointType intentAttachPointType;
- private List<PolicySet> applicablePolicySets = new ArrayList<PolicySet>();
- private long timeout = NO_TIMEOUT;
-
- public String getNode() {
- return node;
- }
-
- public void setNode(String nodeName) {
- this.node = nodeName;
- }
-
- public String getName() {
- return null;
- }
-
- public String getURI() {
- return null;
- }
-
- public void setName(String arg0) {
- }
-
- public void setURI(String arg0) {
- }
-
- public boolean isUnresolved() {
- return false;
- }
-
- public void setUnresolved(boolean arg0) {
- }
-
- public List<PolicySet> getApplicablePolicySets() {
- return applicablePolicySets;
- }
-
- public List<PolicySet> getPolicySets() {
- return policySets;
- }
-
- public List<Intent> getRequiredIntents() {
- return requiredIntents;
- }
-
- public IntentAttachPointType getType() {
- return intentAttachPointType;
- }
-
- public void setType(IntentAttachPointType intentAttachPointType) {
- this.intentAttachPointType = intentAttachPointType;
- }
-
- @Override
- public Object clone() throws CloneNotSupportedException {
- return super.clone();
- }
-
- public String getModule() {
- return module;
- }
-
- public boolean isMbox() {
- return mbox;
- }
-
- public void setMbox(boolean mbox) {
- this.mbox = mbox;
- }
-
- public void setModule(String module) {
- this.module = module;
- }
-
- public long getTimeout() {
- return timeout;
- }
-
- public void setTimeout(long timeout) {
- // NOTE: not setting timeout or setting it to 0 will cause no timeout
- this.timeout = timeout;
- if (timeout != 0) {
- defaultTimeout = false;
- }
- }
-
- public String getCookie() {
- return cookie;
- }
-
- public void setCookie(String cookie) {
- this.cookie = cookie;
- }
-
- public boolean hasTimeout() {
- return timeout != ErlangBinding.NO_TIMEOUT;
- }
-
- public boolean hasCookie() {
- return cookie != null && cookie.length() > 0;
- }
-
- public int getServiceThreadPool() {
- return serviceThreadPool;
- }
-
- public void setServiceThreadPool(int threads) {
- this.serviceThreadPool = threads;
- this.defaultThreads = false;
- }
-
- public boolean isDefaultServiceThreadPool() {
- return defaultThreads;
- }
-
- public boolean isDefaultTimeout() {
- return defaultTimeout;
- }
-
-}
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java b/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java
deleted file mode 100644
index 07b7533314..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java
+++ /dev/null
@@ -1,160 +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.binding.erlang.impl;
-
-import javax.xml.namespace.QName;
-import javax.xml.stream.XMLStreamException;
-import javax.xml.stream.XMLStreamReader;
-import javax.xml.stream.XMLStreamWriter;
-
-import org.apache.tuscany.sca.assembly.xml.Constants;
-import org.apache.tuscany.sca.assembly.xml.PolicyAttachPointProcessor;
-import org.apache.tuscany.sca.binding.erlang.ErlangBinding;
-import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
-import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
-import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
-import org.apache.tuscany.sca.contribution.service.ContributionReadException;
-import org.apache.tuscany.sca.contribution.service.ContributionResolveException;
-import org.apache.tuscany.sca.contribution.service.ContributionWriteException;
-import org.apache.tuscany.sca.policy.PolicyFactory;
-
-/**
- * @version $Rev: $ $Date: $
- */
-public class ErlangBindingProcessor implements
- StAXArtifactProcessor<ErlangBinding> {
-
- private PolicyFactory policyFactory;
- private PolicyAttachPointProcessor policyProcessor;
-
- private static final String ATTR_COOKIE = "cookie";
- private static final String ATTR_MBOX = "mbox";
- private static final String ATTR_MODULE = "module";
- private static final String ATTR_NODE = "node";
- private static final String ATTR_SERVICE_THREAD_POOL = "serviceThreadPool";
- private static final String ATTR_TIMEOUT = "timeout";
-
- public ErlangBindingProcessor(ModelFactoryExtensionPoint modelFactories) {
- this.policyFactory = modelFactories.getFactory(PolicyFactory.class);
- this.policyProcessor = new PolicyAttachPointProcessor(policyFactory);
- }
-
- /**
- * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#getArtifactType()
- */
- public QName getArtifactType() {
- return ErlangBinding.BINDING_ERLANG_QNAME;
- }
-
- /**
- * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#read(javax.xml.stream.XMLStreamReader)
- */
- public ErlangBinding read(XMLStreamReader reader)
- throws ContributionReadException, XMLStreamException {
- ErlangBinding binding = new ErlangBindingImpl();
-
- // Read the policies
- policyProcessor.readPolicies(binding, reader);
-
- binding.setNode(reader.getAttributeValue(null, ATTR_NODE));
-
- String mboxValue = reader.getAttributeValue(null, ATTR_MBOX);
-
- if (mboxValue != null && mboxValue.length() > 0) {
- try {
- binding.setMbox(Boolean.parseBoolean(mboxValue));
- } catch (Exception e) {
- }
- }
-
- try {
- binding.setTimeout(Long.parseLong(reader.getAttributeValue(null,
- ATTR_TIMEOUT)));
- } catch (NumberFormatException e) {
- }
-
- binding.setModule(reader.getAttributeValue(null, ATTR_MODULE));
-
- binding.setCookie(reader.getAttributeValue(null, ATTR_COOKIE));
-
- try {
- binding.setServiceThreadPool(Integer.parseInt(reader
- .getAttributeValue(null, ATTR_SERVICE_THREAD_POOL)));
- } catch (NumberFormatException e) {
- }
-
- return binding;
- }
-
- /**
- * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#write(java.lang.Object,
- * javax.xml.stream.XMLStreamWriter)
- */
- public void write(ErlangBinding model, XMLStreamWriter writer)
- throws ContributionWriteException, XMLStreamException {
-
-
- writer.writeStartElement(Constants.SCA10_TUSCANY_NS, "binding.erlang");
-
- if (model.getCookie() != null && model.getCookie().length() > 0) {
- writer.writeAttribute(ATTR_COOKIE, model.getCookie());
- }
-
- if (model.isMbox()) {
- writer.writeAttribute(ATTR_MBOX, Boolean.TRUE.toString());
- }
-
- if (model.getModule() != null && model.getModule().length() > 0) {
- writer.writeAttribute(ATTR_MODULE, model.getModule());
- }
-
- if (model.getNode() != null && model.getNode().length() > 0) {
- writer.writeAttribute(ATTR_NODE, model.getNode());
- }
-
- if (!model.isDefaultServiceThreadPool()) {
- writer.writeAttribute(ATTR_SERVICE_THREAD_POOL, Integer
- .toString(model.getServiceThreadPool()));
- }
-
- if (!model.isDefaultTimeout()) {
- writer.writeAttribute(ATTR_TIMEOUT, Long.toString(model
- .getTimeout()));
- }
-
- writer.writeEndElement();
- }
-
- /**
- * @see org.apache.tuscany.sca.contribution.processor.ArtifactProcessor#getModelType()
- */
- public Class<ErlangBinding> getModelType() {
- return ErlangBinding.class;
- }
-
- /**
- * @see org.apache.tuscany.sca.contribution.processor.ArtifactProcessor#resolve(java.lang.Object,
- * org.apache.tuscany.sca.contribution.resolver.ModelResolver)
- */
- public void resolve(ErlangBinding model, ModelResolver resolver)
- throws ContributionResolveException {
- }
-
-}
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory b/branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory
deleted file mode 100644
index c7872d89c9..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory
+++ /dev/null
@@ -1,19 +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.
-
-# Implementation class for the model factory
-org.apache.tuscany.sca.binding.erlang.impl.ErlangBindingFactoryImpl \ No newline at end of file
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor
deleted file mode 100644
index 6e614aac3e..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor
+++ /dev/null
@@ -1,19 +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.
-
-# Implementation class for the artifact processor extension
-org.apache.tuscany.sca.binding.erlang.impl.ErlangBindingProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.0#binding.erlang,model=org.apache.tuscany.sca.binding.erlang.ErlangBinding,factory=org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory
diff --git a/branches/sca-java-1.5/modules/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java b/branches/sca-java-1.5/modules/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
deleted file mode 100644
index 673c735f1e..0000000000
--- a/branches/sca-java-1.5/modules/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
+++ /dev/null
@@ -1,154 +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.binding.erlang.testing;
-
-import static org.junit.Assert.assertEquals;
-
-import java.io.ByteArrayOutputStream;
-import java.io.StringReader;
-
-import javax.xml.stream.XMLInputFactory;
-import javax.xml.stream.XMLOutputFactory;
-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;
-import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint;
-import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry;
-import org.apache.tuscany.sca.core.UtilityExtensionPoint;
-import org.apache.tuscany.sca.monitor.Monitor;
-import org.apache.tuscany.sca.monitor.MonitorFactory;
-import org.apache.tuscany.sca.monitor.impl.DefaultMonitorFactoryImpl;
-import org.junit.BeforeClass;
-import org.junit.Ignore;
-import org.junit.Test;
-
-/**
- * General tests for binding.erlang XML processor
- */
-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\" serviceThreadPool=\"1\"/>"
- + " </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\"/>"
- + " <service name=\"HelloWorldService\">"
- + " <tuscany:binding.erlang node=\"SomeNode\"/>"
- + " </service>" + " </component>" + "</composite>";
-
- private static XMLInputFactory inputFactory;
- private static StAXArtifactProcessor<Object> staxProcessor;
- private static Monitor monitor;
-
- @BeforeClass
- public static void init() throws Exception {
- DefaultExtensionPointRegistry extensionPoints = new DefaultExtensionPointRegistry();
- inputFactory = XMLInputFactory.newInstance();
- // Create a monitor
- UtilityExtensionPoint utilities = extensionPoints
- .getExtensionPoint(UtilityExtensionPoint.class);
- MonitorFactory monitorFactory = new DefaultMonitorFactoryImpl();
- if (monitorFactory != null) {
- monitor = monitorFactory.createMonitor();
- utilities.addUtility(monitorFactory);
- }
- StAXArtifactProcessorExtensionPoint staxProcessors = new DefaultStAXArtifactProcessorExtensionPoint(
- extensionPoints);
- staxProcessor = new ExtensibleStAXArtifactProcessor(staxProcessors,
- inputFactory, null, monitor);
- }
-
- /**
- * Tests reading "binding.erlang" element
- *
- * @throws Exception
- */
- @Test
- public void testLoadValidComposite() throws Exception {
- XMLStreamReader reader = inputFactory
- .createXMLStreamReader(new StringReader(COMPOSITE));
- Composite composite = (Composite) staxProcessor.read(reader);
- 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());
- assertEquals(true, binding.hasTimeout());
- assertEquals(true, binding.hasCookie());
- assertEquals(1, binding.getServiceThreadPool());
- assertEquals(false, binding.isDefaultServiceThreadPool());
- assertEquals(false, binding.isDefaultTimeout());
- }
-
- /**
- * Tests using default "resultTimeout", default thread pool, no cookie
- *
- * @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.NO_TIMEOUT, binding.getTimeout());
- assertEquals(null, binding.getCookie());
- assertEquals(false, binding.hasTimeout());
- assertEquals(false, binding.hasCookie());
- assertEquals(ErlangBinding.DEFAULT_THREAD_POOL, binding
- .getServiceThreadPool());
- assertEquals(true, binding.isDefaultServiceThreadPool());
- assertEquals(true, binding.isDefaultTimeout());
- }
-
- @Test
- @Ignore("unbound namespace problem")
- //FIXME: fix it
- public void testWrite() throws Exception {
- XMLStreamReader reader = inputFactory.createXMLStreamReader(new StringReader(COMPOSITE));
- Composite composite = (Composite)staxProcessor.read(reader);
- ErlangBinding binding1 = (ErlangBinding)composite.getComponents().get(0).getServices().get(0).getBindings().get(0);
- ByteArrayOutputStream bos = new ByteArrayOutputStream();
- XMLOutputFactory outputFactory = XMLOutputFactory.newInstance();
-
- staxProcessor.write(composite, outputFactory.createXMLStreamWriter(bos));
-
- XMLStreamReader reader2 = inputFactory.createXMLStreamReader(new StringReader(bos.toString()));
- Composite composite2 = (Composite)staxProcessor.read(reader2);
- ErlangBinding binding2 = (ErlangBinding)composite2.getComponents().get(0).getServices().get(0).getBindings().get(0);
-
- //compare binding1 to binding2
- }
-
-}