diff options
Diffstat (limited to 'sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java')
| -rw-r--r-- | sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java | 122 |
1 files changed, 65 insertions, 57 deletions
diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java index f601e3327c..b611cb2296 100644 --- a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java +++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java @@ -38,69 +38,77 @@ import org.apache.tuscany.sca.policy.PolicyFactory; /**
* @version $Rev: $ $Date: $
*/
-public class ErlangBindingProcessor implements StAXArtifactProcessor<ErlangBinding> {
+public class ErlangBindingProcessor implements
+ StAXArtifactProcessor<ErlangBinding> {
- private PolicyFactory policyFactory;
- private PolicyAttachPointProcessor policyProcessor;
-
- public ErlangBindingProcessor(ModelFactoryExtensionPoint modelFactories) {
- this.policyFactory = modelFactories.getFactory(PolicyFactory.class);
- this.policyProcessor = new PolicyAttachPointProcessor(policyFactory);
- }
+ private PolicyFactory policyFactory;
+ private PolicyAttachPointProcessor policyProcessor;
- /**
- * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#getArtifactType()
- */
- public QName getArtifactType() {
- return ErlangBinding.BINDING_ERLANG_QNAME;
- }
+ public ErlangBindingProcessor(ModelFactoryExtensionPoint modelFactories) {
+ this.policyFactory = modelFactories.getFactory(PolicyFactory.class);
+ this.policyProcessor = new PolicyAttachPointProcessor(policyFactory);
+ }
- /**
- * @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();
+ /**
+ * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#getArtifactType()
+ */
+ public QName getArtifactType() {
+ return ErlangBinding.BINDING_ERLANG_QNAME;
+ }
- // Read the policies
- policyProcessor.readPolicies(binding, reader);
- binding.setNode(reader.getAttributeValue(null, "node"));
- String mboxValue = reader.getAttributeValue(null, "mbox");
- if (mboxValue != null && mboxValue.length() > 0) {
- boolean boolMboxValue = false;
- try {
- boolMboxValue = Boolean.parseBoolean(mboxValue);
- binding.setMbox(boolMboxValue);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- binding.setModule(reader.getAttributeValue(null, "module"));
- return binding;
- }
+ /**
+ * @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();
- /**
- * @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");
- //TODO: implement
- writer.writeEndElement();
- }
+ // Read the policies
+ policyProcessor.readPolicies(binding, reader);
+ binding.setNode(reader.getAttributeValue(null, "node"));
+ String mboxValue = reader.getAttributeValue(null, "mbox");
+ if (mboxValue != null && mboxValue.length() > 0) {
+ try {
+ boolean boolMboxValue = Boolean.parseBoolean(mboxValue);
+ binding.setMbox(boolMboxValue);
+ } catch (Exception e) {
+ }
+ }
+ String timeoutValue = reader.getAttributeValue(null, "timeout");
+ try {
+ long longTimeoutValue = Long.parseLong(timeoutValue);
+ binding.setTimeout(longTimeoutValue);
+ } catch (NumberFormatException e) {
+ }
+ binding.setModule(reader.getAttributeValue(null, "module"));
+ binding.setCookie(reader.getAttributeValue(null, "cookie"));
+ return binding;
+ }
- /**
- * @see org.apache.tuscany.sca.contribution.processor.ArtifactProcessor#getModelType()
- */
- public Class<ErlangBinding> getModelType() {
- return ErlangBinding.class;
- }
+ /**
+ * @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");
+ // TODO: implement writing binding element
+ writer.writeEndElement();
+ }
- /**
- * @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 {
- }
+ /**
+ * @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 {
+ }
}
|