diff options
Diffstat (limited to 'branches/sca-java-1.5.1/modules/binding-erlang/src')
8 files changed, 0 insertions, 656 deletions
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/branches/sca-java-1.5.1/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.1/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.1/modules/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java b/branches/sca-java-1.5.1/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.1/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 - } - -} |