package com.aurea.maven.plugins.sonic.sdm.container.impl;

 import com.aurea.maven.plugins.sonic.sdm.container.IESBContainer;

 import com.aurea.maven.plugins.sonic.sdo.AbstractDataObjectInstance;

 import commonj.sdo.DataObject;

 public class DefaultESBContainer extends AbstractDataObjectInstance implements IESBContainer {

   @Override

   protected String getNamespace() {

     return "http://www.sonicsw.com/sonicxq";

   }

   @Override

   protected String getXSDType() {

     return "XQ_CONTAINER";

   }

   @Override

   protected String getResourceLocation() {

     //TODO remove hard coded schema version number

     //return "ESB/schema/2013/xqContainer.xsd";

             //ATTENTION: XSD Changed in order to allow Instances Tailoring ...

                 //Copy the original xqContainer.xsd and change the integer schema definitions to String

                 //Needs to be checked with every iteration!

           return "schema/ChangedxqContainer2015.xsd";

   }

   /**

    * 

    */

   public DefaultESBContainer() {

   }

   /**

    * @param _busConnection _busConnection

    */

   public void setBusConnection(final String _busConnection) {

     DataObject dobj = getDataObject();

     dobj.set("busConnection_", _busConnection);

   }

   /**

    * @param _routingHttpConnection _routingHttpConnection

    */

   public void setRoutingHttpConnection(final String _routingHttpConnection) {

     DataObject dobj = getDataObject();

     dobj.set("routingHttpConnection_", _routingHttpConnection);

   }

   /**

    * @param _enablePayloadCapture _enablePayloadCapture

    */

   public void setEnablePayloadCapture(final String _enablePayloadCapture) {

     DataObject dobj = getDataObject();

     dobj.set("enablePayloadCapture_", new Boolean(_enablePayloadCapture));

   }

   /**

    * @param _useForLookingGlass _useForLookingGlass

    */

   public void setUseForLookingGlass(final String _useForLookingGlass) {

     DataObject dobj = getDataObject();

     dobj.set("useForLookingGlass_", new Boolean(_useForLookingGlass));

   }

   /**

    * @param _useIntraContainerMessaging _useIntraContainerMessaging

    */

   public void setUseIntraContainerMessaging(final String _useIntraContainerMessaging) {

     DataObject dobj = getDataObject();

     dobj.set("useIntraContainerMessaging_", new Boolean(_useIntraContainerMessaging));

   }

   /**

    * {@inheritDoc}

    */

   public void setName(final String _name) {

     DataObject dobj = getDataObject();

     dobj.set("name", _name);

   }

   /**

    * {@inheritDoc}

    */

   public String getName() {

     return getDataObject().getString("name");

   }

   /**

    * {@inheritDoc}

    */

   public void addServiceInstance(final String _serviceName, final String _listeners, final String _reference, final int _startupPrio, final int _concurrentCalls, boolean inLine) {

     DataObject dObj = getDataObject();

     if (dObj != null) {

       DataObject services = dObj.getDataObject("services");

       if (services == null) {

         services = dObj.createDataObject("services");

       }

       String svcName = (_reference != null ? _reference : _serviceName);

       DataObject instance = services.createDataObject("serviceApplication");

       instance.set("name", svcName);

       instance.set("Instances", _listeners);

       if(inLine){

               String process = (_reference != null ? "PROCESS" : "INSTANCE");

               instance.set("service_ref", process);

       }

       else{              

               instance.set("service_ref", svcName);

       }

       instance.set("startupPriorityLevel", java.math.BigInteger.valueOf(_startupPrio));

       instance.set("ConcurrentCalls", java.math.BigInteger.valueOf(_concurrentCalls));

       //instance.set("Process", Boolean.valueOf(process));

     }

   }

 }