files/providers/wls_messaging_bridge/index.py.erb
m = ls('/MessagingBridges',returnMap='true')
f = open_file("name;target;targettype;asyncenabled;batchinterval;batchsize;durabilityenabled;idletimemax;preservemsgproperty;qosdegradationallowed;qos;reconnectdelayincrease;reconnectdelaymax;reconnectdelaymin;selector;started;transactiontimeout;sourcedestination;targetdestination")
for token in m:
print '___'+token+'___'
cd('/MessagingBridges/'+token)
asyncenabled = get('AsyncEnabled')
batchinterval = get('BatchInterval')
batchsize = get('BatchSize')
durabilityenabled = get('DurabilityEnabled')
idletimemax = get('IdleTimeMaximum')
preservemsgproperty = get('PreserveMsgProperty')
qosdegradationallowed = get('QOSDegradationAllowed')
qos = get('QualityOfService')
reconnectdelayincrease = get('ReconnectDelayIncrease')
reconnectdelaymax = get('ReconnectDelayMaximum')
reconnectdelaymin = get('ReconnectDelayMinimum')
selector = get('Selector')
started = get('Started')
transactiontimeout = get('TransactionTimeout')
sourcedestinationMbean = cmo.getSourceDestination()
if sourcedestinationMbean:
path = getPath(sourcedestinationMbean)
cd("/"+path)
sourcedestination = get('Name')
cd('/MessagingBridges/'+token)
else:
sourcedestination = ''
targetdestinationMbean = cmo.getTargetDestination()
if targetdestinationMbean:
path = getPath(targetdestinationMbean)
cd("/"+path)
targetdestination = get('Name')
cd('/MessagingBridges/'+token)
else:
targetdestination = ''
target, targetType = retrieve_target_list('/Deployments/'+token)
add_index_entry(f, [domain+'/'+token,','.join(target),','.join(targetType),asyncenabled,batchinterval,batchsize,durabilityenabled,idletimemax,preservemsgproperty,qosdegradationallowed,qos,reconnectdelayincrease,reconnectdelaymax,reconnectdelaymin,selector,started,transactiontimeout,sourcedestination,targetdestination])
f.close()
report_back_success()