createJmsConnectionFactory.py.erb 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. wlsUser = '<%= @wlsUser %>'
  2. password = '<%= @password %>'
  3. machine = '<%= @address %>'
  4. portNumber = '<%= @port %>'
  5. subDeploymentName = ""
  6. #subDeploymentName, jmsModuleName, cfName,cfJNDIName,transacted,timeout
  7. <% @params.each do |param| -%>
  8. <%= param %>
  9. <% end -%>
  10. useStoreConfig = '<%= @useStoreConfig %>'
  11. if useStoreConfig != "true":
  12. connect(wlsUser,password,'t3://'+machine+':'+portNumber)
  13. else:
  14. connect(userConfigFile='<%= @userConfigFile %>', userKeyFile='<%= @userKeyFile %>', url='t3://'+machine+':'+portNumber)
  15. print "subDeploymentName: ", subDeploymentName, " jmsModule: ", jmsModuleName, "cfName: ",cfName , "cfJNDIName: ",cfJNDIName
  16. edit()
  17. startEdit()
  18. try:
  19. cd('/')
  20. cd('/JMSSystemResources/'+jmsModuleName+'/JMSResource/'+jmsModuleName)
  21. cmo.createConnectionFactory(cfName)
  22. #cd('/JMSSystemResources/'+jmsModuleName+'/JMSResource/'+jmsModuleName+'/ConnectionFactories/'+cfName+'/SecurityParams/'+cfName)
  23. #cmo.setAttachJMSXUserId(false)
  24. #cd('/JMSSystemResources/'+jmsModuleName+'/JMSResource/'+jmsModuleName+'/ConnectionFactories/'+cfName+'/ClientParams/'+cfName)
  25. #cmo.setClientIdPolicy('Restricted')
  26. #cmo.setSubscriptionSharingPolicy('Exclusive')
  27. #cmo.setMessagesMaximum(10)
  28. cd('/JMSSystemResources/'+jmsModuleName+'/JMSResource/'+jmsModuleName+'/ConnectionFactories/'+cfName)
  29. cmo.setJNDIName(cfJNDIName)
  30. if subDeploymentName:
  31. cmo.setDefaultTargetingEnabled(false)
  32. cmo.setSubDeploymentName(subDeploymentName)
  33. else:
  34. cmo.setDefaultTargetingEnabled(true)
  35. if transacted == "true":
  36. cd('/JMSSystemResources/'+jmsModuleName+'/JMSResource/'+jmsModuleName+'/ConnectionFactories/'+cfName+'/TransactionParams/'+cfName)
  37. cmo.setXAConnectionFactoryEnabled(true)
  38. cmo.setTransactionTimeout( int(timeout) )
  39. save()
  40. activate()
  41. except:
  42. print "Unexpected error:", sys.exc_info()[0]
  43. undo('true','y')
  44. stopEdit('y')
  45. raise