In case you face any issues with file based MDS, you may configure adf-config.xml  with entries like below to resolve the issue.



        <metadata-namespaces>
          <namespace path="/soa/shared" metadata-store-usage="mstore-usage_1"/>
          <namespace path="/apps" metadata-store-usage="mstore-usage_2"/>
        </metadata-namespaces>
        <metadata-store-usages>
          <metadata-store-usage id="mstore-usage_1">
            <metadata-store class-name="oracle.mds.persistence.stores.file.FileMetadataStore">
              <property name="metadata-path"
                        value="${oracle.home}/integration"/>
              <property name="partition-name" value="seed"/>
            </metadata-store>
          </metadata-store-usage>
        <metadata-store-usage id="mstore-usage_2">
            <metadata-store class-name="oracle.mds.persistence.stores.file.FileMetadataStore">
              <property name="metadata-path"
                        value="${oracle.home}/integration"/>
              <property name="partition-name" value="seed"/>
            </metadata-store>
          </metadata-store-usage>
        </metadata-store-usages>

WLST Script to export all SOA composites in one go

1) List all composites

   Connect to WLST  and run following WLST command to list all composites.

   sca_listDeployedComposites(host, port, user, password)

2) Save the output of step 1) to a .txt file ( example : list_of_composites_soa_11g.txt )

3) Create .py file with following content ( file name : import_all_soa_composites_jar_files.py )

 and run wlst to export all SOA Composites : /u01/app/oracle/fmw/12.2/soa/common/bin/wlst.sh import_all_soa_composites_jar_files.py

[oracle@integration ~]$ more import_all_soa_composites_jar_files.py
from java.io import FileInputStream
from java.lang import *
from java.util import Date
from java.util import HashMap
from java.lang import Runtime
from java.util import Arrays
from java.lang import System

f = open("list_of_composites_soa_11g.txt", "r")
for composite in f:
    composite_name = composite.split('[')[0]
    rev_number_temp = composite.split('[')[1]
    rev_number = rev_number_temp.split(']')[0]
    connect('weblogic', 'welcome1', 'localhost:8001')
    soa_composite_name = composite_name+"_rev"+rev_number+".jar"
    print(soa_composite_name)
    print(rev_number)
    sca_exportComposite('http://localhost:8001', 'all', soa_composite_name, composite_name, rev_number, user='weblogic', password='welcome1')
[oracle@integration ~]$

Scripts to Compare baseline configurations among different environments

I have tried to write few scripts to capture the configurations of different environments , which may helpful to compare it later to find out any changes done ..

I have started with BPEL propeties , B2B Properties , SOA Administration configuration and general WLS server level configurations. you may add more based on your requirements.

I have copied my scripts below.

Script 1:

from java.io import FileInputStream
from java.lang import *
from java.util import Date
from java.util import HashMap
from java.lang import Runtime
from java.util import Arrays
from java.lang import System


#passWord=sys.argv[1]
env=sys.argv[1]

propInputStream = FileInputStream(env + ".properties")

configProps = Properties()
configProps.load(propInputStream)
hostName=configProps.get("domain.adminHost")
portNo=configProps.get("domain.adminPort")
adminUserName=configProps.get("domain.adminUserName")
adminURL="t3://" + hostName + ":" + portNo

connect(userConfigFile='/u01/weblogic/etc/admin_config.secure', userKeyFile='/u01/weblogic/etc/admin_key.secure', url='t3://AdminServerURL:7001')

#JTA Time-out , Completion Timeout, Maximum Resource Requests on a Server , Front-End hostname, Front-End port, LDAP, Enable Exalogic Optimizations, Enable Administration Port, Production Mode, Archive Configuration Count, Configuration Archive Enabled


#############################################################################
def JTAConfigurations():

try:
print 'Soa weblogic domain configurations:';
cd('/JTA/soa_domain');
print 'JTA Time-out', cmo.getTimeoutSeconds();
print 'Completion Timeout', cmo.getCompletionTimeoutSeconds();
print 'Maximum Resource Requests on a Server', cmo.getMaxResourceRequestsOnServer();
except:

       print 'Exception while setting B2B properties !';

#############################################################################

def GeneralConfigurations():

try:
print 'General configurations of weblogic ';
cd('/Clusters/soa_cluster')
print 'Front-End hostname : ', cmo.getFrontendHost()
       print 'Front-End port : ', cmo.getFrontendHTTPPort()
cd('/')
                print 'Archive Configuration Count :', cmo.getArchiveConfigurationCount();
print 'Enable Exalogic Optimizations :', cmo.getExalogicOptimizationsEnabled();
                print 'Enable Administration Port :', cmo.getAdministrationPortEnabled();
print 'Production Mode :', cmo.getProductionModeEnabled();

except:
print 'Exception while retriving GeneralConfigurations !';


###################################################################

def B2Bproperties():

    try:

        print 'Setting B2B properties...';

domainRuntime()
B2BConfigobj = ObjectName('oracle.as.soainfra.config:Location=wls_soa11,name=b2b,type=B2BConfig,Application=soa-infra')
print 'Common Properties for soa_server1'
B2Bproperties = mbs.getAttribute(B2BConfigobj,'Properties')
        for element in B2Bproperties:
                print element.get('name'),"=",element.get('value')
    except:

        print 'Exception while setting B2B properties !';

        dumpStack();


#################################################################

def soaSuiteConfigurations():

try:

domainRuntime()
SOAcommonPropertiesObj = ObjectName('oracle.as.soainfra.config:Location=wls_soa11,name=soa-infra,type=SoaInfraConfig,Application=soa-infra')
                SOAcommonproperties = mbs.getAttribute(SOAcommonPropertiesObj,'GlobalTxMaxRetry')
print 'Audit level',"=", mbs.getAttribute(SOAcommonPropertiesObj,'AuditLevel')
print 'ServerURL',"=", mbs.getAttribute(SOAcommonPropertiesObj,'ServerURL')
print 'OracleWebserviceChunkSize',"=", mbs.getAttribute(SOAcommonPropertiesObj,'OracleWebserviceChunkSize')
print 'OracleWebservicesDoNotChunk',"=", mbs.getAttribute(SOAcommonPropertiesObj,'OracleWebservicesDoNotChunk')
print 'HttpServerURL',"=",  mbs.getAttribute(SOAcommonPropertiesObj,'HttpServerURL')
print 'HttpsServerURL',"=", mbs.getAttribute(SOAcommonPropertiesObj,'HttpsServerURL')
print 'EdnJmsMode',"=", mbs.getAttribute(SOAcommonPropertiesObj,'EdnJmsMode')

except:
print 'Exception while retriving SOA COMMON Properties !';



#################################################################

def bpelConfiguration():
try:

domainRuntime()
bpelConfigurationObj = ObjectName('oracle.as.soainfra.config:Location=wls_soa11,name=bpel,type=BPELConfig,Application=soa-infra')
print 'Disable BPEL Monitors and Sensors',"=",  mbs.getAttribute(bpelConfigurationObj,'DisableSensors')
print 'Audit level',"=", mbs.getAttribute(bpelConfigurationObj,'AuditLevel')
print 'Dispatcher System Threads',"=", mbs.getAttribute(bpelConfigurationObj,'DispatcherSystemThreads')
print 'Dispatcher Invoke Threads',"=", mbs.getAttribute(bpelConfigurationObj,'DispatcherInvokeThreads')
print 'Dispatcher Engine Threads',"=", mbs.getAttribute(bpelConfigurationObj,'DispatcherEngineThreads')
print 'AsyncAuditBatchSize (Exalogic only)',"=", mbs.getAttribute(bpelConfigurationObj,'AsyncAuditBatchSize')
print 'AsyncAuditPersisterThreads',"=", mbs.getAttribute(bpelConfigurationObj,'AsyncAuditPersisterThreads')
print 'AsyncAuditQueueSize',"=", mbs.getAttribute(bpelConfigurationObj,'AsyncAuditQueueSize')
print 'AuditStorePolicy',"=", mbs.getAttribute(bpelConfigurationObj,'AuditStorePolicy')
print 'MaximumNumberOfInvokeMessagesInCache',"=", mbs.getAttribute(bpelConfigurationObj,'MaximumNumberOfInvokeMessagesInCache')
print 'RecurringMaxMessageRaiseSize',"=", mbs.getAttribute(bpelConfigurationObj,'RecurringMaxMessageRaiseSize')
print 'StartupMaxMessageRaiseSize',"=", mbs.getAttribute(bpelConfigurationObj,'StartupMaxMessageRaiseSize')
       RecoverConfigProperties = mbs.getAttribute(bpelConfigurationObj,'RecoveryConfig')
