scripts/puppet4ccb/neals_playground/modules/fmw_domain/files/domain/common.py

#
def createBootPropertiesFile(directoryPath,fileName, username, password):
  serverDir = File(directoryPath)
  bool = serverDir.mkdirs()
  fileNew=open(directoryPath + '/'+fileName, 'w')
  fileNew.write('username=%s\n' % username)
  fileNew.write('password=%s\n' % password)
  fileNew.flush()
  fileNew.close()

def createAdminStartupPropertiesFile(directoryPath, args):
  adminserverDir = File(directoryPath)
  bool = adminserverDir.mkdirs()
  fileNew=open(directoryPath + '/startup.properties', 'w')
  args=args.replace(':','\\:')
  args=args.replace('=','\\=')
  fileNew.write('Arguments=%s\n' % args)
  fileNew.flush()
  fileNew.close()

def createMachine(type, name, address, port):
  cd('/')
  create(name,type)
  cd(type + '/' + name)
  create(name, 'NodeManager')
  cd('NodeManager/' + name)
  set('NMType','SSL')
  set('ListenAddress',address)
  if port:
    set('ListenPort', port)

def changeDefaultServerAttributes(server, machine, address, port, java_arguments, java_home):
  print "changeDefaultServerAttributes for server " + server
  cd('/Servers/' + server)

  if machine:
    set('Machine', machine)
  if address:
    set('ListenAddress', address)
  if port:
    set('ListenPort', port)

  create(server, 'ServerStart')
  cd('ServerStart/' + server)
  set('Arguments' , java_arguments)
  set('JavaVendor', 'Sun')
  set('JavaHome'  , java_home)

def changeAdminServer(adminserver, machine, address, port, java_arguments, java_home):
  cd('/Servers/AdminServer')
  set('Name', adminserver )
  changeDefaultServerAttributes(adminserver, machine, address, port, java_arguments, java_home)

def changeManagedServer(server, machine, address, port, java_arguments, java_home):
  changeDefaultServerAttributes(server, machine, address, port, java_arguments, java_home)

def setWebLogicPassword(user, password):
  print('Set password...')
  cd('/')
  cd('Security/base_domain/User/weblogic')
  # weblogic user name + password
  set('Name', user)
  set('Password', password)

def changeDatasource(datasource, username, password, db_url):
  print 'Change datasource '+datasource
  cd('/')
  cd('/JDBCSystemResource/'+datasource+'/JdbcResource/'+datasource+'/JDBCDriverParams/NO_NAME_0')
  set('URL',db_url)
  set('PasswordEncrypted',password)
  cd('Properties/NO_NAME_0/Property/user')
  set('Value',username)
  cd('/')

def changeDatasourceToXA(datasource):
  print 'Change datasource '+datasource
  cd('/')
  cd('/JDBCSystemResource/'+datasource+'/JdbcResource/'+datasource+'/JDBCDriverParams/NO_NAME_0')
  set('DriverName','oracle.jdbc.xa.client.OracleXADataSource')
  set('UseXADataSourceInterface','True')
  cd('/JDBCSystemResource/'+datasource+'/JdbcResource/'+datasource+'/JDBCDataSourceParams/NO_NAME_0')
  set('GlobalTransactionsProtocol','TwoPhaseCommit')
  cd('/')

def changeDatasourceDriver(datasource, username, password, db_url, driver):
  print 'Change datasource '+datasource
  cd('/')
  cd('/JDBCSystemResource/'+datasource+'/JdbcResource/'+datasource+'/JDBCDriverParams/NO_NAME_0')
  set('URL',db_url)
  set('DriverName','oracle.jdbc.OracleDriver')
  set('PasswordEncrypted',password)
  cd('Properties/NO_NAME_0/Property/user')
  set('Value',username)
  cd('/')

def getClusterName(cluster, admin_server):
    targetServerStr = str(cluster)
    s = ls('/Server')
    print ' '
    clustername = " "
    for token in s.split("drw-"):
        token=token.strip().lstrip().rstrip()
        path="/Server/"+token
        cd(path)
        if not token == admin_server and not token == '':
            if not targetServerStr.find(token+":") == -1:
                clustername = get('Cluster')
    return clustername

def getClusterServers(cluster, admin_server):
    servers = []
    s = ls('/Server')
    clustername = " "
    for token in s.split("drw-"):
        token=token.strip().lstrip().rstrip()
        path="/Server/"+token
        cd(path)
        if not token == admin_server and not token == '':
            clustername = get('Cluster')
            searchClusterStr = cluster+":"
            clusterNameStr = str(clustername)
            if not clusterNameStr.find(searchClusterStr) == -1:
                servers.append(token)

    return servers

def getFirstClusterServer(cluster, admin_server):
    s = ls('/Server')
    clustername = " "
    for token in s.split("drw-"):
        token=token.strip().lstrip().rstrip()
        path="/Server/"+token
        cd(path)
        if not token == admin_server and not token == '':
            clustername = get('Cluster')
            searchClusterStr = cluster+":"
            clusterNameStr = str(clustername)
            if not clusterNameStr.find(searchClusterStr) == -1:
                return token


def reassignTarget(type, name, untarget, target):
  untargets = String(untarget).split(",")
  for i in range(len(untargets)):
    try:
      unassign(type, name, 'Target', untargets[i])
    except:
      print "reassignTarget unassign failed type " + type + " name " + name + " untarget " + untarget + " target " + target
      pass

  try:
    assign(type, name, 'Target', target)
  except:
    print "reassignTarget assign failed type " + type + " name " + name + " untarget " + untarget + " target " + target
    pass


