BPM Express Edition for messaging integration
Use the script in Example B-1 to achieve the required configuration on IBM Business Process Manager Express Edition for messaging integration with IBM InfoSphere Master Data Management (MDM) Advanced Edition.
Example B-1 BPM Express Edition configuration for messaging integration with MDM
################################################################################
# Content of file BPMSetupApp.py
################################################################################
import sys
################################################################################
#
# Functions:
#
#
# createJAASAuthData
# setupDeployServer
# createJDBCProvider
# createDatasource
# setOracleDatasourceCustomProperties
# getJMSProvider
# createMQQueueConnectionFactory
# createMQQueue
# createMQTopicConnectionFactory
# createMQTopic
# createWASQueueConnectionFactory
# createWASQueue
# createWASTopicConnectionFactory
# createWASTopic
# createMessageListenerPort
# setWASVariablesForMQ
# createAlias
# printUsage
#
 
def createForeignBus (clusterName,nodeName,serverName,SIBusName,foreignBusName,userId):
#--------------------------------------------------------------------
# up globals
#--------------------------------------------------------------------
global AdminConfig
global AdminTask
#--------------------------------------------------------------------
# Create Foreign Bus
#--------------------------------------------------------------------
print ""
print "---------------------------------------------------------------"
print " Create Foreign Bus "
print "---------------------------------------------------------------"
print " Foreign Bus: "
print " name "+foreignBusName+" "
print " SI bus: "
print " name "+SIBusName+" "
print "---------------------------------------------------------------"
print ""
#--------------------------------------------------------------------
# Create Foreign Bus
#--------------------------------------------------------------------
print " Creating a new Foreign Bus Link named "+foreignBusName+"..."
if clusterName != "None":
params="[-bus "+SIBusName+" -name "+foreignBusName+" -routingType Direct -type SIBus ]"
else:
params="[-bus "+SIBusName+" -name "+foreignBusName+" -routingType Direct -type SIBus -inboundUserid userId]"
try:
AdminTask.createSIBForeignBus(params)
except:
print " The "+foreignBusName+" foreign bus already exists"
 
 
def createForeignBusLink (clusterName,nodeName,serverName,SIBusName,foreignBusName,foreignBusMessagingEngineName,SIBLinkName,endpoint):
#--------------------------------------------------------------------
# up globals
#--------------------------------------------------------------------
global AdminConfig
global AdminTask
#--------------------------------------------------------------------
# Create Foreign Bus
#--------------------------------------------------------------------
print ""
print "---------------------------------------------------------------"
print " Create Foreign Bus "
print "---------------------------------------------------------------"
print " Foreign Bus: "
print " name "+foreignBusName+" "
print " SI bus: "
print " name "+SIBusName+" "
print "---------------------------------------------------------------"
print ""
#--------------------------------------------------------------------
# Create Foreign Bus
#--------------------------------------------------------------------
if clusterName != "None":
localMessagingEngine = clusterName+".000-"+SIBusName
else:
localMessagingEngine = nodeName+"."+serverName+"-"+SIBusName
print " Creating a new SIB Link named "+SIBLinkName+"..."
 
params="[-bus "+SIBusName+" -messagingEngine "+localMessagingEngine+" -name "+SIBLinkName+" -foreignBusName "+foreignBusName+" -remoteMessagingEngineName "+foreignBusMessagingEngineName+" -bootstrapEndpoints "+endpoint+"]"
try:
AdminTask.createSIBLink(params)
except:
print " The "+SIBLinkName+" SIB Link already exists "
 
 
###########################################################
# This method create WAS6 Default JMS Provider.
###########################################################
def createDefaultJMSProvider (clusterName,nodeName,serverName,SIBusName,targetBusName,foreignBusMessagingEngineName,endPointPort,userId):
#-----------------------------------
# Create Foreign Bus
#----------------------------------
endpoint = "localhost:" + endPointPort + ":BootstrapBasicMessaging"
SIBLinkName="MDM_BPM_LINK"
createForeignBus (clusterName,nodeName,serverName,SIBusName,targetBusName,userId)
createForeignBusLink (clusterName,nodeName,serverName,SIBusName,targetBusName,foreignBusMessagingEngineName,SIBLinkName,endpoint)
################################################################################
# Prints the usage message
################################################################################
def printUsage ():
print ""
print "Usage:"
print ""
print " wsadmin -f BPMSetupApp.py"
print "ClusterName"
print "NodeName"
print "ServerName"
print "SIBusName"
print "ForeignBusName"
print "ForeignBusMessagingEngineName"
print "ForeignEndPointPort"
print "AdminUserIdOfBPM"
 
sys.exit(1)
 
 
################################################################################
# Main #
################################################################################
print "Number of arguments:"
print len(sys.argv)
if len(sys.argv) != 8:
printUsage()
sys.exit()
 
 
 
ClusterName = sys.argv[0];
NodeName = sys.argv[1];
ServerName = sys.argv[2];
SIBusName= sys.argv[3];
targetBusName=sys.argv[4];
targetBusMessagingEngineName=sys.argv[5];
targetBusEndPointPort=sys.argv[6];
userId = sys.argv[7];
 
 
 
 
print ""
print "Setting up application server for MDM BPM Integration ..."
print " Cluster name : "+ClusterName
print " Node name : "+NodeName
print " Server name : "+ServerName
print " SI Bus name : "+SIBusName
print " Target SI Bus name : "+targetBusName
print " Target SI Messaging Engine Name : "+targetBusMessagingEngineName
print " Target SI EndPoint Port : "+targetBusEndPointPort
print " Admin User Id of BPM : "+userId
print ""
 
 
 
 
#^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^#
# WAS or MQ JMS Queue Connection Factories #
#------------------------------------------------------------------------------#
 
createDefaultJMSProvider (ClusterName,NodeName,ServerName,SIBusName,targetBusName,targetBusMessagingEngineName,targetBusEndPointPort,userId);
 
#^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^#
# Save server configuration
#------------------------------------------------------------------------------#
print ""
if ClusterName != "None":
print " Saving configuration changes for cluster '"+ClusterName+"'...."
else:
print " Saving configuration changes for server '"+ServerName+"'..."
AdminConfig.save()
 
 
#^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^#
# Done
#------------------------------------------------------------------------------#
print ""
print " Done setting up environment."
print ""
 
 
..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.
Reset