for element in RecoverConfigProperties:
print element.get('itemName')





except:
print 'Exception while retriving BPEL Properties !';


#################################################################

def SOA_weblogic_Servers_configurations():
try:
domainConfig()
managedServers=cmo.getServers()
for server in managedServers:
ServerName = server.getName();
        cd("/Servers/" + ServerName )
print 'Server Name : ', "=", ServerName;
print '  Complete Message Timeout',"=", cmo.getCompleteMessageTimeout();
print '  Maximum Message Size',"=", cmo.getMaxMessageSize();
print '  Idle Connection Timeout',"=", cmo.getIdleConnectionTimeout();
print '  MaxHTTPMessageSize',"=", cmo.getMaxHTTPMessageSize();
## print '  Weblogic Plug-In Enabled',"=", cmo.getWeblogicPluginEnabled();
print '  Maximum Open Sockets',"=", cmo.getMaxOpenSockCount();
print '  Stuck Thread Max Time',"=", cmo.getStuckThreadMaxTime();
print '  AcceptBacklog',"=", cmo.getAcceptBacklog();
print '  Login Timeout',"=", cmo.getLoginTimeoutMillis();
print '  MuxerClass',"=", cmo.getMuxerClass();





except:
print 'Exception while retriving soa weblogic configurations :';

###################################################################


print 'JTA Configuration:'
print '------------------'
JTAConfigurations()
print 'General Configurations:'
print '-----------------------'
GeneralConfigurations()
print 'B2Bproperties:'
print '--------------'
B2Bproperties()
print 'Soa Suite Configurations:'
print '-------------------------'
soaSuiteConfigurations()
print 'BPEL Configurations:'
print '--------------------'
bpelConfiguration()
print 'Weblogic Server configurations:'
print '------------------------------:'
SOA_weblogic_Servers_configurations()


Script 2: File all JMS details.

from java.io import FileInputStream
from java.lang import *
from java.util import Date
from java.util import HashMap
from java.lang import Runtime
from java.util import Arrays
from java.lang import System

env=sys.argv[1]

propInputStream = FileInputStream(env+".properties")

configProps = Properties()
configProps.load(propInputStream)
hostName=configProps.get("domain.adminHost")
portNo=configProps.get("domain.adminPort")
jdbcDatasources=configProps.get("jdbc.datasources")
listOfDatasources = jdbcDatasources.split(',')
listofposiaConnFactories = configProps.get("jms.posia.connection.factories")
POSIAJMSModule=configProps.get("jms.posia.module")
HL7Module=configProps.get("jms.hl7.module")
listOfConnectionFactory = listofposiaConnFactories.split(',')
adminUserName=configProps.get("domain.adminUserName")
adminURL="t3://" + hostName + ":" + portNo
connect(userConfigFile='/u01/weblogic/etc/admin_config.secure', userKeyFile='/u01/weblogic/etc/admin_key.secure', url='t3://AdminServerURL:7001')

cd('/')
for jmsConnFactory in listOfConnectionFactory:

print '--------------------------------------'
print "JMS Name : " + jmsConnFactory
print '--------------------------------------'
cd('/JMSSystemResources/' + MyJMSModule + '/JMSResource/' + MyJMSModule + '/ConnectionFactories/' + jmsConnFactory)
print " "
print "1) JNDI Name : " + cmo.getJNDIName()
print "  "
print "2) JMS Connection factory client params : "
cd('ClientParams/' + jmsConnFactory)
ls()
print "3) JMS Connection factory Transaction param : "
cd('../../TransactionParams/' + jmsConnFactory)
ls()

3) script 3 - Data source details. 

from java.io import FileInputStream

from java.lang import *

from java.util import Date

from java.util import HashMap

from java.lang import Runtime

from java.util import Arrays

from java.lang import System

env=sys.argv[1]

propInputStream = FileInputStream(env+".properties")

configProps = Properties()

configProps.load(propInputStream)

hostName=configProps.get("domain.adminHost")

portNo=configProps.get("domain.adminPort")

jdbcDatasources=configProps.get("jdbc.datasources")

listOfDatasources = jdbcDatasources.split(',')

adminUserName=configProps.get("domain.adminUserName")

adminURL="t3://" + hostName + ":" + portNo

connect(userConfigFile='/u01/weblogic/etc/admin_config.secure', userKeyFile='/u01/weblogic/etc/admin_key.secure', url='t3://AdminServerURL:7001')

cd('/')

for dsName in listOfDatasources:

print '--------------------------------------'

print "DataSource Name : " + dsName

print '--------------------------------------'

cd('/JDBCSystemResources/' + dsName + '/JDBCResource/' + dsName + '/JDBCConnectionPoolParams/' + dsName)

ls()

OSB Configurator for customization of the OSB resources

OSB Configurator for customization of the OSB resources

OSB Configurator is a great tool for customisation of the OSB resources . i will try to explain how to use OSB Configurator with example.


Step 1) Download OSB Configurator code from : https://github.com/tomecode/OSB-Config-WLST-Configurator

Step 2) Unzip the downloaded code , once you unzip it , you will be able to see following directories / files.

com                      
osbCustomizer.py        
pom.xml                
src
httpTransport.properties
osbCustomizer.sh        
README.md

Step 3) Open : osbCustomizer.sh file and set the Weblogic Home , OSB Home , Java Home .. The file looks like below.

#!/bin/bash


WL_HOME="/u01/fmw/product/111/wlserver_10.3"
OSB_HOME="/u01/fmw/product/111/osb_111"
export JAVA_HOME="/u01/fmw/jdk1.7.0_80"