def change11gFMWTargets(admin_server, soa_cluster, osb_cluster, bam_cluster, bpm_enabled):
    AllArray = []
    AdapterArray = []

    AllArray.append(admin_server)
    AdapterArray.append(admin_server)

    if soa_cluster:
      AllArray.append(soa_cluster)
      AdapterArray.append(soa_cluster)

    if bam_cluster:
      AllArray.append(bam_cluster)

    if osb_cluster:
      AllArray.append(osb_cluster)
      AdapterArray.append(osb_cluster)

    All       = ','.join(AllArray)
    Adapters  = ','.join(AdapterArray)

    reassignTarget('AppDeployment', 'DMS Application#11.1.1.1.0', All, All)
    reassignTarget('AppDeployment', 'wsil-wls', All, All)

    try:
      reassignTarget('AppDeployment', 'AqAdapter'        , All, Adapters)
      reassignTarget('AppDeployment', 'DbAdapter'        , All, Adapters)
      reassignTarget('AppDeployment', 'FileAdapter'      , All, Adapters)
      reassignTarget('AppDeployment', 'FtpAdapter'       , All, Adapters)
      reassignTarget('AppDeployment', 'JmsAdapter'       , All, Adapters)
      reassignTarget('AppDeployment', 'MQSeriesAdapter'  , All, Adapters)
      reassignTarget('AppDeployment', 'OracleAppsAdapter', All, Adapters)
      reassignTarget('AppDeployment', 'OracleBamAdapter' , All, Adapters)
      reassignTarget('AppDeployment', 'SocketAdapter'    , All, Adapters)
      if soa_cluster:
        reassignTarget('AppDeployment', 'UMSAdapter'     , All, Adapters)
    except:
      print "AppDeployment Adapters error", sys.exc_info()[0]

    reassignTarget('AppDeployment', 'em'                                     , All, admin_server)
    reassignTarget('AppDeployment', 'FMW Welcome Page Application#11.1.0.0.0', All, admin_server)

    if soa_cluster:
      try:
        reassignTarget('AppDeployment', 'b2bui'                      , All, soa_cluster)
        reassignTarget('AppDeployment', 'composer'                   , All, soa_cluster)
        reassignTarget('AppDeployment', 'DefaultToDoTaskFlow'        , All, soa_cluster)
        reassignTarget('AppDeployment', 'soa-infra'                  , All, soa_cluster)
        reassignTarget('AppDeployment', 'worklistapp'                , All, soa_cluster)
        reassignTarget('AppDeployment', 'usermessagingdriver-email'  , All, soa_cluster)
        reassignTarget('AppDeployment', 'usermessagingserver'        , All, soa_cluster)
        reassignTarget('AppDeployment', 'wsm-pm'                     , All, soa_cluster)
        if bpm_enabled == true:
          reassignTarget('AppDeployment', 'BPMComposer'                , All, soa_cluster)
          reassignTarget('AppDeployment', 'frevvo'                     , All, soa_cluster)
          reassignTarget('AppDeployment', 'OracleBPMComposerRolesApp'  , All, soa_cluster)
          reassignTarget('AppDeployment', 'OracleBPMProcessRolesApp'   , All, soa_cluster)
          reassignTarget('AppDeployment', 'OracleBPMWorkspace'         , All, soa_cluster)
          reassignTarget('AppDeployment', 'SimpleApprovalTaskFlow'     , All, soa_cluster)
      except:
        print "AppDeployment soa apps error", sys.exc_info()[0]

    if bam_cluster:
      try:
        reassignTarget('AppDeployment', 'oracle-bam#11.1.1'          , All, bam_cluster)
        reassignTarget('AppDeployment', 'usermessagingdriver-email'  , All, soa_cluster + "," + bam_cluster)
        reassignTarget('AppDeployment', 'usermessagingserver'        , All, soa_cluster + "," + bam_cluster)
        reassignTarget('AppDeployment', 'wsm-pm'                     , All, soa_cluster + "," + bam_cluster)
      except:
        print "AppDeployment bam apps error", sys.exc_info()[0]

    if osb_cluster:
      osb_server1 = getFirstClusterServer(osb_cluster, admin_server)
      try:
        reassignTarget('AppDeployment', 'ALDSP Transport Provider'                  , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB Coherence Cache Provider'             , All, osb_cluster)
        reassignTarget('AppDeployment', 'ALSB Framework Starter Application'        , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB Logging'                              , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB Publish'                              , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB Resource'                             , All, osb_cluster)
        reassignTarget('AppDeployment', 'ALSB Routing'                              , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB Subscription Listener'                , All, osb_cluster)
        reassignTarget('AppDeployment', 'ALSB Test Framework'                       , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB Transform'                            , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ALSB UDDI Manager'                         , All, admin_server)
        reassignTarget('AppDeployment', 'ALSB WSIL'                                 , All, osb_cluster)
        reassignTarget('AppDeployment', 'BPEL 10g Transport Provider'               , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'EJB Transport Provider'                    , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'FLOW Transport Provider'                   , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'JCA Transport Provider'                    , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'JEJB Transport Provider'                   , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'JMS Reporting Provider'                    , All, osb_cluster)
        reassignTarget('AppDeployment', 'MQ Transport Provider'                     , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'SB Transport Provider'                     , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'ServiceBus_Console'                        , All, admin_server)
        reassignTarget('AppDeployment', 'SOA-DIRECT Transport Provider'             , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'Tuxedo Transport Provider'                 , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'WS Transport Async Applcation'             , All, osb_cluster)
        reassignTarget('AppDeployment', 'WS Transport Provider'                     , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment', 'XBus Kernel'                               , All, osb_cluster + "," + admin_server)

        reassignTarget('AppDeployment', 'ALSB Cluster Singleton Marker Application' , All, osb_server1)
        reassignTarget('AppDeployment', 'ALSB Domain Singleton Marker Application'  , All, osb_server1)
        reassignTarget('AppDeployment', 'Message Reporting Purger'                  , All, osb_server1)

        reassignTarget('AppDeployment', 'Email Transport Provider'                                  , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment.SubDeployment', 'Email Transport Provider.emailtransport.jar' , All, osb_cluster)
        reassignTarget('AppDeployment', 'File Transport Provider'                                   , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment.SubDeployment', 'File Transport Provider.filepoll.jar'        , All, osb_cluster)
        reassignTarget('AppDeployment', 'Ftp Transport Provider'                                    , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment.SubDeployment', 'Ftp Transport Provider.ftp_transport.jar'    , All, osb_cluster)
        reassignTarget('AppDeployment', 'SFTP Transport Provider'                                   , All, osb_cluster + "," + admin_server)
        reassignTarget('AppDeployment.SubDeployment', 'SFTP Transport Provider.sftp_transport.jar'  , All, osb_cluster)
      except:
        print "AppDeployment osb apps error", sys.exc_info()[0]

    reassignTarget('Library', 'emai'                                   , All, admin_server)
    reassignTarget('Library', 'oracle.webcenter.skin#11.1.1@11.1.1'    , All, admin_server)
    reassignTarget('Library', 'oracle.webcenter.composer#11.1.1@11.1.1', All, admin_server)
    reassignTarget('Library', 'emas'                                   , All, admin_server)
    reassignTarget('Library', 'emcore'                                 , All, admin_server)

    reassignTarget('Library', 'adf.oracle.businesseditor#1.0@11.1.1.2.0'  , All, All)
    reassignTarget('Library', 'adf.oracle.domain#1.0@11.1.1.2.0'          , All, All)
    reassignTarget('Library', 'adf.oracle.domain.webapp#1.0@11.1.1.2.0'   , All, All)

    reassignTarget('Library', 'jsf#1.2@1.2.9.0' , All, All)
    reassignTarget('Library', 'jstl#1.2@1.2.0.1', All, All)
    reassignTarget('Library', 'ohw-rcf#5@5.0'   , All, All)
    reassignTarget('Library', 'ohw-uix#5@5.0'   , All, All)

    reassignTarget('Library', 'oracle.adf.desktopintegration.model#1.0@11.1.1.2.0', All, All)
    reassignTarget('Library', 'oracle.adf.desktopintegration#1.0@11.1.1.2.0'      , All, All)
    reassignTarget('Library', 'oracle.adf.dconfigbeans#1.0@11.1.1.2.0'            , All, All)
    reassignTarget('Library', 'oracle.adf.management#1.0@11.1.1.2.0'              , All, All)

    reassignTarget('Library', 'oracle.bi.jbips#11.1.1@0.1'                 , All, All)
    reassignTarget('Library', 'oracle.bi.composer#11.1.1@0.1'              , All, All)
    reassignTarget('Library', 'oracle.bi.adf.model.slib#1.0@11.1.1.2.0'    , All, All)
    reassignTarget('Library', 'oracle.bi.adf.view.slib#1.0@11.1.1.2.0'     , All, All)
    reassignTarget('Library', 'oracle.bi.adf.webcenter.slib#1.0@11.1.1.2.0', All, All)

    reassignTarget('Library', 'oracle.dconfig-infra#11@11.1.1.1.0'   , All, All)
    reassignTarget('Library', 'oracle.jrf.system.filter'             , All, All)
    reassignTarget('Library', 'oracle.jsp.next#11.1.1@11.1.1'        , All, All)
    reassignTarget('Library', 'oracle.pwdgen#11.1.1@11.1.1.2.0'      , All, All)

    reassignTarget('Library', 'oracle.wsm.seedpolicies#11.1.1@11.1.1', All, All)
    reassignTarget('Library', 'orai18n-adf#11@11.1.1.1.0'            , All, All)
    reassignTarget('Library', 'UIX#11@11.1.1.1.0'                    , All, All)

    if bam_cluster:
      try:
        reassignTarget('Library', 'oracle.sdp.client#11.1.1@11.1.1'                , All, soa_cluster + "," + bam_cluster)
        reassignTarget('Library', 'oracle.rules#11.1.1@11.1.1'                     , All, soa_cluster + "," + bam_cluster + "," + admin_server)
        reassignTarget('Library', 'oracle.soa.rules_dict_dc.webapp#11.1.1@11.1.1'  , All, soa_cluster + "," + bam_cluster)
      except:
        print "Library bam libs error", sys.exc_info()[0]
    elif soa_cluster:
      try:
        reassignTarget('Library', 'oracle.sdp.client#11.1.1@11.1.1'                , All, soa_cluster)
        reassignTarget('Library', 'oracle.rules#11.1.1@11.1.1'                     , All, soa_cluster + "," + admin_server)
        reassignTarget('Library', 'oracle.soa.rules_dict_dc.webapp#11.1.1@11.1.1'  , All, soa_cluster)
      except:
        print "Library soa libs error", sys.exc_info()[0]
        dumpStack()

    if soa_cluster:
      try:
        reassignTarget('Library', 'oracle.sdp.messaging#11.1.1@11.1.1'             , All, All)
        reassignTarget('Library', 'oracle.applcore.config#0.1@11.1.1.0.0'          , All, soa_cluster)
        reassignTarget('Library', 'oracle.applcore.model#0.1@11.1.1.0.0'           , All, soa_cluster)
        reassignTarget('Library', 'oracle.applcore.view#0.1@11.1.1.0.0'            , All, soa_cluster)
        reassignTarget('Library', 'oracle.bpm.mgmt#11.1.1@11.1.1'                  , All, soa_cluster + "," + admin_server)
        reassignTarget('Library', 'oracle.soa.bpel#11.1.1@11.1.1'                  , All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.composer.webapp#11.1.1@11.1.1'       , All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.ext#11.1.1@11.1.1'                   , All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.mediator#11.1.1@11.1.1'              , All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.worklist#11.1.1@11.1.1'              , All, soa_cluster)

        reassignTarget('Library', 'oracle.soa.workflow.wc#11.1.1@11.1.1'           , All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.worklist.webapp#11.1.1@11.1.1'       , All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.rules_editor_dc.webapp#11.1.1@11.1.1', All, soa_cluster)
        reassignTarget('Library', 'oracle.soa.workflow#11.1.1@11.1.1'              , All, soa_cluster)
        if bpm_enabled == true:
          reassignTarget('Library', 'oracle.bpm.client#11.1.1@11.1.1'        , All, soa_cluster + "," + admin_server)
          reassignTarget('Library', 'oracle.bpm.composerlib#11.1.1@11.1.1'   , All, soa_cluster + "," + admin_server)
          reassignTarget('Library', 'oracle.bpm.projectlib#11.1.1@11.1.1'    , All, soa_cluster + "," + admin_server)
          reassignTarget('Library', 'oracle.bpm.runtime#11.1.1@11.1.1'       , All, soa_cluster + "," + admin_server)
          reassignTarget('Library', 'oracle.bpm.webapp.common#11.1.1@11.1.1' , All, soa_cluster + "," + admin_server)
          reassignTarget('Library', 'oracle.bpm.workspace#11.1.1@11.1.1'     , All, soa_cluster + "," + admin_server)
      except:
        print "Library soa libs error", sys.exc_info()[0]
        dumpStack()

    if bam_cluster:
      try:
        reassignTarget('Library', 'oracle.bam.library#11.1.1@11.1.1'       , All, bam_cluster + "," + admin_server)
      except:
        print "Library bam libs error", sys.exc_info()[0]

    if osb_cluster:
      try:
        reassignTarget('Library', 'oracle.jrf.coherence#3@11.1.1'                   , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'coherence-l10n#11.1.1@11.1.1'                    , All, osb_cluster)
        reassignTarget('Library', 'ftptransport-l10n#2.5@2.5'                       , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'sftptransport-l10n#3.0@3.0'                      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'emailtransport-l10n#2.5@2.5'                     , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'filetransport-l10n#2.5@2.5'                      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'mqtransport-l10n#3.0@3.0'                        , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'mqconnection-l10n#3.0@3.0'                       , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'ejbtransport-l10n#2.5@2.5'                       , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'tuxedotransport-l10n#2.5@2.5'                    , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'aldsp_transport-l10n#3.0@3.0'                    , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wstransport-l10n#2.6@2.6'                        , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'flow-transport-l10n#3.0@3.0'                     , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'bpel10gtransport-l10n#3.1@3.1'                   , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'jcatransport-l10n#3.1@3.1'                       , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wsif#11.1.1@11.1.1'                              , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'JCAFrameworkImpl#11.1.1@11.1.1'                  , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'jejbtransport-l10n#3.2@3.2'                      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'jejbtransport-jar#3.2@3.2'                       , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'soatransport-l10n#11.1.1.2.0@11.1.1.2.0'         , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'stage-utils#2.5@2.5'                             , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'sbconsole-l10n#2.5@2.5'                          , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'xbusrouting-l10n#2.5@2.5'                        , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'xbustransform-l10n#2.5@2.5'                      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'xbuspublish-l10n#2.5@2.5'                        , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'xbuslogging-l10n#2.5@2.5'                        , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'testfwk-l10n#2.5@2.5'                            , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'com.bea.wlp.lwpf.console.app#10.3.0@10.3.0'      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'com.bea.wlp.lwpf.console.web#10.3.0@10.3.0'      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wlp-lookandfeel-web-lib#10.3.0@10.3.0'           , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wlp-light-web-lib#10.3.0@10.3.0'                 , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wlp-framework-common-web-lib#10.3.0@10.3.0'      , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wlp-framework-struts-1.2-web-lib#10.3.0@10.3.0'  , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'struts-1.2#1.2@1.2.9'                            , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'beehive-netui-1.0.1-10.0#1.0@1.0.2.2'            , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'beehive-netui-resources-1.0.1-10.0#1.0@1.0.2.2'  , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'beehive-controls-1.0.1-10.0-war#1.0@1.0.2.2'     , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'weblogic-controls-10.0-war#10.0@10.2'            , All, osb_cluster + "," + admin_server)
        reassignTarget('Library', 'wls-commonslogging-bridge-war#1.0@1.1'           , All, osb_cluster + "," + admin_server)
      except:
        print "Library osb libs error", sys.exc_info()[0]

    reassignTarget('ShutdownClass', 'JOC-Shutdown'                                      , All, All)
    reassignTarget('ShutdownClass', 'DMSShutdown'                                       , All, All)

    reassignTarget('StartupClass' , 'JRF Startup Class'                                 , All, All)
    reassignTarget('StartupClass' , 'JPS Startup Class'                                 , All, All)
    reassignTarget('StartupClass' , 'ODL-Startup'                                       , All, All)
    reassignTarget('StartupClass' , 'AWT Application Context Startup Class'             , All, All)
    reassignTarget('StartupClass' , 'JMX Framework Startup Class'                       , All, All)
    reassignTarget('StartupClass' , 'Web Services Startup Class'                        , All, All)
    reassignTarget('StartupClass' , 'JOC-Startup'                                       , All, All)
    reassignTarget('StartupClass' , 'DMS-Startup'                                       , All, All)

    if soa_cluster:
      try:
        reassignTarget('StartupClass' , 'SOAStartupClass'                                , All, soa_cluster)
      except:
        print "StartupClass soa class error", sys.exc_info()[0]

    if osb_cluster:
      try:
        reassignTarget('StartupClass' , 'OSB JCA Transport Post-Activation Startup Class', All, osb_cluster + "," + admin_server)
      except:
        print "StartupClass osb class error", sys.exc_info()[0]

    reassignTarget('WldfSystemResource', 'Module-FMWDFW'       , All, All)

    if soa_cluster:
      try:
        reassignTarget('JdbcSystemResource', 'EDNDataSource'       , All, soa_cluster)
        reassignTarget('JdbcSystemResource', 'EDNLocalTxDataSource', All, soa_cluster)
        reassignTarget('JdbcSystemResource', 'mds-soa'             , All, soa_cluster + "," + admin_server)
        reassignTarget('JdbcSystemResource', 'mds-owsm'            , All, All)
        reassignTarget('JdbcSystemResource', 'SOADataSource'       , All, soa_cluster)
        reassignTarget('JdbcSystemResource', 'SOALocalTxDataSource', All, soa_cluster)
      except:
        print "JdbcSystemResource soa jdbc error", sys.exc_info()[0]

    if bam_cluster:
      try:
        reassignTarget('JdbcSystemResource', 'BAMDataSource'       , All, bam_cluster)
        reassignTarget('JdbcSystemResource', 'OraSDPMDataSource'   , All, soa_cluster + "," + bam_cluster)
      except:
        print "JdbcSystemResource bam jdbc error", sys.exc_info()[0]
    elif soa_cluster:
      try:
        reassignTarget('JdbcSystemResource', 'OraSDPMDataSource'   , All, soa_cluster)
      except:
        print "JdbcSystemResource soa jdbc error", sys.exc_info()[0]

    if osb_cluster:
      try:
        reassignTarget('JdbcSystemResource', 'wlsbjmsrpDataSource' , All, osb_cluster + "," + admin_server)
      except:
        print "JdbcSystemResource osb jdbc error", sys.exc_info()[0]

def cleanJMS(jms_module_pattern, jms_server_pattern, filestore_pattern):
  if jms_module_pattern:
    s = ls('/JMSSystemResources')
    for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token == '' and not token.find(jms_module_pattern) == -1:
        print "token "+token
        try:
          delete(token, 'JMSSystemResource')
        except:
          print "delete of " + token + " jmsmodule failed", sys.exc_info()[0]
          pass

  if jms_server_pattern:
    s = ls('/JMSServers')
    for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token == '' and not token.find(jms_server_pattern) == -1:
        print "token "+token
        try:
          delete(token, 'JMSServer')
        except:
          print "delete of " + token + " jmsserver failed", sys.exc_info()[0]
          pass

  if filestore_pattern:
    s = ls('/FileStore')
    for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token == '' and not token.find(filestore_pattern) == -1:
        print "token "+token
        try:
          delete(token, 'FileStore')
        except:
          print "delete of " + token + " filestore failed", sys.exc_info()[0]
          pass

def cleanSAFagents(saf_agent_pattern):
  if saf_agent_pattern:
    s = ls('/SAFAgent')
    for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token == '' and not token.find(saf_agent_pattern) == -1:
        print "token "+token
        try:
          delete(token, 'SAFAgent')
        except:
          print "delete of " + token + " safagent failed", sys.exc_info()[0]
          pass

def createFileStore(storeName, serverName):
    create(storeName, 'FileStore')
    cd('/FileStore/'+storeName)
    set ('Target', serverName)
    set ('Directory', storeName)
    cd('/')


def createJMSServers(cluster, track, currentServerCnt):
  print ' '
  print "Creating JMS Servers for the cluster :- ", cluster
  s = ls('/Server')
  print ' '
  clustername = " "
  serverCnt = currentServerCnt
  for token in s.split("drw-"):
    token=token.strip().lstrip().rstrip()
    path="/Server/"+token
    cd(path)
    if not token == 'AdminServer' and not token == '':
      clustername = get('Cluster')
      print "Cluster Associated with the Server [",token,"] :- ",clustername
      print ' '
      searchClusterStr = cluster+":"
      clusterNameStr = str(clustername)
      print "searchClusterStr = ",searchClusterStr
      print "clusterNameStr = ",clusterNameStr
      if not clusterNameStr.find(searchClusterStr) == -1:
        print token, " is associated with ", cluster
        print ' '
        print "Creating JMS Servers for ", track
        print ' '
        cd('/')

        if track == 'bpm':
          jmsServerName = 'BPMJMSServer_auto_'+str(serverCnt)
          fileStoreName = 'BPMJMSServerFileStore_auto_'+str(serverCnt)
        elif track == 'ag':
          jmsServerName = 'AGJMSServer_auto_'+str(serverCnt)
          fileStoreName = 'AGJMSServerFileStore_auto_'+str(serverCnt)
        elif track == 'ps6soa':
          jmsServerName = 'PS6SOAJMSServer_auto_'+str(serverCnt)
          fileStoreName = 'PS6SOAJMSServerFileStore_auto_'+str(serverCnt)

        createFileStore(fileStoreName, token)
        print "Created File Store :- ", fileStoreName

        create(jmsServerName, 'JMSServer')
        print "Created JMS Server :- ", jmsServerName
        print ' '
        assign('JMSServer', jmsServerName, 'Target', token)
        print jmsServerName, " assigned to server :- ", token
        print ' '
        cd('/JMSServer/'+jmsServerName)
        set ('PersistentStore', fileStoreName)

        serverCnt = serverCnt + 1


def soa11g_bpm(cluster, bpm_enabled):
  createJMSServers(cluster, 'bpm', 1)

  cd('/')
  create('BPMJMSModuleUDDs','JMSSystemResource')

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs')
  assign('JMSSystemResource', 'BPMJMSModuleUDDs', 'Target', cluster)

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs')
  create('BPMJMSSubDM', 'SubDeployment')

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs/SubDeployments/BPMJMSSubDM')

  print ' '
  print ("*** Listing SOA JMS Servers ***")
  s = ls('/JMSServers')
  soaJMSServerStr=''
  for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token.find("BPMJMSServer_auto") == -1:
          soaJMSServerStr = soaJMSServerStr + token +","
      print token

  print ("*** Setting JMS SubModule for SOA JMS Server's target***")
  assign('JMSSystemResource.SubDeployment', 'BPMJMSModuleUDDs.BPMJMSSubDM', 'Target', soaJMSServerStr) 

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0')

  udd=create('MeasurementTopic','UniformDistributedTopic')
  udd.setJNDIName('jms/bpm/MeasurementTopic')
  udd.setJMSCreateDestinationIdentifier('jms/bpm/MeasurementTopic')
  udd.setSubDeploymentName('BPMJMSSubDM')

  udd=create('PeopleQueryTopic','UniformDistributedTopic')
  udd.setJNDIName('jms/bpm/PeopleQueryTopic')
  udd.setJMSCreateDestinationIdentifier('jms/bpm/PeopleQueryTopic')
  udd.setSubDeploymentName('BPMJMSSubDM')

  soacf=create('BAMCommandXAConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('jms/bpm/BAMCommandXAConnectionFactory')
  cd('/JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/BAMCommandXAConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0')

  soacf=create('CubeCommandXAConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('jms/bpm/CubeCommandXAConnectionFactory')
  cd('/JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/CubeCommandXAConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0')

  soacf=create('MeasurementTopicConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('jms/bpm/MeasurementTopicConnectionFactory')
  cd('/JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/MeasurementTopicConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0')

  soacf=create('PeopleQueryConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('jms/bpm/PeopleQueryConnectionFactory')
  cd('/JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/PeopleQueryConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0')

  soacf=create('PeopleQueryTopicConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('jms/bpm/PeopleQueryTopicConnectionFactory')
  cd('/JMSSystemResource/BPMJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/PeopleQueryTopicConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  if bpm_enabled == true:
    cd('/')
    cleanJMS('AGJMSModule', 'AGJMSServer_auto', 'AGJMSFileStore_auto')

    createJMSServers(cluster, 'ag', 1)
    cd('/')
    create('AGJMSModuleUDDs','JMSSystemResource')

    cd('/')
    cd('JMSSystemResource/AGJMSModuleUDDs')
    assign('JMSSystemResource', 'AGJMSModuleUDDs', 'Target', cluster)

    cd('/')
    cd('JMSSystemResource/AGJMSModuleUDDs')
    create('AGJMSSubDM', 'SubDeployment')

    cd('/')
    cd('JMSSystemResource/AGJMSModuleUDDs/SubDeployments/AGJMSSubDM')

    print ' '
    print ("*** Listing SOA JMS Servers ***")
    s = ls('/JMSServers')
    soaJMSServerStr=''
    for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token.find("AGJMSServer_auto") == -1:
        soaJMSServerStr = soaJMSServerStr + token +","
      print token

    print ("*** Setting JMS SubModule for SOA JMS Server's target***")
    assign('JMSSystemResource.SubDeployment', 'AGJMSModuleUDDs.AGJMSSubDM', 'Target', soaJMSServerStr) 

    cd('/')
    cd('JMSSystemResource/AGJMSModuleUDDs/JmsResource/NO_NAME_0')

    udd=create('UIBrokerTopic','UniformDistributedTopic')
    udd.setJNDIName('jms/bpm/UIBrokerTopic')
    udd.setJMSCreateDestinationIdentifier('jms/bpm/UIBrokerTopic')
    udd.setSubDeploymentName('AGJMSSubDM')

    soacf=create('UIBrokerTopicConnectionFactory','ConnectionFactory')
    soacf.setJNDIName('jms/bpm/UIBrokerTopicConnectionFactory')
    cd('/JMSSystemResource/AGJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/UIBrokerTopicConnectionFactory')
    set('DefaultTargetingEnabled', 'true')
    create('TransactionParams', 'TransactionParams')
    cd('TransactionParams/NO_NAME_0')
    cmo.setXAConnectionFactoryEnabled(true)

def soa11g_ps6(cluster):
  cd('/')
  createJMSServers(cluster, 'ps6soa', 1)
  cd('/')
  create('PS6SOAJMSModuleUDDs','JMSSystemResource')
  cd('/')
  cd('JMSSystemResource/PS6SOAJMSModuleUDDs')
  assign('JMSSystemResource', 'PS6SOAJMSModuleUDDs', 'Target', cluster)
  cd('/')
  cd('JMSSystemResource/PS6SOAJMSModuleUDDs')
  create('PS6SOAJMSSubDM', 'SubDeployment')
  cd('/')
  cd('JMSSystemResource/PS6SOAJMSModuleUDDs/SubDeployments/PS6SOAJMSSubDM')

  print ' '
  print ("*** Listing SOA JMS Servers ***")
  s = ls('/JMSServers')
  soaJMSServerStr=''
  for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      if not token.find("PS6SOAJMSServer_auto") == -1:
          soaJMSServerStr = soaJMSServerStr + token +","
      print token

  print ("*** Setting JMS SubModule for SOA JMS Server's target***")
  assign('JMSSystemResource.SubDeployment', 'PS6SOAJMSModuleUDDs.PS6SOAJMSSubDM', 'Target', soaJMSServerStr)
  cd('/')
  cd('JMSSystemResource/PS6SOAJMSModuleUDDs/JmsResource/NO_NAME_0')

  udd=create('CaseEventQueue','UniformDistributedQueue')
  udd.setJNDIName('jms/bpm/CaseEventQueue')
  udd.setJMSCreateDestinationIdentifier('jms/bpm/CaseEventQueue')
  udd.setSubDeploymentName('PS6SOAJMSSubDM')

  soacf=create('CaseEventConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('jms/bpm/CaseEventConnectionFactory')
  cd('/JMSSystemResource/PS6SOAJMSModuleUDDs/JmsResource/NO_NAME_0/ConnectionFactory/CaseEventConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)


def createJMSServersSB(cluster, track, currentServerCnt):
  print ' '
  print "Creating JMS Servers for the cluster :- ", cluster
  s = ls('/Server')
  print ' '
  clustername = " "
  serverCnt = currentServerCnt
  for token in s.split("drw-"):
      token=token.strip().lstrip().rstrip()
      path="/Server/"+token
      cd(path)
      if not token == 'AdminServer' and not token == '':
          clustername = get('Cluster')
          print "Cluster Associated with the Server [",token,"] :- ",clustername
          print ' '
          searchClusterStr = cluster+":"
          clusterNameStr = str(clustername)
          print "searchClusterStr = ",searchClusterStr
          print "clusterNameStr = ",clusterNameStr
          if not clusterNameStr.find(searchClusterStr) == -1:
              print token, " is associated with ", cluster
              print ' '
              print "Creating JMS Servers for ", track
              print ' '
              cd('/')

              if track == 'osb':
                  jmsServerName = 'wlsbJMSServer_auto_'+str(serverCnt)
                  fileStoreName = 'FileStore_auto_'+str(serverCnt)
              elif track == 'wsee':
                  jmsServerName = 'WseeJmsServer_auto_'+str(serverCnt)
                  fileStoreName = 'WseeFileStore_auto_'+str(serverCnt)

              createFileStore(fileStoreName, token)
              print "Created File Store :- ", fileStoreName

              create(jmsServerName, 'JMSServer')
              print "Created JMS Server :- ", jmsServerName
              print ' '
              assign('JMSServer', jmsServerName, 'Target', token)
              print jmsServerName, " assigned to server :- ", token
              print ' '
              cd('/JMSServer/'+jmsServerName)
              set ('PersistentStore', fileStoreName)

              # if track == 'wsee':
              #     safAgent     = 'ReliableWseeSAFAgent_auto_'+str(serverCnt)

              #     cd('/')
              #     create(safAgent, 'SAFAgent')
              #     cd('/SAFAgent/'+safAgent)
              #     set ('Target'     , token)
              #     set ('Store'      , fileStoreName)
              #     set ('ServiceType','Both')

              serverCnt = serverCnt + 1

def sb11g(cluster):
  cd('/')
  create('jmsResourcesUDDs','JMSSystemResource')

  cd('/')
  cd('JMSSystemResource/jmsResourcesUDDs')
  assign('JMSSystemResource', 'jmsResourcesUDDs', 'Target', cluster)

  cd('/')
  cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

  udd=create('dist_QueueIn_auto'                                 ,'DistributedQueue')
  udd.setJNDIName("QueueIn")
  udd=create('dist_wli.reporting.jmsprovider.queue_auto'         ,'DistributedQueue')
  udd.setJNDIName("wli.reporting.jmsprovider.queue")
  udd=create('dist_wli.reporting.jmsprovider_error.queue_auto'   ,'DistributedQueue')
  udd.setJNDIName("wli.reporting.jmsprovider_error.queue")
  udd=create('dist_wlsb.internal.transport.task.queue.email_auto','DistributedQueue')
  udd.setJNDIName("wlsb.internal.transport.task.queue.email")
  udd=create('dist_wlsb.internal.transport.task.queue.file_auto' ,'DistributedQueue')
  udd.setJNDIName("wlsb.internal.transport.task.queue.file")
  udd=create('dist_wlsb.internal.transport.task.queue.ftp_auto'  ,'DistributedQueue')
  udd.setJNDIName("wlsb.internal.transport.task.queue.ftp")
  udd=create('dist_wlsb.internal.transport.task.queue.sftp_auto' ,'DistributedQueue')
  udd.setJNDIName("wlsb.internal.transport.task.queue.sftp")

  createJMSServersSB(cluster, 'osb', 1)

  print ' '
  print ("*** Listing OSB JMS Servers ***")
  s = ls('/JMSServers')
  osbJMSServerStr=''
  serverCnt =  1
  for token in s.split("drw-"):
    token=token.strip().lstrip().rstrip()
    if not token.find("wlsbJMSServer_auto") == -1:
      print token
      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs')
      subDeploymentStr = 'wlsbJMSServer'+str(serverCnt)+'_sub'
      create(subDeploymentStr, 'SubDeployment')

      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/SubDeployments/'+subDeploymentStr)
      assign('JMSSystemResource.SubDeployment', 'jmsResourcesUDDs.'+subDeploymentStr, 'Target', token) 


      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      queue1 = 'QueueIn_auto_'+str(serverCnt)
      udd=create(queue1,'Queue')
      udd.setJNDIName(queue1)
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (queue1)
      #dpo = create('dpoName','DeliveryParamsOverrides')
      #dpo.setRedeliveryDelay(15*60*1000)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')

      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_QueueIn_auto')
      aaa = create(queue1,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_QueueIn_auto/DistributedQueueMember/' + queue1)
      set('Weight',1)

      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      errorQueue = 'wli.reporting.jmsprovider_error.queue_auto_'+str(serverCnt)
      uddErr=create(errorQueue,'Queue')
      uddErr.setJNDIName(errorQueue)
      uddErr.setSubDeploymentName(subDeploymentStr)
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wli.reporting.jmsprovider_error.queue_auto')
      aaa = create(errorQueue,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wli.reporting.jmsprovider_error.queue_auto/DistributedQueueMember/' + errorQueue)
      set('Weight',1)

      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      reportingQueue = 'wli.reporting.jmsprovider.queue_auto_'+str(serverCnt)
      udd=create(reportingQueue,'Queue')
      udd.setJNDIName(reportingQueue)
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (reportingQueue)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Redirect')
      dfp.setErrorDestination(uddErr)
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wli.reporting.jmsprovider.queue_auto')
      aaa = create(reportingQueue,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wli.reporting.jmsprovider.queue_auto/DistributedQueueMember/' + reportingQueue)
      set('Weight',1)

      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      emailQueue = 'wlsb.internal.transport.task.queue.email_auto_'+str(serverCnt)
      udd=create(emailQueue,'Queue')
      udd.setJNDIName(emailQueue)
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (emailQueue)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.email_auto')
      aaa = create(emailQueue,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.email_auto/DistributedQueueMember/' + emailQueue)
      set('Weight',1)


      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      fileQueue = 'wlsb.internal.transport.task.queue.file_auto_'+str(serverCnt)
      udd=create(fileQueue,'Queue')
      udd.setJNDIName(fileQueue)
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (fileQueue)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.file_auto')
      aaa = create(fileQueue,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.file_auto/DistributedQueueMember/' + fileQueue)
      set('Weight',1)

      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      ftpQueue = 'wlsb.internal.transport.task.queue.ftp_auto_'+str(serverCnt)
      udd=create(ftpQueue,'Queue')
      udd.setJNDIName(ftpQueue)
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (ftpQueue)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.ftp_auto')
      aaa = create(ftpQueue,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.ftp_auto/DistributedQueueMember/' + ftpQueue)
      set('Weight',1)

      cd('/')
      cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

      sftpQueue = 'wlsb.internal.transport.task.queue.sftp_auto_'+str(serverCnt)
      udd=create(sftpQueue,'Queue')
      udd.setJNDIName(sftpQueue)
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (sftpQueue)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.sftp_auto')
      aaa = create(sftpQueue,'DistributedQueueMember')
      cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/DistributedQueue/dist_wlsb.internal.transport.task.queue.sftp_auto/DistributedQueueMember/' + sftpQueue)
      set('Weight',1)

      serverCnt = serverCnt + 1


  cd('/')
  cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

  purgeQueue = 'wli.reporting.purge.queue'
  udd=create(purgeQueue,'Queue')
  udd.setJNDIName(purgeQueue)
  udd.setSubDeploymentName('wlsbJMSServer1_sub')
  cd ('Queue')
  cd (purgeQueue)
  #dpo = create('dpoName','DeliveryParamsOverrides')
  #dpo.setRedeliveryDelay(15*60*1000)
  dfp = create('dfpName', 'DeliveryFailureParams')
  dfp.setRedeliveryLimit(2)
  dfp.setExpirationPolicy('Discard')

  cd('/')
  cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')


  osbcf=create('weblogic.wlsb.jms.transporttask.QueueConnectionFactory','ConnectionFactory')
  osbcf.setJNDIName('weblogic.wlsb.jms.transporttask.QueueConnectionFactory')
  cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/ConnectionFactory/weblogic.wlsb.jms.transporttask.QueueConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

  osbcf=create('wli.reporting.jmsprovider.ConnectionFactory','ConnectionFactory')
  osbcf.setJNDIName('wli.reporting.jmsprovider.ConnectionFactory')
  cd('/JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0/ConnectionFactory/wli.reporting.jmsprovider.ConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/jmsResourcesUDDs/JmsResource/NO_NAME_0')

  createJMSServersSB(cluster, 'wsee', 1)

  cd('/')
  create('WseeJmsModuleUDDs','JMSSystemResource')

  cd('/')
  cd('JMSSystemResource/WseeJmsModuleUDDs')
  assign('JMSSystemResource', 'WseeJmsModuleUDDs', 'Target', cluster)

  print ' '
  print ("*** Listing OSB JMS Servers ***")
  s = ls('/JMSServers')
  osbJMSServerStr=''
  serverCnt =  1
  for token in s.split("drw-"):
    token=token.strip().lstrip().rstrip()
    if not token.find("WseeJmsServer_auto") == -1:
      print token
      cd('/')
      cd('JMSSystemResource/WseeJmsModuleUDDs')
      subDeploymentStr = 'WseeJmsServer_auto_'+str(serverCnt)+'-Sub'
      create(subDeploymentStr, 'SubDeployment')

      cd('/')
      cd('JMSSystemResource/WseeJmsModuleUDDs/SubDeployments/'+subDeploymentStr)
      assign('JMSSystemResource.SubDeployment', 'WseeJmsModuleUDDs.'+subDeploymentStr, 'Target', token) 

      cd('/')
      cd('JMSSystemResource/WseeJmsModuleUDDs/JmsResource/NO_NAME_0')

      callBackQueue = 'DefaultCallbackQueue-WseeJmsServer_auto_'+str(serverCnt)
      udd=create(callBackQueue,'Queue')
      udd.setJNDIName('weblogic.wsee.DefaultCallbackQueue-WseeJmsServer_auto_'+str(serverCnt))
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (callBackQueue)
      #dpo = create('dpoName','DeliveryParamsOverrides')
      #dpo.setRedeliveryDelay(15*60*1000)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')

      cd('/')
      cd('JMSSystemResource/WseeJmsModuleUDDs/JmsResource/NO_NAME_0')
      wseeQueue = 'DefaultQueue-WseeJmsServer_auto_'+str(serverCnt)
      udd=create(wseeQueue,'Queue')
      udd.setJNDIName('weblogic.wsee.DefaultQueue-WseeJmsServer_auto_'+str(serverCnt))
      udd.setSubDeploymentName(subDeploymentStr)
      cd ('Queue')
      cd (wseeQueue)
      #dpo = create('dpoName','DeliveryParamsOverrides')
      #dpo.setRedeliveryDelay(15*60*1000)
      dfp = create('dfpName', 'DeliveryFailureParams')
      dfp.setRedeliveryLimit(2)
      dfp.setExpirationPolicy('Discard')

      serverCnt = serverCnt + 1


def createJMSServersBAM12c(cluster, track, currentServerCnt):
  print ' '
  print "Creating JMS Servers for the cluster :- ", cluster
  s = ls('/Server')
  print ' '
  clustername = " "
  serverCnt = currentServerCnt
  for token in s.split("drw-"):
    token=token.strip().lstrip().rstrip()
    path="/Server/"+token
    cd(path)
    if not token == 'AdminServer' and not token == '':
      clustername = get('Cluster')
      print "Cluster Associated with the Server [",token,"] :- ",clustername
      print ' '
      searchClusterStr = cluster+":"
      clusterNameStr = str(clustername)
      print "searchClusterStr = ",searchClusterStr
      print "clusterNameStr = ",clusterNameStr
      if not clusterNameStr.find(searchClusterStr) == -1:
        print token, " is associated with ", cluster
        print ' '
        print "Creating JMS Servers for ", track
        print ' '
        cd('/')

        if track == 'bam':
          jmsServerName = 'BamCQServiceJmsServer_auto_'+str(serverCnt)
          fileStoreName = 'BamCQServiceJmsFileStore_auto_'+str(serverCnt)

        createFileStore(fileStoreName, token)
        print "Created File Store :- ", fileStoreName

        create(jmsServerName, 'JMSServer')
        print "Created JMS Server :- ", jmsServerName
        print ' '
        assign('JMSServer', jmsServerName, 'Target', token)
        print jmsServerName, " assigned to server :- ", token
        print ' '
        cd('/JMSServer/'+jmsServerName)
        set ('PersistentStore', fileStoreName)

        if track == 'wsee':
          safAgent     = 'ReliableWseeSAFAgent_auto_'+str(serverCnt)

          cd('/')
          create(safAgent, 'SAFAgent')
          cd('/SAFAgent/'+safAgent)
          set ('Target'     , token)
          set ('Store'      , fileStoreName)
          set ('ServiceType','Both')

        serverCnt = serverCnt + 1

def BAMJms12c(cluster):

  createJMSServersBAM12c(cluster, 'bam', 1)

  print "create BAM CQ JMSSystemResource"
  cd('/')
  create('BamCQServiceJmsSystemResource','JMSSystemResource')

  print "target BAM CQ JMSSystemResource"
  cd('/')
  cd('JMSSystemResource/BamCQServiceJmsSystemResource')
  assign('JMSSystemResource', 'BamCQServiceJmsSystemResource', 'Target', cluster)

  print "subdeployment BAM CQ JMSSystemResource"
  cd('/')
  cd('JMSSystemResource/BamCQServiceJmsSystemResource')
  create('BamCQServiceAlertEngineSubdeployment', 'SubDeployment')

  cd('/')
  cd('JMSSystemResource/BamCQServiceJmsSystemResource/SubDeployments/BamCQServiceAlertEngineSubdeployment')

  print ' '
  print ("*** Listing Bam CQ JMS Servers ***")
  s = ls('/JMSServers')
  bamJMSServerStr=''
  for token in s.split("drw-"):
    token=token.strip().lstrip().rstrip()
    if not token.find("BamCQServiceJmsServer_auto") == -1:
      bamJMSServerStr = bamJMSServerStr + token +","
    print token

  print ("*** Setting JMS SubModule for BamCQ JMS Server's target***")
  assign('JMSSystemResource.SubDeployment', 'BamCQServiceJmsSystemResource.BamCQServiceAlertEngineSubdeployment', 'Target', bamJMSServerStr)

  cd('/')
  cd('JMSSystemResource/BamCQServiceJmsSystemResource/JmsResource/NO_NAME_0')

  udd=create('BamCQServiceAlertEngineQueue','UniformDistributedQueue')
  udd.setJNDIName('queue/oracle.beam.cqservice.mdbs.alertengine')
  udd.setSubDeploymentName('BamCQServiceAlertEngineSubdeployment')

  udd=create('BamCQServiceReportCacheQueue','UniformDistributedQueue')
  udd.setJNDIName('queue/oracle.beam.cqservice.mdbs.reportcache')
  udd.setSubDeploymentName('BamCQServiceAlertEngineSubdeployment')

  soacf=create('BamCQServiceAlertEngineConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('queuecf/oracle.beam.cqservice.mdbs.alertengine')
  cd('/JMSSystemResource/BamCQServiceJmsSystemResource/JmsResource/NO_NAME_0/ConnectionFactory/BamCQServiceAlertEngineConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)

  cd('/')
  cd('JMSSystemResource/BamCQServiceJmsSystemResource/JmsResource/NO_NAME_0')

  soacf=create('BamCQServiceReportCacheConnectionFactory','ConnectionFactory')
  soacf.setJNDIName('queuecf/oracle.beam.cqservice.mdbs.reportcache')
  cd('/JMSSystemResource/BamCQServiceJmsSystemResource/JmsResource/NO_NAME_0/ConnectionFactory/BamCQServiceReportCacheConnectionFactory')
  set('DefaultTargetingEnabled', 'true')
  create('TransactionParams', 'TransactionParams')
  cd('TransactionParams/NO_NAME_0')
  cmo.setXAConnectionFactoryEnabled(true)


def createUMSJMSServers(cluster, track, currentServerCnt, adminserver_name):
    print ' '
    print "Creating JMS Servers for the cluster :- ", cluster
    s = ls('/Server')
    print ' '
    clustername = " "
    serverCnt = currentServerCnt
    for token in s.split("drw-"):
        token=token.strip().lstrip().rstrip()
        path="/Server/"+token
        cd(path)
        if not token == adminserver_name and not token == '':
            clustername = get('Cluster')
            print "Cluster Associated with the Server [",token,"] :- ",clustername
            print ' '
            searchClusterStr = cluster+":"
            clusterNameStr = str(clustername)
            print "searchClusterStr = ",searchClusterStr
            print "clusterNameStr = ",clusterNameStr
            if not clusterNameStr.find(searchClusterStr) == -1:
                print token, " is associated with ", cluster
                print ' '
                print "Creating JMS Servers for ", track
                print ' '
                cd('/')

                if track == 'ums':
                    jmsServerName = 'UMSJMSServer_auto_'+str(serverCnt)
                    fileStoreName = 'UMSJMSFileStore_auto_'+str(serverCnt)


                createFileStore(fileStoreName, token)
                print "Created File Store :- ", fileStoreName

                create(jmsServerName, 'JMSServer')
                print "Created JMS Server :- ", jmsServerName
                print ' '
                assign('JMSServer', jmsServerName, 'Target', token)
                print jmsServerName, " assigned to server :- ", token
                print ' '
                cd('/JMSServer/'+jmsServerName)
                set ('PersistentStore', fileStoreName)

                serverCnt = serverCnt + 1

def getCurrentUMSServerCnt():
    s = ls('/JMSServer')
    count = s.count("UMSJMSServer_auto")
    return count + 1

def getUMSJMSServers(cluster, adminserver_name):
    s = ls('/JMSServers')
    jmsServersStr = " "
    print ' '
    clustername = " "
    for token in s.split("drw-"):
        token=token.strip().lstrip().rstrip()
        if not token == '' and not token.find("UMSJMSServer_auto") == -1:
            cd('/JMSServers/'+token)
            targetServer = get('Target')
            clustername = getClusterName(targetServer, adminserver_name)
            searchClusterStr = cluster+":"
            clusterNameStr = str(clustername)
            print "searchClusterStr = ",searchClusterStr
            print "clusterNameStr = ",clusterNameStr
            if not clusterNameStr.find(searchClusterStr) == -1:
                    jmsServersStr = jmsServersStr + token + ","
    print "UMS JMS Servers for Cluster :- ", cluster , " is :- ", jmsServersStr
    return jmsServersStr

def recreateUMSJms12c(adminserver_name, soa_cluster, osb_cluster, bam_cluster, ess_cluster, all_clusters):

    if soa_cluster:
        print "fix SOA UMS JMS"
        createUMSJMSServers(soa_cluster, 'ums', getCurrentUMSServerCnt(), adminserver_name)

    if osb_cluster:
        print "fix BAM UMS JMS"
        createUMSJMSServers(osb_cluster, 'ums', getCurrentUMSServerCnt(), adminserver_name)

    if bam_cluster:
        print "fix OSB UMS JMS"
        createUMSJMSServers(bam_cluster, 'ums', getCurrentUMSServerCnt(), adminserver_name)

    if ess_cluster:
        print "fix ESS UMS JMS"
        createUMSJMSServers(ess_cluster, 'ums', getCurrentUMSServerCnt(), adminserver_name)


    print "create UMSJMSSystemResource"
    cd('/')
    create('UMSJMSSystemResource','JMSSystemResource')

    print "target UMSJMSSystemResource"
    cd('/')
    cd('JMSSystemResource/UMSJMSSystemResource')
    assign('JMSSystemResource', 'UMSJMSSystemResource', 'Target', all_clusters)

    print("*** Creating Connection Factories for UMS ***");
    cd('/')
    cd('JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')

    cf1=create('OraSDPMQueueConnectionFactory','ConnectionFactory')
    cf1.setJNDIName('OraSDPM/QueueConnectionFactory')

    print ("*** Enabling XA ***")
    cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0/ConnectionFactory/OraSDPMQueueConnectionFactory')
    set('DefaultTargetingEnabled', 'true')
    create('TransactionParams', 'TransactionParams')
    cd('TransactionParams/NO_NAME_0')
    cmo.setXAConnectionFactoryEnabled(true)
    cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0/ConnectionFactory/OraSDPMQueueConnectionFactory')
    create('DefaultDeliveryParams', 'DefaultDeliveryParams')
    cd('DefaultDeliveryParams/NO_NAME_0')
    cmo.setDefaultDeliveryMode('Persistent')
    cmo.setDefaultRedeliveryDelay(400)

    cd('/')
    cd('JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
    dk1=create('Priority','DestinationKey')
    dk1.setProperty('JMSPriority')
    dk1.setKeyType('Int')
    dk1.setSortOrder('Descending')

    if soa_cluster:

        print "create subdeployment SOA UMS JMS"
        cd('/')
        cd('JMSSystemResource/UMSJMSSystemResource')
        create('UMSJMSSubDMSOA', 'SubDeployment')

        umsJMSServerStr = getUMSJMSServers(soa_cluster, adminserver_name)
        umsJMSServerStr = umsJMSServerStr.strip().lstrip().rstrip()
        assign('JMSSystemResource.SubDeployment', 'UMSJMSSystemResource.UMSJMSSubDMSOA', 'Target', umsJMSServerStr)

        print ("*** Creating Queues for UMS ***")
        cd('/')
        print ' '

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd= create('OraSDPMEngineSndQ1_soa','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMSOA')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMEngineSndQ1_soa')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEngineRcvQ1_soa','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMSOA')
        cd ('UniformDistributedQueue/OraSDPMEngineRcvQ1_soa')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMDriverDefSndQ1_soa','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMDriverDefSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMSOA')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMDriverDefSndQ1_soa')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        uddError=create('OraSDPMAppDefRcvErrorQ1_soa','UniformDistributedQueue')
        uddError.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvErrorQ1')
        uddError.setSubDeploymentName('UMSJMSSubDMSOA')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMAppDefRcvQ1_soa','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMSOA')
        cd ('UniformDistributedQueue/OraSDPMAppDefRcvQ1_soa')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')
        dfp.setErrorDestination(uddError)

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMWSRcvQ1_soa','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMWSRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMSOA')
        cd ('UniformDistributedQueue/OraSDPMWSRcvQ1_soa')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEnginePendingRcvQ_soa','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEnginePendingRcvQ')
        udd.setSubDeploymentName('UMSJMSSubDMSOA')
        cd ('UniformDistributedQueue/OraSDPMEnginePendingRcvQ_soa')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

    if bam_cluster:
        print "create subdeployment BAM UMS JMS"
        cd('/')
        cd('JMSSystemResource/UMSJMSSystemResource')
        create('UMSJMSSubDMBAM', 'SubDeployment')

        umsJMSServerStr = getUMSJMSServers(bam_cluster, adminserver_name)
        umsJMSServerStr = umsJMSServerStr.strip().lstrip().rstrip()
        assign('JMSSystemResource.SubDeployment', 'UMSJMSSystemResource.UMSJMSSubDMBAM', 'Target', umsJMSServerStr)

        print ("*** Creating Queues for UMS ***")
        cd('/')
        print ' '

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd= create('OraSDPMEngineSndQ1_bam','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMBAM')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMEngineSndQ1_bam')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEngineRcvQ1_bam','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMBAM')
        cd ('UniformDistributedQueue/OraSDPMEngineRcvQ1_bam')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMDriverDefSndQ1_bam','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMDriverDefSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMBAM')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMDriverDefSndQ1_bam')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        uddError=create('OraSDPMAppDefRcvErrorQ1_bam','UniformDistributedQueue')
        uddError.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvErrorQ1')
        uddError.setSubDeploymentName('UMSJMSSubDMBAM')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMAppDefRcvQ1_bam','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMBAM')
        cd ('UniformDistributedQueue/OraSDPMAppDefRcvQ1_bam')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')
        dfp.setErrorDestination(uddError)

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMWSRcvQ1_bam','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMWSRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMBAM')
        cd ('UniformDistributedQueue/OraSDPMWSRcvQ1_bam')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEnginePendingRcvQ_bam','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEnginePendingRcvQ')
        udd.setSubDeploymentName('UMSJMSSubDMBAM')
        cd ('UniformDistributedQueue/OraSDPMEnginePendingRcvQ_bam')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

    if osb_cluster:
        print "create subdeployment OSB UMS JMS"
        cd('/')
        cd('JMSSystemResource/UMSJMSSystemResource')
        create('UMSJMSSubDMOSB', 'SubDeployment')

        umsJMSServerStr = getUMSJMSServers(osb_cluster, adminserver_name)
        umsJMSServerStr = umsJMSServerStr.strip().lstrip().rstrip()
        assign('JMSSystemResource.SubDeployment', 'UMSJMSSystemResource.UMSJMSSubDMOSB', 'Target', umsJMSServerStr)

        print ("*** Creating Queues for UMS ***")
        cd('/')
        print ' '

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd= create('OraSDPMEngineSndQ1_osb','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMOSB')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMEngineSndQ1_osb')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEngineRcvQ1_osb','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMOSB')
        cd ('UniformDistributedQueue/OraSDPMEngineRcvQ1_osb')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMDriverDefSndQ1_osb','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMDriverDefSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMOSB')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMDriverDefSndQ1_osb')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        uddError=create('OraSDPMAppDefRcvErrorQ1_osb','UniformDistributedQueue')
        uddError.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvErrorQ1')
        uddError.setSubDeploymentName('UMSJMSSubDMOSB')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMAppDefRcvQ1_osb','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMOSB')
        cd ('UniformDistributedQueue/OraSDPMAppDefRcvQ1_osb')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')
        dfp.setErrorDestination(uddError)

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMWSRcvQ1_osb','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMWSRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMOSB')
        cd ('UniformDistributedQueue/OraSDPMWSRcvQ1_osb')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEnginePendingRcvQ_osb','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEnginePendingRcvQ')
        udd.setSubDeploymentName('UMSJMSSubDMOSB')
        cd ('UniformDistributedQueue/OraSDPMEnginePendingRcvQ_osb')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

    if ess_cluster:
        print "create subdeployment ESS UMS JMS"
        cd('/')
        cd('JMSSystemResource/UMSJMSSystemResource')
        create('UMSJMSSubDMESS', 'SubDeployment')

        umsJMSServerStr = getUMSJMSServers(ess_cluster, adminserver_name)
        umsJMSServerStr = umsJMSServerStr.strip().lstrip().rstrip()
        assign('JMSSystemResource.SubDeployment', 'UMSJMSSystemResource.UMSJMSSubDMESS', 'Target', umsJMSServerStr)

        print ("*** Creating Queues for UMS ***")
        cd('/')
        print ' '

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd= create('OraSDPMEngineSndQ1_ess','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMESS')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMEngineSndQ1_ess')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEngineRcvQ1_ess','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEngineRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMESS')
        cd ('UniformDistributedQueue/OraSDPMEngineRcvQ1_ess')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMDriverDefSndQ1_ess','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMDriverDefSndQ1')
        udd.setSubDeploymentName('UMSJMSSubDMESS')
        udd.setDestinationKeys(jarray.array([String('Priority')],String))
        cd ('UniformDistributedQueue/OraSDPMDriverDefSndQ1_ess')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        uddError=create('OraSDPMAppDefRcvErrorQ1_ess','UniformDistributedQueue')
        uddError.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvErrorQ1')
        uddError.setSubDeploymentName('UMSJMSSubDMESS')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMAppDefRcvQ1_ess','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMAppDefRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMESS')
        cd ('UniformDistributedQueue/OraSDPMAppDefRcvQ1_ess')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')
        dfp.setErrorDestination(uddError)

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMWSRcvQ1_ess','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMWSRcvQ1')
        udd.setSubDeploymentName('UMSJMSSubDMESS')
        cd ('UniformDistributedQueue/OraSDPMWSRcvQ1_ess')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')

        cd('/JMSSystemResource/UMSJMSSystemResource/JmsResource/NO_NAME_0')
        udd=create('OraSDPMEnginePendingRcvQ_ess','UniformDistributedQueue')
        udd.setJNDIName('OraSDPM/Queues/OraSDPMEnginePendingRcvQ')
        udd.setSubDeploymentName('UMSJMSSubDMESS')
        cd ('UniformDistributedQueue/OraSDPMEnginePendingRcvQ_ess')
        dfp = create('dfpName', 'DeliveryFailureParams')
        dfp.setRedeliveryLimit(2)
        dfp.setExpirationPolicy('Log')


def sb12c(cluster):
  createJMSServersSB(cluster, 'wsee', 1)

  cd('/')
  create('WseeJmsModule','JMSSystemResource')

  cd('/')
  cd('JMSSystemResource/WseeJmsModule')
  assign('JMSSystemResource', 'WseeJmsModule', 'Target', cluster)

  print ' '
  print ("*** Listing OSB JMS Servers ***")
  s = ls('/JMSServers')
  osbJMSServerStr=''
  serverCnt =  1
  for token in s.split("drw-"):
    token=token.strip().lstrip().rstrip()
    if not token.find("WseeJmsServer_auto") == -1:
      print token
      cd('/')
      cd('JMSSystemResource/WseeJmsModule')
      subDeploymentStr = 'WseeJmsServer_auto_'+str(serverCnt)+'-Sub'
      create(subDeploymentStr, 'SubDeployment')

      cd('/')
      cd('JMSSystemResource/WseeJmsModule/SubDeployments/'+subDeploymentStr)
      assign('JMSSystemResource.SubDeployment', 'WseeJmsModule.'+subDeploymentStr, 'Target', token) 

      cd('/')
      cd('JMSSystemResource/WseeJmsModule/JmsResource/NO_NAME_0')

      callBackQueue = 'DefaultCallbackQueue-WseeJmsServer_auto_'+str(serverCnt)
      udd=create(callBackQueue,'Queue')
      udd.setJNDIName('weblogic.wsee.DefaultCallbackQueue-WseeJmsServer_auto_'+str(serverCnt))
      udd.setLocalJNDIName('weblogic.wsee.DefaultCallbackQueue')
      udd.setSubDeploymentName(subDeploymentStr)

      cd('/')
      cd('JMSSystemResource/WseeJmsModule/JmsResource/NO_NAME_0')
      wseeQueue = 'DefaultQueue-WseeJmsServer_auto_'+str(serverCnt)
      udd=create(wseeQueue,'Queue')
      udd.setJNDIName('weblogic.wsee.DefaultQueue-WseeJmsServer_auto_'+str(serverCnt))
      udd.setLocalJNDIName('weblogic.wsee.DefaultQueue')
      udd.setSubDeploymentName(subDeploymentStr)

      serverCnt = serverCnt + 1