export PATH=${JAVA_HOME}/bin:$PATH
export CLASSPATH=${WL_HOME}/server/lib/weblogic.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-kernel-common.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-kernel-resources.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-kernel-api.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-kernel-impl.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-kernel-wls.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-transports-main.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/sb-transports-http-wls.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/modules/*:$CLASSPATH
export CLASSPATH=${OSB_HOME}/modules/*:$CLASSPATH
export CLASSPATH=${OSB_HOME}/modules/features/*:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/transports/mq*.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/transports/ftp*.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/transports/file*.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/transports/sftp*.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/transports/email*.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib/transports/sb*.jar:$CLASSPATH
export CLASSPATH=${OSB_HOME}/lib*.jar:$CLASSPATH
export CLASSPATH=/sbcm1o/admin/scripts/OSB-Config-WLST-Configurator-master/com/tomecode/utils/Utils.class:$CLASSPATH
export CLASSPATH=./*.jar:$CLASSPATH

echo $CLASSPATH

java weblogic.WLST -i osbCustomizer.py $1

4) prepare a property file with the required changes .  In this example i am trying to change only ReadTimeout and ConnectionTimeout of particular Business Service . Properties file name : httpTransport.properties . file entries are below.

#OSB Configuration for deployment

SB_SERVER={

        "ListenAddress":"",

        "ListenPort":7001,

        "Username":"sgannavaram",

        "Password":"",

}

#Setting for customizer

#The list of settings, which will be customized in SBConfig (jar) before deploying to the OSB

SB_CUSTOMIZATOR={

    #SBConfig file location

        "sbconfig.jar":{

                #Customization type: Business Service with transport type: HTTP

                "HTTP":{

                        #Path to the file (BusinessService), which will be customized in SBConfig

                        "OSB_Services/BusinessServices/OSB_BS.BusinessService":{

                                "ReadTimeout":90,

                                "ConnectionTimeout":90

                        },

                },

                #...

        },

}

Step 5)  Place OSB.jar file to script location and run command : osbCustomizer.sh httpTransport.properties

this configurator modify the required changes and deploy the OSB.jar automatically.

For More information refer : 

https://github.com/tomecode/OSB-Config-WLST-Configurator/wiki/OSB-Config-WLST-Configurator

WLST Script to change the BPEL properties , EDN status , Audit level and create partitions..

WLST Script to change the BPEL properties , EDN status , Audit level and create partitions..

Step 1) Create a property file with AdminServer details . Let us say the property filename is : dev.properties.

admin.url=t3://AdminServerName:7001
admin.soaurl=t3://SOAServerName:8001
admin.username=Weblogic
admin.password=Weblogic1

Step 2) Create a WLST script with below entries . let us say , script name is :  fmwBPELMbean.py

import java.io.IOException;
import java.net.MalformedURLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import javax.management.Attribute;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.Query;
import javax.management.QueryExp;
import javax.management.openmbean.CompositeDataSupport;
import javax.management.openmbean.OpenDataException;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;

from java.io import FileInputStream
from java.util import Properties
from org.apache.log4j import *
import javax.management.openmbean.CompositeDataSupport;

if __name__ == '__main__':
    from wlstModule import *



def loginToAdmin(config):
        adminuser = config.get("admin.username")
   
   adminpwd = config.get("admin.password")
        adminurl = config.get("admin.soaurl")
        logger.info('Logging into SOA URL:"+adminurl')
        connect(adminuser,adminpwd,adminurl)

def partitionExists(part):
        foldermbean = sca_getFolderMBean();
        try:
                folders = mbs.getAttribute(foldermbean, "Folders")
                for folder in folders:
                        if folder.getName() == part:
                                return True
                return False
        except Exception, detail:
                print 'Exception:', detail

def createSOAPartition(config):
        loginToSOA(config)
        if not partitionExists('Partition1'):
                sca_createPartition ('Partition1')
        if not partitionExists('Partition2'):
                sca_createPartition ('Partition2')
        if not partitionExists('Partition3'):
                sca_createPartition ('Partition3')
        if not partitionExists('Partition4'):
                sca_createPartition ('Partition4')

        sca_listPartitions()

def changelog(config):
        #requires admin login
        loginToAdmin(config)
        domainRuntime()
        SOAInfraConfigobj = ObjectName('oracle.as.soainfra.config:Location=wls_soa1,name=soa-infra,type=SoaInfraConfig,Application=soa-infra')

        print 'Before: AuditLevel at SOAConfig (Global)~', mbs.getAttribute(SOAInfraConfigobj,'AuditLevel')

        mbs.setAttribute(SOAInfraConfigobj,Attribute("AuditLevel","Off"))
        print 'After : AuditLevel at SOAConfig (Global)~', mbs.getAttribute(SOAInfraConfigobj,'AuditLevel')


def changeEDN(config):
        custom()
        cd('oracle.as.soainfra.config/oracle.as.soainfra.config:name=edn,type=EDNConfig,Application=soa-infra')
        pausedval=get('Paused')
        logger.info('EDN Paused value = ' + str(pausedval))
        sca_disableEventsDelivery()
        logger.info('EDN Paused value = ' + str(pausedval))

def changeBPEL(config):
        logger.info('Processing BPEL')
        BPELConfigobj = ObjectName('oracle.as.soainfra.config:Location=wls_soa1,name=bpel,type=BPELConfig,Application=soa-infra')

        print 'Before: AuditLevel at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'AuditLevel')
        print 'Before: DisableSensors at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'DisableSensors')
        print 'Before: AuditStorePolicy at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'AuditStorePolicy')
        print 'Before: RecurringMaxMessageRaiseSize at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'RecurringMaxMessageRaiseSize')
        print 'Before: StartupMaxMessageRaiseSize at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'StartupMaxMessageRaiseSize')

        # instructions say None.  off appears to be valid, not None
        mbs.setAttribute(BPELConfigobj,Attribute('AuditLevel','off'))

        mbs.setAttribute(BPELConfigobj,Attribute('DisableSensors',1))
        mbs.setAttribute(BPELConfigobj,Attribute('AuditStorePolicy','async'))
        mbs.setAttribute(BPELConfigobj,Attribute('RecurringMaxMessageRaiseSize',0))
        mbs.setAttribute(BPELConfigobj,Attribute('StartupMaxMessageRaiseSize',0))

        print 'After : AuditLevel at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'AuditLevel')
        print 'After : DisableSensors at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'DisableSensors')
        print 'After : AuditStorePolicy at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'AuditStorePolicy')
        print 'After : RecurringMaxMessageRaiseSize at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'RecurringMaxMessageRaiseSize')
        print 'After : StartupmaxMessageRaiseSize at BPELConfig (Global)~', mbs.getAttribute(BPELConfigobj,'RecurringMaxMessageRaiseSize')

def changeBPELRecovery(config):
        logger.info('Processing BPEL')
        BPELConfigobj = ObjectName('oracle.as.soainfra.config:Location=wls_soa1,name=bpel,type=BPELConfig,Application=soa-infra')
        rec_config_obj  = mbs.getAttribute(BPELConfigobj, 'RecoveryConfig')
        rec_recurrr_obj = rec_config_obj.get('RecurringScheduleConfig')
        rec_startup_obj = rec_config_obj.get('StartupScheduleConfig')
        rec_cluster_obj = rec_config_obj.get('ClusterConfig')

        #Update configs
        new_startup_obj = setStartupConfig(rec_startup_obj,BPELConfigobj)
        new_recur_obj = setRecurringConfig(rec_recurrr_obj,BPELConfigobj)
        new_clust_obj = setClusterConfig(rec_cluster_obj,BPELConfigobj)

        #Create HashMap for Assignment
   
   pyMap = { "ClusterConfig":new_clust_obj, "RecurringScheduleConfig":new_recur_obj, "StartupScheduleConfig":new_startup_obj }
        javaMap = java.util.HashMap()
        for k in pyMap.keys():
                javaMap[k] = pyMap[k]

        new_rec_config_obj = CompositeDataSupport(rec_config_obj.getCompositeType(), javaMap)

        #javax.management.Attribute
        SOAattribute = Attribute('RecoveryConfig', new_rec_config_obj)

        mbs.setAttribute(BPELConfigobj, SOAattribute)

def setRecurringConfig(recur_obj,BPELMBeanobj):
        print ' in Recurring Config'
        cnt = 0
        keySet = recur_obj.getCompositeType().keySet()

        keys = keySet.toArray()
        keyitems = [ key for key in keys ]
        values = recur_obj.getAll(keyitems)
        for key in keys:
                print 'Processing key:',key

                if key == 'maxMessageRaiseSize':

                        print 'bpel current RecurringScheduleConfig:maxMessageRaiseSize ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = Integer(0)
                        print 'bpel set RecurringScheduleConfig:maxMessageRaiseSize ' + key + ' to value ' + str(values[cnt])
                if key == 'stopWindowTime':
                        print 'bpel set RecurringScheduleConfig:stopWindowTime ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = '00:00'
                        print 'bpel set RecurringScheduleConfig:stopWindowTime ' + key + ' to value ' + str(values[cnt])
                if key == 'startWindowTime':
                        print 'bpel set RecurringScheduleConfig:startWindowTime ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = '00:00'
                        print 'bpel set RecurringScheduleConfig:startWindowTime ' + key + ' to value ' + str(values[cnt])
                if key == 'subsequentTriggerDelay':
                        print 'bpel set RecurringScheduleConfig:subsequentTriggerDelay ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = Long(0)
                        print 'bpel set RecurringScheduleConfig:subsequentTriggerDelay ' + key + ' to value ' + str(values[cnt])
                if key == 'threshHoldTimeInMinutes':
                        print 'bpel set RecurringScheduleConfig:threshHoldTimeInMinutes ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = Integer(0)
                        print 'bpel set RecurringScheduleConfig:threshHoldTimeInMinutes ' + key + ' to value ' + str(values[cnt])
                cnt = cnt + 1
        new_obj = CompositeDataSupport(recur_obj.getCompositeType(), keyitems, values)
        return new_obj


def setClusterConfig(cluster_obj,BPELMBeanobj):
        print ' in ClusterConfig '
        cnt = 0
        keySet = cluster_obj.getCompositeType().keySet()
        keys = keySet.toArray()
        keyitems = [ key for key in keys ]
        values = cluster_obj.getAll(keyitems)
        for key in keys:
                print 'Processing key:',key
                cnt = cnt + 1
        new_obj = CompositeDataSupport(cluster_obj.getCompositeType(), keyitems, values)

      return new_obj


def setStartupConfig(startup_obj,BPELMBeanobj):
        print ' in Startup Config'
        cnt = 0
        keySet = startup_obj.getCompositeType().keySet()

        print 'keySet:',keySet
        keys = keySet.toArray()
        print 'keys:',keys
        keyitems = [ key for key in keys ]
        print 'keyitems:',keyitems
        values = startup_obj.getAll(keyitems)
        print 'keySet',keySet
        for key in keys:
                print key
                if key == 'maxMessageRaiseSize':
                        print 'bpel current StartupScheduleConfig:maxMessageRaiseSize ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = Integer(0)
                        print 'bpel set StartupScheduleConfig:maxMessageRaiseSize ' + key + ' to value ' + str(values[cnt])
                if key == 'startupRecoveryDuration':
                        print 'bpel set StartupScheduleConfig:startupRecoveryDuration ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = Long(0)
                        print 'bpel set StartupScheduleConfig:startupRecoveryDuration ' + key + ' to value ' + str(values[cnt])
                if key == 'subsequentTriggerDelay':
                        print 'bpel set StartupScheduleConfig:subsequentTriggerDelay ' + key + ' to value ' + str(values[cnt])
                        values [cnt] = Long(0)
                        print 'bpel set StartupScheduleConfig:subsequentTriggerDelay ' + key + ' to value ' + str(values[cnt])
                cnt = cnt + 1
        new_obj = CompositeDataSupport(startup_obj.getCompositeType(), keyitems, values)
        return new_obj





##################### Main line ##########################

env=sys.argv[1]
print "Config file:" + env
configfile = FileInputStream(env)

print "Loaded file : " + env
configProps = Properties()
configProps.load(configfile)

PropertyConfigurator.configure("log4j.properties")
logger = Logger.getLogger("SOASetup")


logger.info('Starting')
try:
        createconn(end,configProps)
        changelog(configProps)
        changeBPEL(configProps)
        changeBPELRecovery(configProps)
        changeEDN(configProps)
        createSOAPartition(configProps)

except Exception, e:
        print 'Exception---------------------------'
        print e
        cancelEdit('y')

logger.info('Ending')

3) Invoke WLST to change BEPL configurations : wlst.sh fmwBPELMbean.py  dev.properties

WLST script to create JMS Objects  ( JMS servers , Modules , FileStore ,Queue , Topic , Connection factories and so on )

1) Step : Create property file with list of JMS Servers , JMS Module,FileStore ,Queue , Topic , Connection factories needs to configure.  Let us say property file name : jmsObjects.properties.

#  JMS Objects - Properties
#
#
#############################################################
domain.name=soa_domain

wlst.log=soa_domain_jms.log
admin.url=t3://AdminServerURL:7001
admin.username=Weblogic
admin.password=Weblogic1

####################################################################
# PERSISTENT STORES PROPERTIES
####################################################################
persistentstores.list=JMSFileStorePOSIA_auto_1,JMSFileStorePOSIA_auto_2

JMSFileStorePOSIA_auto_1.directory=/u01/admin/soa_domain/soa_cluster/JMSFileStorePOSIA_auto_1
JMSFileStorePOSIA_auto_1.target=wls_soa1
JMSFileStorePOSIA_auto_1.targetType=Server

JMSFileStorePOSIA_auto_2.directory=/u01/admin/soa_domain/soa_cluster/JMSFileStorePOSIA_auto_2
JMSFileStorePOSIA_auto_2.target=wls_soa3
JMSFileStorePOSIA_auto_2.targetType=Server



###################################################################
#
#        JMS SERVERS PROPERTIES
##################################################################
jmsservers.list=JMSServer_auto_1,JMSServer_auto_2

JMSServer_auto_1.filestore=JMSFileStorePOSIA_auto_1
JMSServer_auto_1.target=wls_soa1
JMSServer_auto_1.targetType=Server

JMSServer_auto_2.filestore=JMSFileStorePOSIA_auto_2
JMSServer_auto_2.target=wls_soa3
JMSServer_auto_2.targetType=Server



##################################################################
##
##################################################################
##
##         JMS MODULES
##
#################################################################
jmsmodules.list=JMSModule

JMSModule.targets=soa_cluster:Cluster


JMSModule.subdeployments.list=SUB
JMSModule.SUB.target=JMSServer_auto_1,JMSServer_auto_2
JMSModule.SUB.targetType=JMSServer



JMSModule.connectionFactories.list=QueueConnectionFactory,ErrorConnectionFactory

JMSModule.QueueConnectionFactory.jndiName=jms/jms/QueueConnectionFactory
JMSModule.QueueConnectionFactory.clientID=
JMSModule.QueueConnectionFactory.clientIDPolicy=
JMSModule.QueueConnectionFactory.subscriptionSharingPolicy=
JMSModule.QueueConnectionFactory.messagesMaximun=
JMSModule.QueueConnectionFactory.xaEnabled=true
JMSModule.QueueConnectionFactory.transactionTimeout=
JMSModule.QueueConnectionFactory.serverAffinity=false


JMSModule.uniformDistributedQueues.list=IN_QUEUE_DLQ


Step 2) : create below .py script . let us say file name : JMSObjectsCreation.py

"""
This script starts an edit session, creates two different JMS Servers,
targets the jms servers to the server WLST is connected to and creates
jms topics, jms queues and jms templates in a JMS System module. The
jms queues and topics are targeted using sub-deployments.
"""

def startTransaction():
    edit()
    startEdit()

def endTransaction():
    save()
    activate(block="true")


############################################################################
#  Connect to the domain Administration Server
############################################################################
def connectToAdminServer(conUsername, conPassword, conURL):
    try:
        print 'Connecting to the Admin Server : %s with the user: %s' %(conURL, conUsername)
        connect(conUsername, conPassword, conURL)
        print 'Connected...'
    except:
        print 'Cannot connect to the administration server'
        exit()

def createFilePersistentStore(psname, psDirectoryValue, psTargetValue, psTargetType):
    try:
        print 'Creating Physical Directories on the shared'
        fileStoreDir = File(psDirectoryValue)
        bCreate = fileStoreDir.mkdirs()
        if bCreate == 0:
            if fileStoreDir.delete() == 1:
                bCreate = fileStoreDir.mkdirs()
            else:
                stopExecution("Cannot create a physical directory")
                exit()
        print 'Creating File Persistent Store'
        cmo = cd('/')
        print psname
        cmo.createFileStore(psname)
        psPath = '/FileStores/' + psname
        cmo = cd(psPath)
        cmo.setDirectory(psDirectoryValue)
        targets = createTargetsObj(psTargetValue, psTargetType)
        print targets

        set('Targets',jarray.array(targets, ObjectName))

        save()
        print ' Successful Create File Persistent Store %s' %(psname)

    except Exception, e:
        print 'Cannot Create the File Persistent Store %s' %(psname)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the File Persistent Store')
        exit()

def createJMSServer(jmsServerName, jmsFileStoreValue, jmsTargetValue,jmsTargetTypePropertyValue):
    try:
        print 'Creating JMS Server'
        cmo = cd('/')
        cmo.createJMSServer(jmsServerName)
        jmsPath = '/Deployments/' + jmsServerName
        cmo = cd(jmsPath)
        fsPath = '/FileStores/' + jmsFileStoreValue
        cmo.setPersistentStore(getMBean(fsPath))

        targets = createTargetsObj(jmsTargetValue, jmsTargetTypePropertyValue)

        set('Targets',jarray.array(targets, ObjectName))

        save()
        print ' Successful Create JMS Server %s' %(jmsServerName)

    except Exception, e:
        print 'Cannot Create the JMS Server %s' %(jmsServerName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the JMS Server')
        exit()

def createJMSModule(jmsModuleName,jmsModuleTargets):
    try:
        print 'Creating JMS Module'
        cmo = cd('/')
        cmo.createJMSSystemResource(jmsModuleName)
        modulePath = '/SystemResources/' + jmsModuleName
        cmo = cd(modulePath)
        print "jmsModuleTargets =  "+jmsModuleTargets
        targets = createTargetsObjList(jmsModuleTargets)
        set('Targets',jarray.array(targets, ObjectName))

        save()
        print ' Successful Create JMS Module %s' %(jmsModuleName)

    except Exception, e:
        print 'Cannot Create the JMS Module %s' %(jmsModuleName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the JMS Server')
        exit()


def createTargetsObj(targets, targetType):
    listOfTargets = []
    targetList = targets.split(',')
    for target in targetList:
        targetObj = 'com.bea:Name='+ target + ',Type=' + targetType
        print targetObj
        listOfTargets.append(ObjectName(str(targetObj)))

    return listOfTargets

def createTargetsObjList(listOfTargetsStr):
    listOfTargets = []
    targetList = listOfTargetsStr.split(',')
    for targetStr in targetList:
        target = targetStr.split(":")
        targetObj = 'com.bea:Name='+ target[0] + ',Type=' + target[1]
        print targetObj
        listOfTargets.append(ObjectName(str(targetObj)))

    return listOfTargets

def getJMSModulePath(jmsModuleName):
        jmsModulePath = "/JMSSystemResources/"+jmsModuleName+"/JMSResource/"+jmsModuleName
        return jmsModulePath

def createSubDeployment(jmsModuleName, jmsSubDeployName, jmsTargetVal, jmsTargetTypeVal):
    try:
        print 'Creating SubDeployment...' + jmsSubDeployName + ' for Module ...' + jmsModuleName
        cmo = cd('/')
        cmo = cd('/SystemResources/'+jmsModuleName)
        cmo.createSubDeployment(jmsSubDeployName)
        cmo = cd('/SystemResources/'+jmsModuleName+'/SubDeployments/'+subDeployName)
        targets = createTargetsObj(jmsTargetVal, jmsTargetTypeVal)
        set('Targets',jarray.array(targets, ObjectName))

        save()
        print ' Successful Create SubDeployment %s' %(jmsSubDeployName)

    except Exception, e:
        print 'Cannot Create the SubDeployment name %s' %(jmsSubDeployName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the JMS Module')
        exit()

def createJMSConnectionFactory(jmsModuleName, cfName, configProps):
    try:
        jmsModulePath = getJMSModulePath(jmsModuleName)
        cmo = cd(jmsModulePath)
        cf = create(cfName,'ConnectionFactory')
        cfPath =jmsModulePath + '/ConnectionFactories/' + cfName
        cmo = cd(cfPath)
        value = configProps.get(jmsModuleName + '.' + cfName + '.jndiName')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setJNDIName(value)

        value = configProps.get(jmsModuleName + '.' + cfName + '.subdeploymentName')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setSubDeploymentName(value)
            cmo.setDefaultTargetingEnabled(false)
        else:
            cmo.setDefaultTargetingEnabled(true)

        cmo = cd(cfPath + '/ClientParams/' + cfName)

        value = configProps.get(jmsModuleName + '.' + cfName + '.clientID')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setClientId(value)

        value = configProps.get(jmsModuleName + '.' + cfName + '.clientIDPolicy')
        if (value != None and value != ''):
            if (value == 'Restricted' or value == 'Unrestricted'):
                cmo.setClientIdPolicy(value)

        value = configProps.get(jmsModuleName + '.' + cfName + '.subscriptionSharingPolicy')
        if (value != None and value != ''):
            if (value == 'Exclusive' or value == 'Sharable'):
                cmo.setSubscriptionSharingPolicy(value)

        value = configProps.get(jmsModuleName + '.' + cfName + '.messagesMaximun')
        if (value != None and value != ''):
            cmo.setMessagesMaximum(value)

        cmo = cd(cfPath+'/TransactionParams/'+ cfName)

        value = configProps.get(jmsModuleName + '.' + cfName + '.xaEnabled')
        if (value == 'true'):
            cmo.setXAConnectionFactoryEnabled(true)
        if (value == 'false'):
            cmo.setXAConnectionFactoryEnabled(false)

        value = configProps.get(jmsModuleName + '.' + cfName + '.transactionTimeout')
        if (value != None and value != ''):
            cmo.setTransactionTimeout(Long(value))

        cmo = cd(cfPath+'/LoadBalancingParams/'+ cfName)

        value = configProps.get(jmsModuleName + '.' + cfName + '.serverAffinity')
        if (value != None and value != ''):
            if (value == 'true'):
                cmo.setServerAffinityEnabled(true)
            if (value == 'false'):
                cmo.setServerAffinityEnabled(false)

        save()
        print ' Successful Create Connection Factory %s' %(cfName)

    except Exception, e:
        print 'Cannot Create the Connection Factory name %s' %(cfName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the Connection Factory')
        exit()


def createJMSDistributedQueueUDD(jmsModuleName, distrQName, configProps):
    try:
        jmsModulePath = getJMSModulePath(jmsModuleName)
        cmo = cd(jmsModulePath)
        cmo.createUniformDistributedQueue(distrQName)
        distrQPath = jmsModulePath + '/UniformDistributedQueues/' + distrQName
        cmo = cd(distrQPath)
        value = configProps.get(jmsModuleName + '.' + distrQName + '.jndiName')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setJNDIName(value)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.subdeploymentName')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setSubDeploymentName(value)

        cmo = cd(distrQPath + '/DeliveryFailureParams/' + distrQName)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.errorDestination')
        if (value != None and value != ''):
            value = String(value).trim()
            errorQPath = '/JMSSystemResources/' + jmsModuleName + '/JMSResource/' + jmsModuleName + '/UniformDistributedQueues/' + value
            cmo.setErrorDestination(getMBean(errorQPath))

        value = configProps.get(jmsModuleName + '.' + distrQName + '.expirationLoggingPolicy')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setExpirationLoggingPolicy(value)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.expirationPolicy')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setExpirationPolicy(value)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.redeliveryLimit')
        if (value != None and value != ''):
            cmo.setRedeliveryLimit(Integer(value))

        cmo = cd(distrQPath + '/DeliveryParamsOverrides/' + distrQName)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.deliveryMode')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setDeliveryMode(value)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.redeliveryDelay')
        if (value != None and value != ''):
            cmo.setRedeliveryDelay(Long(value))

        value = configProps.get(jmsModuleName + '.' + distrQName + '.timeToDeliver')
        if (value != None and value != ''):
            cmo.setTimeToDeliver(value)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.timeToLive')
        if (value != None and value != ''):
            cmo.setTimeToLive(Long(value))

        cd(distrQPath + '/MessageLoggingParams/' + distrQName)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.messageLoggingEnabled')
        if (value == 'true'):
            cmo.setMessageLoggingEnabled(true)
        if (value == 'false'):
            cmo.setMessageLoggingEnabled(false)

        value = configProps.get(jmsModuleName + '.' + distrQName + '.messageLoggingFormat')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setMessageLoggingFormat(value)

        save()

    except Exception, e:
        print 'Cannot Create the UUD Queue name %s' %(distrQName)
        print e

def createJMSDistributedTopicUDD(jmsModuleName, distrTopicName, configProps):
    try:
        jmsModulePath = getJMSModulePath(jmsModuleName)
        cmo = cd(jmsModulePath)
        cmo.createUniformDistributedTopic(distrTopicName)
        distrTPath = jmsModulePath + '/UniformDistributedTopics/' + distrTopicName
        cmo = cd(distrTPath)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.jndiName')
        cmo.setJNDIName(value)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.forwardingPolicy')
        if (value == 'Replicated' or value == 'Partitioned'):
            cmo.setForwardingPolicy(value)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.subdeploymentName')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setSubDeploymentName(value)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.jmscreatedestinationidentifier')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setJMSCreateDestinationIdentifier(value)

        cmo = cd(distrTPath + '/DeliveryFailureParams/' + distrTopicName)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.errorDestination')
        if (value != None and value != ''):
            value = String(value).trim()
            errorTPath = '/JMSSystemResources/' + jmsModuleName + '/JMSResource/' + jmsModuleName + '/UniformDistributedTopics/' + value
            cmo.setErrorDestination(getMBean(errorTPath))

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.expirationPolicy')
        if (value == 'None' or value == 'Log' or value == 'Redirect' or value == 'Discard'):
            cmo.setExpirationPolicy(value)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.redeliveryLimit')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setRedeliveryLimit(Integer(value))

        cmo = cd(distrTPath + '/DeliveryParamsOverrides/' + distrTopicName)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.deliveryMode')
        if (value == 'Persistent' or value == 'Non-Persistent' or value == 'No-Delivery'):
            cmo.setDeliveryMode(value)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.redeliveryDelay')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setRedeliveryDelay(Long(value))

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.timeToDeliver')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setTimeToDeliver(value)

        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.timeToLive')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setTimeToLive(Long(value))


        cmo = cd(distrTPath + '/MessageLoggingParams/' + distrTopicName)
        value = configProps.get(jmsModuleName + '.' + distrTopicName + '.messageLoggingEnabled')
        if (value == 'false'):
            cmo.setMessageLoggingEnabled(false)

        if (value == 'true'):
            cmo.setMessageLoggingEnabled(true)
            format = configProps.get(jmsModuleName + '.' + distrTopicName + '.messageLoggingFormat')
            if (format != None and format != ''):
                format = String(format).trim()
                cmo.setMessageLoggingFormat(format)

        save()

    except Exception, e:
        print 'Cannot Create the Distributed Topic Name %s' %(distrTopicName)
        print e


def createJMSTemplates(jmsModuleName, template, configProps):
    try:
        jmsModulePath = getJMSModulePath(jmsModuleName)
        cmo = cd(jmsModulePath)
        cmo.createTemplate(template)
        templatePath = jmsModulePath + '/Templates/' + template
        cmo = cd(templatePath)

        cmo = cd(templatePath + '/DeliveryFailureParams/' + template)

        value = configProps.get(jmsModuleName + '.' + template + '.expirationPolicy')
        if (value == 'None' or value == 'Log' or value == 'Redirect' or value == 'Discard'):
            cmo.setExpirationPolicy(value)

        value = configProps.get(jmsModuleName + '.' + template + '.redeliveryLimit')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setRedeliveryLimit(Integer(value))

        cmo = cd(templatePath + '/DeliveryParamsOverrides/' + template)

        value = configProps.get(jmsModuleName + '.' + template + '.deliveryMode')
        if (value == 'Persistent' or value == 'Non-Persistent' or value == 'No-Delivery'):
            cmo.setDeliveryMode(value)

        value = configProps.get(jmsModuleName + '.' + template + '.redeliveryDelay')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setRedeliveryDelay(Long(value))

        value = configProps.get(jmsModuleName + '.' + template + '.timeToDeliver')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setTimeToDeliver(value)

        value = configProps.get(jmsModuleName + '.' + template + '.timeToLive')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setTimeToLive(value)


        cmo = cd(templatePath + '/MessageLoggingParams/' + template)
        value = configProps.get(jmsModuleName + '.' + template + '.messageLoggingEnabled')
        if (value == 'false'):
            cmo.setMessageLoggingEnabled(false)

        if (value == 'true'):
            cmo.setMessageLoggingEnabled(true)
            format = configProps.get(jmsModuleName + '.' + template + '.messageLoggingFormat')
            if (format != None and format != ''):
                format = String(format).trim()
                cmo.setMessageLoggingFormat(format)

        save()

    except Exception, e:
        print 'Cannot Create the template Name %s' %(template)
        print e



def createJMSQuotas(jmsModuleName, quota, configProps):
    try:
        jmsModulePath = getJMSModulePath(jmsModuleName)
        cmo = cd(jmsModulePath)
        cmo.createQuota(quota)
        quotaPath = jmsModulePath + '/Quotas/' + quota
        cmo = cd(quotaPath)

        value = configProps.get(jmsModuleName + '.' + quota + '.bytesMaximum')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setBytesMaximum(Long(value))

        value = configProps.get(jmsModuleName + '.' + quota + '.messagesMaximum')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setMessagesMaximum(Long(value))

        value = configProps.get(jmsModuleName + '.' + quota + '.policy')
        if (value != None and value != ''):
            value = String(value).trim()
            cmo.setPolicy(value)

        value = configProps.get(jmsModuleName + '.' + quota + '.shared')
        if (value == 'false'):
            cmo.setShared(false)
        if (value == 'true'):
            cmo.setShared(true)

        save()

    except Exception, e:
        print 'Cannot Create the Quota Name %s' %(quota)
        print e



def UpdateJMSServer(jmsServerName, configProps):
    try:
        print 'Updating JMS Server %s' %(jmsServerName)
        jmsPath = '/Deployments/' + jmsServerName
        cmo = cd(jmsPath)

        value = configProps.get(jmsServerName + '.hostingTemporaryDestinations')
        if (value != None and value != ''):
            value = String(value).trim()
            if (value == 'true'):
                cmo.setHostingTemporaryDestinations(true)
                value1 = configProps.get(jmsServerName + '.temporaryTemplateResource')
                if (value1 != None and value1 != ''):
                    value1 = String(value1).trim()
                    cmo.setTemporaryTemplateResource(value1)

                value1 = configProps.get(jmsServerName + '.temporaryTemplateName')
                if (value1 != None and value1 != ''):
                    value1 = String(value1).trim()
                    cmo.setTemporaryTemplateName(value1)
                #end if
            #end if
        #end if

        save()
        print ' Successful Update JMS Server %s' %(jmsServerName)

    except Exception, e:
        print 'Cannot Update the JMS Server %s' %(jmsServerName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Update the JMS Server')
        exit()

def createForeignJNDIProvider(foreignJNDIProviderName,listOfTargetsStr,initialContextFactory,providerURL,user,password):
    try:
        print 'Creating ForeignJNDIProvider'
        cmo = cd('/')
        foreignJNDIInstance=create(foreignJNDIProviderName,"ForeignJNDIProvider")
        foreignJNDIInstance.setInitialContextFactory(initialContextFactory)
        foreignJNDIInstance.setProviderURL(providerURL)
        foreignJNDIInstance.setUser(user)
        foreignJNDIInstance.setPassword(password)

        targetList = listOfTargetsStr.split(',')
        for targetStr in targetList:
                target = targetStr.split(":")
                targetObj = 'com.bea:Name='+ target[0] + ',Type=' + target[1]
                if (target[1]=="Server"):
                        targetMB=getMBean("/Servers/"+target[0])
                if (target[1]=="Cluster"):
                        targetMB=getMBean("/Clusters/"+target[0])
                if targetMB is None:
                        print "@@@ Invalid Foreign JNDI Provider Target '"+target[0]+"'"
                        exit()
                foreignJNDIInstance.addTarget(targetMB)

        save()

    except Exception, e:
        print 'Cannot Create the Foreign JNDI Provider name %s' %(foreignJNDIProviderName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the Foreign JNDI Provider')
        exit()

def createForeignJNDIProviderLink(foreignJNDIProviderName,linkName,localJNDI,remoteJNDI):
    try:
        print 'Creating ForeignJNDIProvider link'
        foreignJNDIInstance = getMBean("/ForeignJNDIProviders/"+foreignJNDIProviderName)
        foreignLinkInstance=foreignJNDIInstance.createForeignJNDILink(linkName)
        foreignLinkInstance.setLocalJNDIName(localJNDI)
        foreignLinkInstance.setRemoteJNDIName(remoteJNDI)
        save()

    except Exception, e:
        print 'Cannot Create the Foreign JNDI Provider name %s' %(foreignJNDIProviderName)
        print e
        cancelEdit('y')
        stopExecution('Cannot Create the Foreign JNDI Provider')
        exit()

####################################################################################################
#
#     Main Module
#
####################################################################################################

from java.io import FileInputStream
from wlstModule import *

print 'Starting...'

propertiesFile = sys.argv[1]
if (propertiesFile == None or len(propertiesFile) == 0):
    print 'Usage wlst.sh configureJMSObjects.py JMSPLIS.properties'
    exit()

try:
    propInputStream = FileInputStream(propertiesFile)
    configProps = Properties()
    configProps.load(propInputStream)
    wlstLogFile = configProps.get("wlst.log")
    redirect(wlstLogFile)

    domainName=configProps.get("domain.name")
    adminURL=configProps.get("admin.url")
    adminUserName=configProps.get("admin.username")
    adminPassword=configProps.get("admin.password")
except Exception, e:
    print 'Missing properties in properties file or cannot read properties file'
    print e
    exit()

#    Connect to the Administration Server

print 'Connecting to the Administration server ...'
connectToAdminServer(adminUserName, adminPassword, adminURL)

print 'Starting Edit the domain ' + domainName

#### Starting an edit session

startTransaction()

### Creating file stores
filestores=configProps.get("persistentstores.list")
if (filestores != None and (len(String(filestores).trim()) > 0)):

    print 'Creating Persistent Stores:  %s' %(filestores)

    listofPS = filestores.split(',')
    for psname in listofPS:
        print psname
        psDirectoryProperty = psname + '.directory'
        psDirectoryValue = configProps.get(psDirectoryProperty)
        print psDirectoryValue
        psTargetProperty = psname + '.target'
        psTargetValue = configProps.get(psTargetProperty)
        print psTargetValue
        psTargetTypeProperty = psname + '.targetType'
        psTargetTypeValue = configProps.get(psTargetTypeProperty)
        print psTargetTypeValue

        createFilePersistentStore(psname, psDirectoryValue, psTargetValue, psTargetTypeValue)

# Create JMS Servers
jmsservers=configProps.get("jmsservers.list")
if (jmsservers != None and (len(String(jmsservers).trim()) > 0)):
    print 'Creating JMS Servers:  %s' %(jmsservers)

    listofJMSServers = jmsservers.split(',')
    for jmsServerName in listofJMSServers:
        print jmsServerName
        jmsFileStoreProperty = jmsServerName + '.filestore'
        jmsFileStoreValue = configProps.get(jmsFileStoreProperty)
        print jmsFileStoreValue
        jmsTargetProperty = jmsServerName + '.target'
        jmsTargetValue = configProps.get(jmsTargetProperty)
        print jmsTargetValue
        jmsTargetTypeProperty = jmsServerName + '.targetType'
        jmsTargetTypeValue = configProps.get(jmsTargetTypeProperty)
        print jmsTargetTypeValue

        createJMSServer(jmsServerName, jmsFileStoreValue, jmsTargetValue, jmsTargetTypeValue)

#### Activating the creation of JMS Servers before creating the modules
endTransaction()

startTransaction()

#Create JMS Modules
jmsmodules = configProps.get("jmsmodules.list")
if (jmsmodules != None and (len(String(jmsmodules).trim()) > 0)):
    print 'Creating JMS Modules: %s' %(jmsmodules)
    listofJMSModules = jmsmodules.split(',')
    for jmsModuleName in listofJMSModules:
        print jmsModuleName
        jmsTargetsProp = jmsModuleName + '.targets'
        jmsTargetsPropValue = configProps.get(jmsTargetsProp)
        print jmsTargetsPropValue

        createJMSModule(jmsModuleName,jmsTargetsPropValue)

        ####Create Sub deployment

        subDeploys = configProps.get(jmsModuleName + '.subdeployments.list')
        if (subDeploys != None and (len(String(subDeploys).trim()) > 0)):
            print 'Creating Sub Deployments: %s' %(subDeploys)

          listOfSubDeploys = subDeploys.split(',')
            for subDeployName in listOfSubDeploys:
                print subDeployName
                jmsTargetProperty = jmsModuleName + '.' + subDeployName + '.target'
                jmsTargetTypeProperty = jmsModuleName + '.' + subDeployName + '.targetType'
                jmsTargetVal = configProps.get(jmsTargetProperty)
                jmsTargetTypeVal = configProps.get(jmsTargetTypeProperty)
                createSubDeployment(jmsModuleName, subDeployName, jmsTargetVal, jmsTargetTypeVal)
            #end for
        #end if
        #Create JMS Module Objects - ConnectionFactories
        connFactories = configProps.get(jmsModuleName + '.connectionFactories.list')
        if (connFactories != None and (len(String(connFactories).trim()) > 0)):
            print 'Creating Connection Factories %s for Module: %s' %(connFactories, jmsModuleName)
            listofCfName = connFactories.split(',')
            for cfName in listofCfName:
                print cfName
                createJMSConnectionFactory(jmsModuleName, cfName, configProps)
            # end for connectionFactories
        #end if

        ## Create JMS Templates
        templates = configProps.get(jmsModuleName + '.templates.list')
        if (templates != None and (len(String(templates).trim()) > 0)):
            print 'Creating Templates %s for Module: %s' %(templates, jmsModuleName)
            listofTemplates = templates.split(',')
            for template in listofTemplates:
                print template
                createJMSTemplates(jmsModuleName, template, configProps)
            #end for
        #end if

        ## Create JMS Quotqs
        quotas= configProps.get(jmsModuleName + '.quotas.list')
        if (quotas != None and (len(String(quotas).trim()) > 0)):
            print 'Creating Quotas %s for Module: %s' %(quotas, jmsModuleName)
            listofQuotas = quotas.split(',')
            for quota in listofQuotas:

                print quota

                createJMSQuotas(jmsModuleName, quota, configProps)
            #end for
        #end if

        ## Create JMS Module Objects - Distributed Queue
        distrQueues = configProps.get(jmsModuleName + '.uniformDistributedQueues.list')
        if (distrQueues != None and (len(String(distrQueues).trim()) > 0)):
            print 'Creating Distributed Queues UDD %s for Module: %s' %(distrQueues, jmsModuleName)
            listofDistrQName = distrQueues.split(',')
            for distrQName in listofDistrQName:
                print distrQName
                createJMSDistributedQueueUDD(jmsModuleName, distrQName, configProps)
            #end for
        #end if

        ## Create JMS Module Objects - Distributed Topics
        distrTopics = configProps.get(jmsModuleName + '.uniformDistributedTopics.list')
        if (distrTopics != None and (len(String(distrTopics).trim()) > 0)):
            print 'Creating Distributed Topics UDD %s for Module: %s' %(distrTopics, jmsModuleName)
            listofDistrTName = distrTopics.split(',')
            for distrTName in listofDistrTName:
                print distrTName
                createJMSDistributedTopicUDD(jmsModuleName, distrTName, configProps)
            #end for
        #end if

    #end for
#end if
endTransaction()

startTransaction()
###### Update JMS Servers
jmsservers=configProps.get("update.jmsservers.list")
if (jmsservers != None and (len(String(jmsservers).trim()) > 0)):
    print 'Updating JMS Servers:  %s' %(jmsservers)

    listofJMSServers = jmsservers.split(',')
    for jmsServerName in listofJMSServers:

 print jmsServerName
        UpdateJMSServer(jmsServerName, configProps)


endTransaction()

startTransaction()

#Create Foreign JNDI Providers
foreignJNDIProviders = configProps.get("foreignJNDIProviders.list")
if (foreignJNDIProviders != None and (len(String(foreignJNDIProviders).trim()) > 0)):
    print 'Creating Foreign JNDI Providers: %s' %(foreignJNDIProviders)
    listofForeignJNDIProviders = foreignJNDIProviders.split(',')
    for foreignJNDIProviderName in listofForeignJNDIProviders:
        print foreignJNDIProviderName
        providerTargetsProp = foreignJNDIProviderName + '.targets'
        listOfTargetsStr = configProps.get(providerTargetsProp)
        print listOfTargetsStr
        providerInitialContextFactoryProp = foreignJNDIProviderName + '.initialContextFactory'
        providerInitialContextFactoryPropValue = configProps.get(providerInitialContextFactoryProp)
        print providerInitialContextFactoryPropValue
        providerURLProp = foreignJNDIProviderName + '.providerURL'
        providerURLPropValue = configProps.get(providerURLProp)
        print providerURLPropValue
        providerUserProp = foreignJNDIProviderName + '.user'
        providerUserPropValue = configProps.get(providerUserProp)
        print providerUserPropValue
        providerPasswordProp = foreignJNDIProviderName + '.password'
        providerPasswordPropValue = configProps.get(providerPasswordProp)
        print providerPasswordPropValue

        createForeignJNDIProvider(foreignJNDIProviderName,listOfTargetsStr,providerInitialContextFactoryPropValue,providerURLPropValue,providerUserPropValue,providerPas
swordPropValue)

        ####Create Foreign JNDI Provider Links
        jndiLinks = configProps.get(foreignJNDIProviderName + '.jndi.list')
        if (jndiLinks != None and (len(String(jndiLinks).trim()) > 0)):
            print 'Creating Foreign JNDI Provider Links: %s' %(jndiLinks)
            listOfLinks = jndiLinks.split(',')
            for jndiLinkName in listOfLinks:
                print jndiLinkName
                localJNDIProp = foreignJNDIProviderName + '.jndi.' + jndiLinkName + '.localJNDI'
                localJNDIValue = configProps.get(localJNDIProp)
                remoteJNDIProp = foreignJNDIProviderName + '.jndi.' + jndiLinkName + '.remoteJNDI'
                remoteJNDIValue = configProps.get(remoteJNDIProp)
                createForeignJNDIProviderLink(foreignJNDIProviderName,jndiLinkName,localJNDIValue,remoteJNDIValue)
            #end for
        #end if
    #end for
#end if
endTransaction()

exit()

Step 3) Invoke WLST and run .py script : wlst.sh JMSObjectsCreation.py    jmsObjects.properties

WLST script for Database adaptor configurations

Step 1) create a property file with Admin Server details , and Number of connections to configure in database adaptor and those configuration details. in this example , i am taking only one DB adaptor configuration. let us say our property file name : dev.properties

domain.name=soa_domain
domain.adminHost=AdminServerHostname
domain.adminPort=7001
domain.adminUserName=Weblogic
domain.soahome=/u01/fmw/product/111/soa_111


###########################DB Configuration#########################################
########## make 'xa' value true if data source is XA################################

deploymentPlan.db.location=/u01/shared/posia/soa/connectors/DBAdapterPlan.xml
totalDbToConfigure=1
############################DB CCBSOA Config properties#################################
db.resource.dbJNDIName1=eis/DB/SOA_INFRA
db.resource.dataSourceName1=jdbc/SOA/SOA_INFRA
db.resource.platformClassName1=
db.resource.xa1=true
db.resource.sequencePreallocationSize1=1
############################################################################################

Step 2 ) Script for DB Adaptor configurations. Let us say file name is : DBAdaptorConfig.py

from java.io import FileInputStream

env=sys.argv[1]

propInputStream = FileInputStream( env+".properties")

configProps = Properties()

configProps.load(propInputStream)

totdbToConfigure=configProps.get('totalDbToConfigure')

domainName=configProps.get("domain.name")

hostName=configProps.get("domain.adminHost")

portNo=configProps.get("domain.adminPort")

adminUserName=configProps.get("domain.adminUserName")

planPathDB=configProps.get("deploymentPlan.db.location")

adminURL="t3://" + hostName + ":" + portNo

soahome=configProps.get('domain.soahome')

appPathDB=soahome+'/soa/connectors/DbAdapter.rar'

appNameDB='DbAdapter'

moduleOverrideNamedb=appNameDB+'.rar'

moduleDescriptorName='META-INF/weblogic-ra.xml'

def delDeploymentPlanVariable(wlstPlan, name, value, xpath,overrideName, origin='planbased'):

    print 'inside delDeploymentPlanVariable'

    wlstPlan.destroyVariable(name)

    wlstPlan.destroyVariableAssignment(name, overrideName, moduleDescriptorName)

def makeDeploymentPlanVariable(wlstPlan, name, value, xpath,overrideName, origin='planbased'):

    print 'inside makeDeploymentPlanVariable'

    wlstPlan.destroyVariable(name)

    wlstPlan.destroyVariableAssignment(name, overrideName, moduleDescriptorName)

    variableAssignment = wlstPlan.createVariableAssignment(name, overrideName, moduleDescriptorName)

    variableAssignment.setXpath(xpath)

    variableAssignment.setOrigin(origin)

    wlstPlan.createVariable(name, value)

    print 'moduleDescriptorName=',moduleDescriptorName

i = 1

print 'no of adapter to configure...' +totdbToConfigure

print 'connecting to weblogic domain...' + domainName

print 'configuring adapter ....' + appPathDB

connect()

edit()

startEdit()

try:

        myPlandb=loadApplication(appPathDB, planPathDB)

        while (i <= int(totdbToConfigure)):

            print 'inside while'

            try:

                    dbJndi =  configProps.get("db.resource.dbJNDIName"+str(i))

                    dbDS=configProps.get('db.resource.dataSourceName'+str(i))

                    dbPlatform=configProps.get('db.resource.platformClassName'+str(i))

                    xaDS= configProps.get('db.resource.xa'+str(i))

                    sequencePreallocationSize=configProps.get('db.resource.sequencePreallocationSize'+str(i))

                    print 'dbjndi............', dbJndi

                    makeDeploymentPlanVariable(myPlandb, "ConnectionInstance_"+dbJndi, dbJndi, '/weblogic-connector/outbound-resource-adapter/connection-definition-grou

p/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/jndi-name',moduleOverrideNamedb)

                    if String(xaDS).indexOf('false') == -1:

                        delDeploymentPlanVariable(myPlandb, "ConfigProperty_dataSourceName_Value_"+dbJndi, dbDS, '/weblogic-connector/outbound-resource-adapter/connecti

on-definition-group/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/connection-properties/properties/

property/[name="dataSourceName"]/value',moduleOverrideNamedb)

                        makeDeploymentPlanVariable(myPlandb, "ConfigProperty_dataSourceName_Value_"+dbJndi, dbDS, '/weblogic-connector/outbound-resource-adapter/connect

ion-definition-group/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/connection-properties/properties

/property/[name="xaDataSourceName"]/value',moduleOverrideNamedb)

                    else:

                        print 'Not a XA'

                        delDeploymentPlanVariable(myPlandb, "ConfigProperty_dataSourceName_Value_"+dbJndi, dbDS, '/weblogic-connector/outbound-resource-adapter/connecti

on-definition-group/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/connection-properties/properties/

property/[name="xaDataSourceName"]/value',moduleOverrideNamedb)

                        makeDeploymentPlanVariable(myPlandb, "ConfigProperty_dataSourceName_Value_"+dbJndi, dbDS, '/weblogic-connector/outbound-resource-adapter/connect

ion-definition-group/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/connection-properties/properties

/property/[name="dataSourceName"]/value',moduleOverrideNamedb)

                    if len(dbPlatform)!=0:

                        makeDeploymentPlanVariable(myPlandb, "ConfigProperty_platformClassName_Value_"+dbJndi, dbPlatform, '/weblogic-connector/outbound-resource-adapte

r/connection-definition-group/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/connection-properties/p

roperties/property/[name="platformClassName"]/value',moduleOverrideNamedb)

                    if len(sequencePreallocationSize)!=0:

                        makeDeploymentPlanVariable(myPlandb, "ConfigProperty_platformClassName_Value_"+dbJndi, sequencePreallocationSize, '/weblogic-connector/outbound-

resource-adapter/connection-definition-group/[connection-factory-interface="javax.resource.cci.ConnectionFactory"]/connection-instance/[jndi-name="'+dbJndi+'"]/connecti

on-properties/properties/property/[name="sequencePreallocationSize"]/value',moduleOverrideNamedb)

                    myPlandb.save();

                    save();

            except:

                    print 'Exception occured while creating datasource'

                    print 'error infor....', sys.exc_info()[0]

                    raise

            i = i+1

        cd('/AppDeployments/DbAdapter/Targets');

        print 'updating configuration............. for ', appNameDB

        print 'updating configuration............. for ', planPathDB

        updateApplication(appNameDB, planPathDB);

        startApplication(appNameDB)

        activate(block='true');

except:

     print '********************************************'

     print 'Exception occured while configuring db jndi'

     print 'error infor....', sys.exc_info()[0]

     undo('false','y')

     exit('y',1001)

     print '********************************************'

Step 3) Invoke WLST and run the script : wlst.sh DBAdaptorConfig.py dev